Title: 📨Message queue
Canonical: https://microi.net/en/doc/system-engine/mq.html
Page-Modified: 2026-03-22T10:27:14.000Z
Source: published HTML document body; page revision is not a capability verification date.

# 📨Message queue

The platform currently supports RabbitMQ message queues

---

## 📌Introduction

The platform currently supports RabbitMQ message queues.

---

## 🐳RabbitMQ Docker orchestration

- Port 1673 is web admin panel

Expand View Shell Commands (line 23)

shell

```
version: '3.8'
services:
  rabbitmq:
    image: rabbitmq:management-alpine
    container_name: rabbitmq
    restart: always
    tty: true
    stdin_open: true
    ports:
      - "1672:5672"
      - "1673:15672"
    environment:
      - RABBITMQ_DEFAULT_USER=root
      - RABBITMQ_DEFAULT_PASS=password123456
    volumes:
      - /etc/localtime:/etc/localtime
      - /volume1/docker/rabbitmq/lib:/var/lib/rabbitmq
      - /volume1/docker/rabbitmq/log:/var/log/rabbitmq
    logging:
      driver: "json-file"
      options:
        max-size: "10m"
        max-file: "10"
```

## SaaS Engine MQ Configuration

- MQHost:192.168.31.199

- MQPort:1672

- MQUserName:root

- MQPassword:password123456

- MQVitrualHost 😕

## Create a message queue

- [diy_queue_receive] Add a piece of data to the table, such:

- Type: Interface Engine

- QueueName:test_queue

- ApiEngineKey:messagetest

## Producing a message

Expand to view JavaScript code (20 lines)

js

```
//前端调用生产消息接口
V8.Post('/api/mq/sendmsg', {
  //必传：消息队列名称
  QueueName : 'test_queue',
  //必传：消息内容。如：抢购的商品Id + 数量
  Message : JSON.stringify({ ProductId : '123'， Count : 2}),
}, function(result){
  if(result.Code == 1){
    V8.Tips('生产消息成功！');
  }else{
    V8.Tips('生产消息失败：' + result.Msg, false);
  }
}, null, {}, 'json');

//后端接口引擎或后端V8事件调用生产消息接口
V8.MQ.SendMsg('test_queue', { 
  ProductId : '123'， 
  Count : 2
  }
);
```

## Consuming a message

- Automatically consumed in the interface engine [messagetest], because the ApiEngineKey specified when creating the message queue: messagetest

js

```
//接口引擎自动消费消息
//包含：Id（消息Id）、Message（消息内容）、CurrentUserId（生产消息的用户Id）
var message = V8.Param.Message;//object类型
var messageStr = JSON.stringify(message);
//实现您的业务逻辑，如扣除库存...
V8.Method.AddSysLog({
	Type : '消息队列消费者', //日志类型，自定义文字，如：接口日志、性能日志、登录日志等
	Title : '消息队列消费者', //日志标题，如：张三登录了系统
	Content: '消费消息：' + messageStr, //日志内容，如：张三在2024-12-12 20:13通过扫码登录了系统 
	OtherInfo : '', //其它信息，如：{ Append : 'test' }
	Remark : '', //日志备注
	Level : 1,//日志等级
});
return { Code : 1, Msg : '成功消费消息：' + messageStr };
```