Nuxt CNode：Node.js专业中文社区

koa初学的example运行抛出异常？

发布于 10 年前作者 Web-Kevin 15603 次预览最后一次回复是 9 年前来自问答

lz最近刚接触nodejs，

使用koa写了这个 https://github.com/koajs/koa#example 例子

const Koa = require('koa');
const app = new Koa();

// logger

app.use((ctx, next) => {
  const start = new Date;
  return next().then(() => {
    const ms = new Date - start;
    console.log(`${ctx.method} ${ctx.url} - ${ms}ms`);
  });
});

// response

app.use(ctx => {
  ctx.body = 'Hello World';
});

app.listen(3000);

但每次运行都是有

	assert.js:89
	throw new assert.AssertionError({
	^
   AssertionError: app.use() requires a generator function

网上搜到了 https://github.com/alexmingoia/koa-router/issues/177 可是还是抛出同样异常

所以来请教各位大神

还有没有express经验直接学koa学习曲线怎么样？

7 回复

lian774739140

1楼•10 年前

我也刚开始学，感觉是你的koa版本有点旧，还不支持非generator function 自豪地采用 CNodeJS ionic

Web-Kevin

2楼•10 年前

@lian774739140 我之前也怀疑，查了是1.1.2，最新的是2.0.0-alpha.3 我去下个试试多谢

yakczh

3楼•9 年前

升级了koa2 提示 constructor() { ^ TypeError: Class constructors cannot be invoked without ‘new’

zstxt1989

4楼•9 年前

中间件必须是个generator，就是带星号的函数，而且你代码中用的ctx这是koa2的写法，但你装的好像是koa1？总之提供两种写法供你参考一下吧

koa1

	app.use(funciton*(next){
		console.log("step1")
		yield next
		console.log("step3")
		this.body = "hello"
	})
	app.use(function*(next){
		console.log("step2");
	})

koa2

	app.use(async function(ctx,next){
		console.log("step1")
		await next()
		console.log("step3")
		ctx.body = "hello"
	})
	app.use(async function(next){
		console.log("step2");
	})

koa2需要用babel转换成es5代码才能运行

i5ting

5楼•9 年前

使用这个吧https://github.com/17koa/koa-generator

yakczh

6楼•9 年前

@zstxt1989 中间件里需要要传入额外的参数呢,比如打印日志appender 或者打印格式打印详细/简要等级这些参数从哪里传进去呢?

zstxt1989

7楼•9 年前

@yakczh 中间件只接收三个参数:err,ctx,next，参数都在ctx里，你说的打印格式这种不就可以通过url传参控制么？

贴一段我的代码吧，献丑了

	/**
	 * Created by admin on 16/4/2.
	 */
	"use strict"
	
	//环境变量初始化,默认development环境
	process.env.NODE_ENV = process.env.NODE_ENV || 'development';
	
	require('source-map-support').install();
	require("babel-polyfill");
	var koa = require('koa');
	var morgan = require('koa-morgan');
	var configs = require('../configs');
	var redis = require('./components/redis');
	var mysql = require('./components/mysql');
	var ipnet = require('xz-ipnet')();
	
	const app = new koa();
	
	//自定义错误处理
	app.use(async (ctx, next) => {
	  try {
		await next()
		if (ctx.status === 404) ctx.throw(404)
	  } catch (err) {
		ctx.status = err.status || 500
		ctx.body = err.body || err.message
		console.error(ctx.url);
		console.error(err.toString());
		console.error(err.stack+"\n");
	  }
	})
	
	//访问日志,apache格式
	var logformat = {
	  production : ':remote-addr - :remote-user [:date[clf]] ":method :url HTTP/:http-version" :status :res[content-length] ":referrer" ":user-agent" - [:response-time ms]',
	  dev : 'dev'
	}
	app.use(morgan(app.env == 'production'?logformat.production:logformat.dev));
	
	//redis连接
	app.use(redis(configs.redis));
	
	//mysql连接池
	app.use(mysql(configs.database));
	
	//ip查询服务
	app.use(async function(ctx,next) {
	  ctx.ipnet = ipnet;
	  await next();
	});
	
	app.use(require('./routes').routes());
	
	app.on('error',(err,ctx) => {
	  console.error(ctx.url);
	  console.error(err);
	  console.error(err.stack);
	});
	
	
	app.proxy = true;
	app.listen(3000);