我们可以通过以下脚本来查询消息:
var filter = { "type": "custom_mq", "persion": "张三@zhangsan@p" } this.actions.load("x_message_assemble_communicate").messageaction.listpaging(1, 5, filter, function(json){ var msglist = json.data; //发送成功后的回调 });
打开配置文件o2server/config/messages.json(config下不存在可以从configsample拷贝过来),5.3后版本可以在web端登录系统,进入系统设置——基础配置——配套配置中找到messages.json,在文档末尾添加自定义消息类型的配置(示例):
"custom_mq": { "consumersv2": { "ws": "", "pms": "", "zhengwudingding": "", "qiyeweixin": "", "welink": "", "dingding": "" } }
其中custom_mq为自定义消息类型,名字必须以custom_开头,如需自定义发送websocket消息(消费者为ws)那么类型名字必须固定为custom_create,consumersv2中配置需要的消费者。
平台提供自定义消息发送的api,开发者根据业务需要调用接口发送消息,接口地址进入
http://{ip}:20020/x_message_assemble_communicate/jest/index.html,找到messageaction的customcreate服务,调用示例:
我们可以通过以下脚本来发送消息:
var msg = { "type": "custom_mq", "persion": "张三@zhangsan@p", "title": "测试消息发送", "body": "{"name": "张三", "textvalue": "测试"}" } this.actions.load("x_message_assemble_communicate").messageaction.customcreate(msg, function(json){ //发送成功后的回调 });
同样进入第二步的api服务地址,找到messageaction的listpaging服务,根据条件查询消息(平台默认保留7天的消息):
我们可以通过以下脚本来查询消息:
var filter = { "type": "custom_mq", "persion": "张三@zhangsan@p" } this.actions.load("x_message_assemble_communicate").messageaction.listpaging(1, 5, filter, function(json){ var msglist = json.data; //发送成功后的回调 });