README
¶
RocketMQ 4.x
端口号列表
| 端口号 | 所属服务器 | 用途 |
|---|---|---|
| 9876 | NameServer | 命名服务对外端口 |
| 10911 | BrokerServer | Broker 接收生产者的消息，处理消费者拉取消息。（上报给NameServer） |
| 10909 | BrokerServer | Broker 接收生产者的消息，不能处理消费者拉取消息。 |
| 10912 | BrokerServer | Broker用于主从同步 |
| 9800 | DashBoard | 管理后台 |
架构图
Docker部署开发环境
至少启动一个NameServer，一个Broker。
NameServer
# NameServer
docker run -d \
--name rocketmq-namesrv \
-p 9876:9876 \
-e "JAVA_OPT_EXT=-Xms512M -Xmx512M -Xmn128m" \
apache/rocketmq:latest \
sh mqnamesrv
Broker
# Broker
docker run -d \
--name rmqbroker \
-p 10911:10911 \
-p 10909:10909 \
-p 10912:10912 \
--link rocketmq-namesrv \
-e "JAVA_OPT_EXT=-Xms512M -Xmx512M -Xmn128m" \
-e "NAMESRV_ADDR=rocketmq-namesrv:9876" \
apache/rocketmq:latest \
sh mqbroker -c /home/rocketmq/rocketmq-4.9.2/conf/broker.conf
需要注意的是，NameServer下发的是Docker容器的内网IP地址，从宿主机的外网访问是访问不了的，需要进行配置：
vi /home/rocketmq/rocketmq-5.1.4/conf/broker.conf
添加如下配置，brokerIP1可以是ip也可以是dns，hostname：
brokerIP1 = host.docker.internal
Web控制台
docker pull styletang/rocketmq-console-ng:latest
docker run -d \
--name rmqconsole \
-p 9800:8080 \
--link rocketmq-namesrv \
-e "JAVA_OPTS=-Drocketmq.namesrv.addr=rocketmq-namesrv:9876 -Dcom.rocketmq.sendMessageWithVIPChannel=false" \
-t styletang/rocketmq-console-ng:latest
控制台访问地址： http://localhost:9800/#/
参考资料
Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ConsumerMessageCarrier ¶
type ConsumerMessageCarrier struct {
// contains filtered or unexported fields
}
func NewConsumerMessageCarrier ¶
func NewConsumerMessageCarrier(msg *primitive.MessageExt) ConsumerMessageCarrier
func (ConsumerMessageCarrier) Get ¶
func (c ConsumerMessageCarrier) Get(key string) string
func (ConsumerMessageCarrier) Keys ¶
func (c ConsumerMessageCarrier) Keys() []string
func (ConsumerMessageCarrier) Set ¶
func (c ConsumerMessageCarrier) Set(key, val string)
type ProducerMessageCarrier ¶
type ProducerMessageCarrier struct {
// contains filtered or unexported fields
}
func NewProducerMessageCarrier ¶
func NewProducerMessageCarrier(msg *primitive.Message) ProducerMessageCarrier
func (ProducerMessageCarrier) Get ¶
func (c ProducerMessageCarrier) Get(key string) string
func (ProducerMessageCarrier) Keys ¶
func (c ProducerMessageCarrier) Keys() []string
func (ProducerMessageCarrier) Set ¶
func (c ProducerMessageCarrier) Set(key, val string)
Source Files
Click to show internal directories.
Click to hide internal directories.