service-msg/app/controller/home.js

'use strict';

const Controller = require('egg').Controller;

class HomeController extends Controller {
  async index() {
    const { ctx } = this;
    ctx.body = 'hi, egg';
  }

  async sendmq() {
    const { ctx } = this;
    // const msg = { userid: ctx.body.userid, name: ctx.body.name, createtime: ctx.body.createtime, type: ctx.body.type, content: ctx.body.content, remark: ctx.body.remark };
    const ex = 'schedule';
    const routekey = '11';
    const parm = { durable: true, headers: { userId: '2', type: '1', name: '哈哈' } };
    await this.service.rabbitmq.sendQueueMsg(ex, routekey, 'hhhsss', parm);
    this.ctx.body = '发送成功';
  }
}

module.exports = HomeController;