SpringBoot3.0 + RocketMq 构建企业级数据中台 获课789it.top/5063/

def run_api_d(): try: # 处理消息队列 consumer = PushConsumer('aD') consumer.set_name_server_address('XXXXX:9876') consumer.set_thread_count(1) # 启动消费者 consumer.start() # 等待退出信号 while True: msg_subject = MsgQueueConsumptionSubject() consumer.subscribe('aiDress', msg_subject.d) time.sleep(3600) except Exception as e: print(e) def run_api_dr(): try: # 处理消息队列 consumer_draw = PushConsumer('aDr') consumer_draw.set_name_server_address('XXXXX:9876') msg_subject = MsgQueueConsumptionSubject() consumer_draw.subscribe('ai

Centos7安装的rocketmq，启动namesrv无明显报错信息，启动成功后5秒左右自己闪退 2022-10-27 17:53:09 INFO ShutdownHook - shutdown hook was invoked, 1 times. 2022-10-27 17:53:09 INFO ShutdownHook - shutdown thread NettyEventExecutor interrupt false 2022-10-27 17:53:09 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelInactive, the channel[121.11.115.228:49346] 2022-10-27 17:53:09 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelUnregistered, the channel[121.11.115.228:49346] 2022-10-27 17:53:09 INFO NettyEventExecutor - the broker's channel dest

一直提示找不到jdk路径 配置已经改了究竟是为什么呢

服务器信息如下： | 序号** | **IP** | **角色** | **架构模式** | | ------ | ------------- | ------------------------------------ | ----------------------- | | 1 | 47.99.114.165 | nameserver、brokerserver | Master1、Slave2 | | 2 | 120.55.98.207 | nameserver、brokerserver | Master2、Slave1 | ========================================================== 服务器1的主从可以正常启动，服务器2的主可以启动可以正常将信息注册到namesrv,但是当启动从节点时，可以启动服务，但是会提示如下异常，同时rocketmq控制台也同样会提示 con

gitchat资料，可以私聊我扣扣:842533193,备注git下载

服务器信息如下： | 序号** | **IP** | **角色** | **架构模式** | | ------ | ------------- | ------------------------------------ | ----------------------- | | 1 | 192.168.83.138 | nameserver、brokerserver | Master1、Slave2 | | 2 | 192.168.83.139 | nameserver、brokerserver | Master2、Slave1 | ========================================================== 服务器1的主从可以正常启动，服务器2的主可以启动可以正常将信息注册到namesrv,但是当启动从节点时，可以启动服务，但是会提示如下异常，同时rocketmq控制台也同样会提示 2

不知道西安目前有没有企业在用rocketmq呀。

rocket mq会一直维护吗

现在知道rocketmq可以按照自己的想法报有循序的数据先后丢到同一个queue里面去，但是我的消费端是个集群

如题

rocketmq联盟136798125，现在有不少人都希望学习rocketmq，但官方文档资源还是有点稀缺，希望通过这个群来让

希望被阉割的事务消息可以重新开发出来！

亲爱的各位吧友：欢迎来到rocketmq