hh

app/controller/home.js

@@ -13,7 +13,11 @@ class HomeController extends Controller {
   async sendmq() {
     const { ctx, app } = this;
     console.log(msgValue.MsgValues.EXCHANGE_CROP_REG);
-    await this.service.rabbitmq.sendQueueMsg(ctx.query.exchange,ctx.query.routekey, new Buffer(JSON.stringify(ctx.query.msg)));
+    await this.service.rabbitmq.sendQueueMsg(ctx.query.exchange,ctx.query.routekey, new Buffer(JSON.stringify(ctx.query.msg)), (data) => 
+    {    
+       console.log(data);
+       
+    });
     ctx.body = '发送成功';
   }
 
@@ -22,6 +26,10 @@ class HomeController extends Controller {
     await this.service.rabbitmq.receiveQueueMsg(ctx.query.exchange,ctx.query.routekey,(msg) => 
     {    
        console.log(msg);
+ 
+      // 插入待办事项到数据库中。
+        
+
     });
     ctx.body = "接收成功";
   }

app/service/rabbitmq.js

@@ -27,7 +27,7 @@ class RabbitmqnewService extends Service {
   }
 
   // 发送消息
-  async sendQueueMsg(queueName, routeKey, msg) {
+  async sendQueueMsg(queueName, routeKey, msg, sendCallBack) {
     const self = this;
     const conn = await amqp.connect(self.hosts[self.index]);
     const ch = await conn.createConfirmChannel();
@@ -40,8 +40,10 @@ class RabbitmqnewService extends Service {
       console.log('==result==', result);
       if (result) {
         console.log('发送成功');
+        sendCallBack && sendCallBack(true);
       } else {
         console.log('发送失败');
+        sendCallBack && sendCallBack(false);
       }
       await ch.close();
     } catch (e) {