项目说明

官方文档

• 基于GRPC 仅支持rocketmq5.x 得用GRPC端口（默认为8081） 不能用nameserver端口，否则会连不上
• 默认GRPC端口为8081 如果需要修改 可以在conf/rmq-proxy.json 中添加 grpcServerPort": 8086

消息主题

创建主题

需要通过dashboard或者命令行先创建 topic 否则会抛出异常： No topic route info in name server for the topic: xxx

可使用如下命令创建主题

  mqadmin updateTopic -b 172.25.96.1:10911 -t routingKey

消息类型

如果publish的消息类型跟当前topic的类型不一致 则会出现如下异常：

`Current message type not match with topic accept message types`

消息类型共支持四种： NORMAL TRANSACTION DELAY ：FIFO

创建主题的时候如果未指定消息类型则默认为 NORMAL

a. 如果需要消息支持事务 需要修改为 TRANSACTION 
b. 如果需要消息支持延时消息 需要修改为 DELAY 
c. 如果需要消息支持顺序消息 需要修改为 FIFO

可以在创建主题的时候指定消息的类型：

  mqadmin updateTopic -b 172.25.96.1:10911 -t routingKey -a +message.type=DELAY
  
  mqadmin updateTopic -c DefaultCluster -t DelayTopic -n 127.0.0.1:9876 -a +message.type=DELAY
  
  mqadmin updateTopic -c DefaultCluster -t FIFOTopic -o true -n 127.0.0.1:9876 -a +message.type=FIFO
  
  mqadmin updatetopic -n localhost:9876 -t TestTopic -c DefaultCluster -a +message.type=TRANSACTION