Skip to content

Latest commit

 

History

History
137 lines (67 loc) · 5.09 KB

produceAndConsume.md

File metadata and controls

137 lines (67 loc) · 5.09 KB

一、创建topic

点击生产消息,选项如下图:

各个选项释义如下:

组名:业务组的名字,比如用户组可以填user。

业务名:具体的业务名字,比如用户订单业务可以填order。

Topic:组名-业务名-topic。

为了规范命名,MQCloud自动根据组名业务名命名topic和producerGroup的名字。

队列数量:默认为一个broker8个队列,如非特殊需求,不建议修改,后期可以动态扩容。

生产者:producerGroup的名字,组名-业务名-topic-producer。

消息量:请根据业务预估量填写,单位 条/天

高峰消息量:请根据业务预估量填写,单位 条/秒

使用环境:如果是测试使用,请选择测试环境,将会在测试集群创建此topic。

序列化方式:这里有两种方式:

  1. Protobuf

    优点:大多数情况下压缩比高,性能好。

    缺点:兼容性差,消费方须用Protobuf反序列化。

    此种序列化方式已经不推荐使用。

  2. String

    优点:可以使用json或xml,跨语言。

    缺点:性能和压缩比不高。

    如果此topic别人消费,建议使用此种方式序列化。

    如果选择String方式,需要业务自己用JSON库或者XML库序列化数据,具体参考发送json消息

通信协议:是指客户端与RocketMQ采用何种协议进行通信,这里支持三种方式:

  1. RocketMQ

    即默认的通信协议,如果使用MQCloud的客户端或RocketMQ官方提供的Go,Python,C++等客户端,都使用此通信协议。

  2. HTTP

    由于非java语言的RocketMQ客户端实现并不完备,出问题往往很难定位,故非java语言业务可以选用此方式进行通信,具体使用方式参考

  3. Proxy Remoting

    RocketMQ从5.x采用了计算存储分离的架构,提供了无状态的Proxy模块,可以理解为RocketMQ的网关,复杂网络业务建议采用Proxy Remoting协议,比2.HTTP协议更高效、稳定。

用途:此topic在业务里的用途,该项同样会展示在topic的用途信息里。

消息顺序:默认为局部有序,如果需要全局有序,请更改此选项,全局有序将丧失高可用性。

开启Trace:默认不开启trace,如果开启trace后,使用MQCloud提供的客户端将自动对消息进行trace,并可以在消息查询模块查看trace情况。

支持事务:默认不支持事务,如果勾选支持事务,将会在事务集群创建此topic。

消息延迟:该选项的意义是告知MQCloud从哪里获取统计数据,由于RocketMQ的延迟消息与普通消息统计方式不同,MQCloud需要知道此topic是否用于发送延迟消息。

二、消费消息

点击消费消息,选项如下图:

各个选项释义如下:

Topic:选择想要消费的topic。

消费者:就是consumerGroup,这里建议采用:组名-业务名-部分topic名-consumer 的命名方式。

消费方式

  1. 集群消费:所有的消费实例均分消息进行消费。
  2. 广播消息:每个消费实例会消费所有的消息。

流控:MQCloud客户端提供了精准流量控制功能,此流控仅是单实例的流控,并非针对集群生效的。

消费协议:采用何种协议与RocketMQ进行通信,与Topic申请时一致,具体参见

用途:根据业务填写。

三、关联资源

MQCloud可以管理已有的集群,但MQCloud并不知道以前的集群中已经存在的topic归属于谁,所以用户需要通过关联资源入口, 与生产者或消费者进行关联,这样才能让MQCloud为您服务。

1 关联生产者

各个选项释义如下:

Topic:选择想要关联的topic。

我是:选择生产者

生产者:输入producerGroup即可,一般查看之前的代码配置就知道了。

2 关联消费者

各个选项释义如下:

Topic:选择想要关联的topic。

我是:选择消费者

消费者:选择即可,如果consumer group列表没有,请联系管理员添加。

四、批量授权

topic详情页可以授权生产者权限给单个用户,在消费详情页可以授权消费者权限给单个用户,但是,某些情况下,有希望将自己拥有的生产者和消费者批量授权的需求,故有了此功能,如下:

五、搜索ip

可以使用此功能搜索某日内的ip连接的生产者或消费者: