请先参考生产和消费完成申请。
由于RocketMQ为java语言实现的，其他语言的客户端实现并不完备，往往出现某些问题很难定位，故建议非java语言使用http协议进行消息的生产和消费。
-
接口：
POST http://${httpProducerUriPrefix}/mq/produce -
参数：
- 【必选】producer: 在MQCloud申请的生产者名称
- 【必选】message: 消息
- 【可选】keys: key
- 【可选】orderId：发送顺序消息id，将用该参数定位消息发往的队列，定位方法采用orderId.hash%队列数 例如，同一个订单的消息如果想保障顺序，orderId可以传订单id。
-
响应说明：
{ "status": 200, "result": { "sendStatus": "SEND_OK", "msgId": "7F0000010008323659F89380B26C3B73", "messageQueue": { "topic": "mqcloud-http-test-topic", "brokerName": "broker-c", "queueId": 3 }, "queueOffset": 3153, "offsetMsgId": "0A121DC100002A9F0000000020EBAC2D", "regionId": "DefaultRegion", "traceOn": true } }- status：标识本次响应的状态码，包括但不限于如下值（如需100%发送成功，非200时要重试发送）：
- 200：生产成功
- 300：生产未知，如需保障100%成功需要重试
- 400：参数错误
- 500：服务内部异常
- message：当响应状态码非200时的提示信息。
- result：响应结果
- sendStatus：本次发送消息的状态，包括但不限于如下值：
- SEND_OK：发送成功
- FLUSH_DISK_TIMEOUT：消息接收成功，但是服务器刷盘超时，消息已经进入服务器队列，只有此时服务器宕机，消息才会丢失
- FLUSH_SLAVE_TIMEOUT：消息接收成功，但是服务器同步到 Slave 时超时，消息已经进入服务器队列，只有此时服务器宕机，消息才会丢失
- SLAVE_NOT_AVAILABLE：消息接送成功，但是此时 slave 不可用，消息已经进入服务器队列，只有此时服务器宕机，消息才会丢失
- msgId：消息id，客户端生成的
- offsetMsgId：消息id，broker生成的
- messageQueue：消息发送到的消息队列对象
- queueOffset：消息发送到队列的偏移量
- sendStatus：本次发送消息的状态，包括但不限于如下值：
- status：标识本次响应的状态码，包括但不限于如下值（如需100%发送成功，非200时要重试发送）：
-
生产举例：
<script> var param = { producer: "mqcloud-http-test-topic-producer" }; function httpProduce() { param.message = "http生产测试"; $.ajax({ type: "POST", url: "http://${httpProducerUriPrefix}/mq/produce", data: param, success: function (data) { console.log(data) if (data.status == 200) { console.log("send ok") } else { // 重试发送 httpProduce() } }, error: function (XmlHttpRequest, textStatus, errorThrown) { console.error(textStatus) // 重试发送 setTimeout("httpProduce()", 1000); } }); } httpProduce() </script>
-
消息消费接口：
GET http://${httpConsumerUriPrefix}/mq/message -
参数：
- 【必选】topic：打算消费的主题
- 【必选】consumer: 在MQCloud申请的消费者名称
- 【必选】requestId：请求id，用于确认上次消费完成
- 【广播消费必选】clientId：广播模式消费时须携带，不同的clientId消费全量消息，可以设置为ip
- 【可选】clientIp: 用于记录客户端与消费队列的关系，默认会自动解析clientIp，只有自动解析不正确时才需要传递该参数
-
响应说明：
{ "status": 200, "result": { "status": "FOUND", "requestId": "YnJva2VyLWMsNCwyMTU2OSwyMTYwMSwxNjU1ODgyNjM0MDU0", "msgList": [{ "messageId": "7F00000122AC18B4AAC26F3E531D000B", "message": "{\"id\":11,\"name\":\"搜狐tv11\"}", "timestamp": 1655879164144 }, { "messageId": "7F00000122AC18B4AAC26F3E550A001B", "message": "{\"id\":27,\"name\":\"搜狐tv27\"}", "timestamp": 1655879164640 }], "msgListSize": 2, "retryMsgList": [{ "messageId": "7F0000010008323659F82698564A13A3", "message": "{\"id\":13,\"name\":\"搜狐tv13\"}", "timestamp": 1657252317780 }, { "messageId": "7F0000010008323659F8269857B513A9", "message": "{\"id\":14,\"name\":\"搜狐tv14\"}", "timestamp": 1657252318144 }], "retryMsgListSize": 2 } }- status：标识本次响应的状态码，包括但不限于如下值：
- 200：响应正常
- 400：参数错误
- 500：服务内部异常
- message：当响应状态码非200时的提示信息
- result：响应结果
- status：本次消息拉取状态，包括但不限于如下值：
- FOUND：正常拉取到消息
- NO_NEW_MSG：没有新消息
- NO_MATCHED_MSG：没有匹配的消息
- OFFSET_ILLEGAL：偏移量非法
- PAUSED：消费暂停
- RATE_LIMITED：消费被限速
- requestId：请求id，下次请求时需要携带此参数
- msgList：消息列表
- messageId：消息id
- message：消息体
- timestamp：消息时间戳，可以理解为消息发送时间戳
- msgListSize：消息量
- retryMsgList：重试消息列表，可以在消息搜索模块发送重试消息。
- retryMsgListSize：重试消息量
- status：本次消息拉取状态，包括但不限于如下值：
- status：标识本次响应的状态码，包括但不限于如下值：
-
消息消费成功确认接口：
GET http://${httpConsumerUriPrefix}/mq/ack参数与
消息消费接口相同，用于当消费业务下线时ACK使用。默认情况下，消费消息时，传递的requestId参数用于确认上一批消息消费成功。但是当服务下线时，不再拉取消息，那么最后一次消费的消息就无法确认，所以需要在停止消息拉取后再单独调用一次ack接口。
-
ACK机制说明
为了确保消息消费成功，需要消息确认机制，即ACK机制，具体如下：
- 当调用
http://${httpConsumerUriPrefix}/mq/message接口时，会返回字段requestId， 它用于标识本次请求返回的消息。 - 当下次调用
http://${httpConsumerUriPrefix}/mq/message，需要把上次返回的requestId当做请求参数，这样后台会确认上次的消息消费成功了。
如果某次拉取的消息未进行ACK，那么会认为这批消息没有消费成功，在锁定一段时间后（默认为5分钟），会被重新拉取到。
另外，在拉取消息时传递
requestId势必对编程或用浏览器测试造成些困难，这里提供了自动化ACK功能，即在拉取消息时增加一个参数即可：useCookie=true。这样，requestId会自动存到cookie中，当发送请求时，自动携带cookie，不用在单独传递
requestId了。注意： 浏览器或客户端需要支持cookie功能，否则加上参数
useCookie=true，也无法自动ACK。 - 当调用
-
主动解锁队列接口：
GET http://${httpConsumerUriPrefix}/mq/unlock参数与
消息消费接口相同，用于当消费业务下线时，解锁最后一次消费的队列。主要用于服务下线时，此时消费任务还没有完成，但是想直接重启程序后再消费的情况。如果直接退出的话，由于最后一次消费的队列没有ACK，队列会被锁定，至到锁定超时后才会解锁。如果程序重启后想立马消费该队列，就需要主动调用/mq/unlock接口，解锁该队列。注意：解锁后，最后一次消费的消息会重新被拉取到。
-
集群消费举例：
下面是jquery的一个demo，便于理解如何使用：
<script> var param = { topic: "mqcloud-json-test-topic", consumer: "http-clustering-consumer" }; function httpConsume() { $.ajax({ type: "GET", url: "http://${httpConsumerUriPrefix}/mq/message", data: param, success: function (data) { if (data.status == 200) { param.requestId = data.result.requestId; if (data.result.msgListSize > 0) { console.log(data.result.status + "," + data.result.msgListSize); } if (data.result.retryMsgListSize > 0) { console.log(data.result.retryMsgListSize); } } else { console.log(data.message); } interval = setTimeout("httpConsume()", 1000); }, error: function (XmlHttpRequest, textStatus, errorThrown) { console.error(textStatus) interval = setTimeout("httpConsume()", 1000); } }); } httpConsume(); </script>当返回结果的status字段为200时，务必把result.requestId当做参数，传递给下一次请求，否则，本次消息会认为没有消费成功。
-
广播消费举例：
<script> var param = { topic: "mqcloud-json-test-topic", consumer: "http-clustering-consumer", clientId: "127.0.0.1" }; function httpConsume() { $.ajax({ type: "GET", url: "http://${httpConsumerUriPrefix}/mq/message", data: param, success: function (data) { if (data.status == 200) { param.requestId = data.result.requestId; if (data.result.msgListSize > 0) { console.log(data.result.status + "," + data.result.msgListSize); } if (data.result.retryMsgListSize > 0) { console.log(data.result.retryMsgListSize); } } else { console.log(data.message); } interval = setTimeout("httpConsume()", 1000); }, error: function (XmlHttpRequest, textStatus, errorThrown) { console.error(textStatus) interval = setTimeout("httpConsume()", 1000); } }); } httpConsume(); </script>广播模式消费与集群模式唯一的区别是需要额外传递一个参数
clientId，不同的clientId将消费全量消息。