备案控制台
探索云世界
开发者社区 > 云原生 > 正文

rocketmq客户端invokeSync：由于超时而关闭套接字，3000ms

rocketmq版本信息：4.9.1 springboot: org.apache.rocketmq rocketmq-spring-boot-starter 2.2.1

客户端报错:(一直报这个信息) 15:50:28.835 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - [info,90] - createChannel: begin to connect remote host[x.x.x.x:10911] asynchronously 15:50:28.835 [NettyClientWorkerThread_4] INFO RocketmqRemoting - [info,90] - NETTY CLIENT PIPELINE: CLOSE x.x.x.x:10911 15:50:28.835 [NettyClientWorkerThread_4] INFO RocketmqRemoting - [info,90] - eventCloseChannel: the channel[null] has been removed from the channel table before 15:50:28.835 [NettyClientWorkerThread_2] INFO RocketmqRemoting - [info,95] - NETTY CLIENT PIPELINE: CONNECT UNKNOWN => x.x.x.x:10911 15:50:28.836 [NettyClientSelector_1] INFO RocketmqRemoting - [info,95] - closeChannel: close the connection to remote address[x.x.x.x:10911] result: true 15:50:28.853 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - [info,95] - createChannel: connect remote host[x.x.x.x:10911] success, AbstractBootstrap$PendingRegistrationPromise@2bcc4a73(success) 15:50:28.959 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - [info,95] - closeChannel: begin close the channel[x.x.x.x:10911] Found: true 15:50:28.959 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - [info,90] - closeChannel: the channel[x.x.x.x:10911] was removed from channel table 15:50:28.959 [MQClientFactoryScheduledThread] WARN RocketmqRemoting - [warn,125] - invokeSync: close socket because of timeout, 3000ms, x.x.x.x:10911 15:50:28.959 [NettyClientWorkerThread_3] INFO RocketmqRemoting - [info,90] - NETTY CLIENT PIPELINE: CLOSE x.x.x.x:10911 15:50:28.959 [MQClientFactoryScheduledThread] WARN RocketmqRemoting - [warn,115] - invokeSync: wait response timeout exception, the channel[x.x.x.x:10911] 15:50:28.960 [NettyClientWorkerThread_3] INFO RocketmqRemoting - [info,90] - eventCloseChannel: the channel[null] has been removed from the channel table before 15:50:28.960 [NettyClientSelector_1] INFO RocketmqRemoting - [info,95] - closeChannel: close the connection to remote address[x.x.x.x:10911] result: true 15:50:28.960 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - [info,90] - createChannel: begin to connect remote host[x.x.x.x:10911] asynchronously 15:50:28.960 [NettyClientWorkerThread_4] INFO RocketmqRemoting - [info,95] - NETTY CLIENT PIPELINE: CONNECT UNKNOWN => x.x.x.x:10911 15:50:28.977 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - [info,95] - createChannel: connect remote host[x.x.x.x:10911] success, AbstractBootstrap$PendingRegistrationPromise@5d0af6f(success) 15:50:29.042 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - [info,95] - closeChannel: begin close the channel[x.x.x.x:10911] Found: true 15:50:29.042 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - [info,90] - closeChannel: the channel[x.x.x.x:10911] was removed from channel table 15:50:29.042 [MQClientFactoryScheduledThread] WARN RocketmqRemoting - [warn,125] - invokeSync: close socket because of timeout, 3000ms, x.x.x.x:10911 15:50:29.042 [MQClientFactoryScheduledThread] WARN RocketmqRemoting - [warn,115] - invokeSync: wait response timeout exception, the channel[x.x.x.x:10911] 15:50:29.042 [NettyClientWorkerThread_4] INFO RocketmqRemoting - [info,90] - NETTY CLIENT PIPELINE: CLOSE x.x.x.x:10911 15:50:29.042 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - [info,90] - createChannel: begin to connect remote host[x.x.x.x:10911] asynchronously 15:50:29.043 [NettyClientWorkerThread_4] INFO RocketmqRemoting - [info,90] - eventCloseChannel: the channel[null] has been removed from the channel table before 15:50:29.043 [NettyClientWorkerThread_1] INFO RocketmqRemoting - [info,95] - NETTY CLIENT PIPELINE: CONNECT UNKNOWN => x.x.x.x:10911 15:50:29.043 [NettyClientSelector_1] INFO RocketmqRemoting - [info,95] - closeChannel: close the connection to remote address[x.x.x.x:10911] result: true 15:50:29.057 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - [info,95] - createChannel: connect remote host[x.x.x.x:10911] success, AbstractBootstrap$PendingRegistrationPromise@7c02fe16(success) 15:50:31.050 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - [info,95] - closeChannel: begin close the channel[x.x.x.x:10911] Found: true 15:50:31.050 [MQClientFactoryScheduledThread] INFO RocketmqRemoting - [info,90] - closeChannel: the channel[x.x.x.x:10911] was removed from channel table 15:50:31.050 [MQClientFactoryScheduledThread] WARN RocketmqRemoting - [warn,125] - invokeSync: close socket because of timeout, 3000ms, x.x.x.x:10911

broker报错信息： io.netty.channel.StacklessClosedChannelException: null at io.netty.channel.AbstractChannel$AbstractUnsafe.write(Object, ChannelPromise)(Unknown Source) ~[netty-all-4.1.65.Final.jar:4.1.65.Final] 2022-01-07 16:11:57 ERROR NettyServerNIOSelector_3_1 - RemotingCommand [code=11, language=JAVA, version=395, opaque=25308, flag(B)=0, remark=null, extFields={queueId=0, maxMsgNums=32, sysFlag=2, suspendTimeoutMillis=15000, commitOffset=0, topic=jsjlr, queueOffset=0, expressionType=TAG, subVersion=1641541883872, consumerGroup=jsjlr_remove_njxxgcdx}, serializeTypeCurrentRPC=JSON] 2022-01-07 16:11:57 ERROR NettyServerNIOSelector_3_1 - RemotingCommand [code=19, language=JAVA, version=395, opaque=25308, flag(B)=1, remark=NO_MESSAGE_IN_QUEUE, extFields=null, serializeTypeCurrentRPC=JSON] 2022-01-07 16:11:57 ERROR NettyServerNIOSelector_3_3 - RemotingCommand [code=11, language=JAVA, version=395, opaque=25806, flag(B)=0, remark=null, extFields={queueId=0, maxMsgNums=32, sysFlag=2, suspendTimeoutMillis=15000, commitOffset=0, topic=jsjlr, queueOffset=0, expressionType=TAG, subVersion=1641541930456, consumerGroup=jsjlr_remove_njxxgcdx}, serializeTypeCurrentRPC=JSON] 2022-01-07 16:11:57 ERROR NettyServerNIOSelector_3_3 - RemotingCommand [code=19, language=JAVA, version=395, opaque=25806, flag(B)=1, remark=NO_MESSAGE_IN_QUEUE, extFields=null, serializeTypeCurrentRPC=JSON] 2022-01-07 16:11:57 ERROR NettyServerNIOSelector_3_2 - processRequestWrapper response to /x.x.x.x:45867 failed io.netty.channel.StacklessClosedChannelException: null at io.netty.channel.AbstractChannel$AbstractUnsafe.write(Object, ChannelPromise)(Unknown Source) ~[netty-all-4.1.65.Final.jar:4.1.65.Final] 2022-01-07 16:11:57 ERROR NettyServerNIOSelector_3_2 - RemotingCommand [code=11, language=JAVA, version=395, opaque=25814, flag(B)=0, remark=null, extFields={queueId=1, maxMsgNums=32, sysFlag=3, suspendTimeoutMillis=15000, commitOffset=10, topic=xqts, queueOffset=10, expressionType=TAG, subVersion=1641541884177, consumerGroup=xqts_remove_njxxgcdx}, serializeTypeCurrentRPC=JSON] 2022-01-07 16:11:57 ERROR NettyServerNIOSelector_3_2 - RemotingCommand [code=19, language=JAVA, version=395, opaque=25814, flag(B)=1, remark=OFFSET_OVERFLOW_ONE, extFields=null, serializeTypeCurrentRPC=JSON] 2022-01-07 16:11:58 WARN PullMessageThread_19 - the consumer's group info not exist, group: jsjlr_edit_njxxgcdx 2022-01-07 16:11:58 WARN PullMessageThread_10 - the consumer's group info not exist, group: jsjlr_edit_njxxgcdx 2022-01-07 16:11:58 WARN PullMessageThread_15 - the consumer's group info not exist, group: jsjlr_edit_njxxgcdx 2022-01-07 16:11:58 WARN PullMessageThread_19 - the consumer's group info not exist, group: jsjlr_edit_njxxgcdx 2022-01-07 16:11:59 WARN PullMessageThread_7 - the consumer's group info not exist, group: jsjlr_edit_njxxgcdx 2022-01-07 16:12:01 WARN ConsumerManageThread_16 - getConsumerGroupInfo failed, xqts_edit_njxxgcdx x.x.x.x:41571 2022-01-07 16:12:01 INFO NettyEventExecutor - NETTY EVENT: remove channel[ClientChannelInfo [channel=[id: 0x400a059c, L:/192.168.0.100:10911 ! R:/x.x.x.x:50244], clientId=x.x.x.x@x.x.x.x:9876@2815@155974395232204, language=JAVA, version=395, lastUpdateTimestamp=1641543114094]][x.x.x.x:50244] from ProducerManager groupChannelTable, producer group: CLIENT_INNER_PRODUCER 2022-01-07 16:12:01 WARN NettyEventExecutor - NETTY EVENT: remove not active channel[ClientChannelInfo [channel=[id: 0x400a059c, L:/192.168.0.100:10911 ! R:/x.x.x.x:50244], clientId=x.x.x.x@x.x.x.x:9876@2815@155974395232204, language=JAVA, version=395, lastUpdateTimestamp=1641543114094]] from ConsumerGroupInfo groupChannelTable, consumer group: xqpp_rematch_njxxgcdx 2022-01-07 16:12:01 INFO NettyEventExecutor - unregister consumer ok, no any connection, and remove consumer group, xqpp_rematch_njxxgcdx 2022-01-07 16:12:02 WARN ClientHousekeepingScheduledThread1 - SCAN: remove expired channel[x.x.x.x:22068] from ProducerManager groupChannelTable, producer group name: CLIENT_INNER_PRODUCER 2022-01-07 16:12:02 ERROR NettyServerNIOSelector_3_3 - processRequestWrapper response to /x.x.x.x:38281 failed io.netty.channel.StacklessClosedChannelException: null at io.netty.channel.AbstractChannel$AbstractUnsafe.write(Object, ChannelPromise)(Unknown Source) ~[netty-all-4.1.65.Final.jar:4.1.65.Final] 2022-01-07 16:12:02 ERROR NettyServerNIOSelector_3_3 - RemotingCommand [code=11, language=JAVA, version=395, opaque=25863, flag(B)=0, remark=null, extFields={queueId=0, maxMsgNums=32, sysFlag=2, suspendTimeoutMillis=15000, commitOffset=0, topic=%RETRY%xqts_remove_njxxgcdx, queueOffset=0, expressionType=TAG, subVersion=1641540113347, consumerGroup=xqts_remove_njxxgcdx}, serializeTypeCurrentRPC=JSON] 2022-01-07 16:12:02 ERROR NettyServerNIOSelector_3_3 - RemotingCommand [code=19, language=JAVA, version=395, opaque=25863, flag(B)=1, remark=NO_MESSAGE_IN_QUEUE, extFields=null, serializeTypeCurrentRPC=JSON] 2022-01-07 16:12:02 ERROR NettyServerNIOSelector_3_3 - processRequestWrapper response to /x.x.x.x:38281 failed io.netty.channel.StacklessClosedChannelException: null at io.netty.channel.AbstractChannel$AbstractUnsafe.write(Object, ChannelPromise)(Unknown Source) ~[netty-all-4.1.65.Final.jar:4.1.65.Final] 2022-01-07 16:12:02 ERROR NettyServerNIOSelector_3_3 - RemotingCommand [code=11, language=JAVA, version=395, opaque=25865, flag(B)=0, remark=null, extFields={queueId=0, maxMsgNums=32, sysFlag=3, suspendTimeoutMillis=15000, commitOffset=8, topic=xqts, queueOffset=8, expressionType=TAG, subVersion=1641541884177, consumerGroup=xqts_remove_njxxgcdx}, serializeTypeCurrentRPC=JSON] 2022-01-07 16:12:02 ERROR NettyServerNIOSelector_3_3 - RemotingCommand [code=19, language=JAVA, version=395, opaque=25865, flag(B)=1, remark=OFFSET_OVERFLOW_ONE, extFields=null, serializeTypeCurrentRPC=JSON] 2022-01-07 16:12:02 ERROR NettyServerNIOSelector_3_3 - processRequestWrapper response to /x.x.x.x:38281 failed io.netty.channel.StacklessClosedChannelException: null at io.netty.channel.AbstractChannel$AbstractUnsafe.write(Object, ChannelPromise)(Unknown Source) ~[netty-all-4.1.65.Final.jar:4.1.65.Final] 2022-01-07 16:12:02 ERROR NettyServerNIOSelector_3_3 - RemotingCommand [code=11, language=JAVA, version=395, opaque=25864, flag(B)=0, remark=null, extFields={queueId=1, maxMsgNums=32, sysFlag=3, suspendTimeoutMillis=15000, commitOffset=10, topic=xqts, queueOffset=10, expressionType=TAG, subVersion=1641541884177, consumerGroup=xqts_remove_njxxgcdx}, serializeTypeCurrentRPC=JSON] 2022-01-07 16:12:02 ERROR NettyServerNIOSelector_3_3 - RemotingCommand [code=19, language=JAVA, version=395, opaque=25864, flag(B)=1, remark=OFFSET_OVERFLOW_ONE, extFields=null, serializeTypeCurrentRPC=JSON] 2022-01-07 16:12:04 WARN PullMessageThread_16 - the consumer's group info not exist, group: xqts_edit_njxxgcdx 2022-01-07 16:12:04 WARN PullMessageThread_12 - the consumer's group info not exist, group: xqts_edit_njxxgcdx 2022-01-07 16:12:05 WARN PullMessageThread_22 - the consumer's group info not exist, group: jsjlr_edit_njxxgcdx 2022-01-07 16:12:05 WARN PullMessageThread_22 - the consumer's group info not exist, group: jsjlr_edit_njxxgcdx 2022-01-07 16:12:05 WARN PullMessageThread_22 - the consumer's group info not exist, group: jsjlr_edit_njxxgcdx 2022-01-07 16:12:05 WARN PullMessageThread_22 - the consumer's group info not exist, group: jsjlr_edit_njxxgcdx 2022-01-07 16:12:05 WARN PullMessageThread_22 - the consumer's group info not exist, group: jsjlr_edit_njxxgcdx 2022-01-07 16:12:09 WARN PullMessageThread_20 - the consumer's group info not exist, group: jsjlr_add_njxxgcdx 2022-01-07 16:12:09 WARN PullMessageThread_12 - the consumer's group info not exist, group: jsjlr_add_njxxgcdx 2022-01-07 16:12:09 WARN PullMessageThread_20 - the consumer's group info not exist, group: jsjlr_add_njxxgcdx 2022-01-07 16:12:09 WARN PullMessageThread_16 - the consumer's group info not exist, group: jsjlr_add_njxxgcdx 2022-01-07 16:12:09 WARN PullMessageThread_20 - the consumer's group info not exist, group: jsjlr_add_njxxgcdx 2022-01-07 16:12:12 INFO BrokerControllerScheduledThread1 - dispatch behind commit log 0 bytes 2022-01-07 16:12:12 INFO BrokerControllerScheduledThread1 - Slave fall behind master: 82029 bytes 2022-01-07 16:12:12 WARN ClientHousekeepingScheduledThread1 - SCAN: remove expired channel[x.x.x.x:26120] from ProducerManager groupChannelTable, producer group name: CLIENT_INNER_PRODUCER 2022-01-07 16:12:12 INFO brokerOutApi_thread_4 - register broker[0]to name server x.x.x.x:9876 OK 2022-01-07 16:12:13 WARN PullMessageThread_2 - the consumer's group info not exist, group: jsjlr_add_njxxgcdx 2022-01-07 16:12:13 WARN PullMessageThread_18 - the consumer's group info not exist, group: jsjlr_add_njxxgcdx 2022-01-07 16:12:13 WARN PullMessageThread_2 - the consumer's group info not exist, group: jsjlr_add_njxxgcdx 2022-01-07 16:12:13 WARN PullMessageThread_19 - the consumer's group info not exist, group: jsjlr_add_njxxgcdx 2022-01-07 16:12:13 INFO HeartbeatThread_1 - new consumer connected, group: jsjlr_add_njxxgcdx CONSUME_PASSIVELY CLUSTERING channel: ClientChannelInfo [channel=[id: 0x0be0a28c, L:0.0.0.0/0.0.0.0:10911 ! R:/x.x.x.x:3353], clientId=x.x.x.x@x.x.x.x:9876@2815@155974091247466, language=JAVA, version=395, lastUpdateTimestamp=1641543133227] 2022-01-07 16:12:13 INFO HeartbeatThread_1 - subscription changed, add new topic, group: jsjlr_add_njxxgcdx SubscriptionData [classFilterMode=false, topic=%RETRY%jsjlr_add_njxxgcdx, subString=, tagsSet=[], codeSet=[], subVersion=1641540112843, expressionType=TAG] 2022-01-07 16:12:13 INFO HeartbeatThread_1 - subscription changed, add new topic, group: jsjlr_add_njxxgcdx SubscriptionData [classFilterMode=false, topic=jsjlr, subString=add, tagsSet=[add], codeSet=[96417], subVersion=1641541913309, expressionType=TAG] 2022-01-07 16:12:13 INFO HeartbeatThread_1 - registerConsumer info changed ConsumerData [groupName=jsjlr_add_njxxgcdx, consumeType=CONSUME_PASSIVELY, messageModel=CLUSTERING, consumeFromWhere=CONSUME_FROM_LAST_OFFSET, unitMode=false, subscriptionDataSet=[SubscriptionData [classFilterMode=false, topic=%RETRY%jsjlr_add_njxxgcdx, subString=, tagsSet=[], codeSet=[], subVersion=1641540112843, expressionType=TAG], SubscriptionData [classFilterMode=false, topic=jsjlr, subString=add, tagsSet=[add], codeSet=[96417], subVersion=1641541913309, expressionType=TAG]]] x.x.x.x:3353 2022-01-07 16:12:13 INFO HeartbeatThread_1 - new producer connected, group: CLIENT_INNER_PRODUCER channel: ClientChannelInfo [channel=[id: 0x0be0a28c, L:0.0.0.0/0.0.0.0:10911 ! R:/x.x.x.x:3353], clientId=x.x.x.x@x.x.x.x:9876@2815@155974091247466, language=JAVA, version=395, lastUpdateTimestamp=1641543133227]

nameserver报错信息： io.netty.channel.unix.Errors$NativeIoException: readAddress(..) failed: Connection reset by peer 2022-01-07 16:12:41 INFO NettyServerCodecThread_5 - NETTY SERVER PIPELINE: channelInactive, the channel[x.x.x.x:14429] 2022-01-07 16:12:41 INFO NettyServerEPOLLSelector_3_3 - closeChannel: close the connection to remote address[x.x.x.x:14429] result: true 2022-01-07 16:12:41 INFO NettyServerCodecThread_5 - NETTY SERVER PIPELINE: channelUnregistered, the channel[x.x.x.x:14429] 2022-01-07 16:12:44 WARN NettyServerCodecThread_4 - NETTY SERVER PIPELINE: exceptionCaught x.x.x.x:55833 2022-01-07 16:12:44 WARN NettyServerCodecThread_4 - NETTY SERVER PIPELINE: exceptionCaught exception. io.netty.channel.unix.Errors$NativeIoException: readAddress(..) failed: Connection reset by peer 2022-01-07 16:12:44 INFO NettyServerEPOLLSelector_3_2 - closeChannel: close the connection to remote address[x.x.x.x:55833] result: true 2022-01-07 16:12:44 INFO NettyServerCodecThread_4 - NETTY SERVER PIPELINE: channelInactive, the channel[x.x.x.x:55833] 2022-01-07 16:12:44 INFO NettyServerCodecThread_4 - NETTY SERVER PIPELINE: channelUnregistered, the channel[x.x.x.x:55833] 2022-01-07 16:12:48 INFO NettyServerCodecThread_8 - NETTY SERVER PIPELINE: channelInactive, the channel[x.x.x.x:38213] 2022-01-07 16:12:48 INFO NettyServerCodecThread_8 - NETTY SERVER PIPELINE: channelUnregistered, the channel[x.x.x.x:38213] 2022-01-07 16:12:50 INFO NettyServerCodecThread_7 - NETTY SERVER PIPELINE: channelRegistered x.x.x.x:16109 2022-01-07 16:12:50 INFO NettyServerCodecThread_7 - NETTY SERVER PIPELINE: channelActive, the channel[x.x.x.x:16109] 2022-01-07 16:12:53 WARN NettyServerCodecThread_7 - NETTY SERVER PIPELINE: exceptionCaught x.x.x.x:16951 2022-01-07 16:12:53 WARN NettyServerCodecThread_7 - NETTY SERVER PIPELINE: exceptionCaught exception. io.netty.channel.unix.Errors$NativeIoException: readAddress(..) failed: Connection reset by peer 2022-01-07 16:12:53 INFO NettyServerEPOLLSelector_3_3 - closeChannel: close the connection to remote address[x.x.x.x:16951] result: true 2022-01-07 16:12:53 INFO NettyServerCodecThread_7 - NETTY SERVER PIPELINE: channelInactive, the channel[x.x.x.x:16951] 2022-01-07 16:12:53 INFO NettyServerCodecThread_7 - NETTY SERVER PIPELINE: channelUnregistered, the channel[x.x.x.x:16951] 2022-01-07 16:13:15 INFO NettyServerCodecThread_8 - NETTY SERVER PIPELINE: channelRegistered x.x.x.x:1260 2022-01-07 16:13:15 INFO NettyServerCodecThread_8 - NETTY SERVER PIPELINE: channelActive, the channel[x.x.x.x:1260] 2022-01-07 16:13:15 INFO NettyServerCodecThread_6 - NETTY SERVER PIPELINE: channelInactive, the channel[x.x.x.x:13023] 2022-01-07 16:13:15 INFO NettyServerCodecThread_6 - NETTY SERVER PIPELINE: channelUnregistered, the channel[x.x.x.x:13023] 2022-01-07 16:13:20 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelRegistered x.x.x.x:24209 2022-01-07 16:13:20 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelActive, the channel[x.x.x.x:24209] 2022-01-07 16:13:23 INFO NettyServerCodecThread_3 - NETTY SERVER PIPELINE: channelInactive, the channel[x.x.x.x:48726] 2022-01-07 16:13:23 INFO NettyServerCodecThread_3 - NETTY SERVER PIPELINE: channelUnregistered, the channel[x.x.x.x:48726] 2022-01-07 16:13:25 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelInactive, the channel[x.x.x.x:24209] 2022-01-07 16:13:25 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelUnregistered, the channel[x.x.x.x:24209] 2022-01-07 16:13:26 INFO NettyServerCodecThread_2 - NETTY SERVER PIPELINE: channelInactive, the channel[x.x.x.x:62978] 2022-01-07 16:13:26 INFO NettyServerCodecThread_2 - NETTY SERVER PIPELINE: channelUnregistered, the channel[x.x.x.x:62978] 2022-01-07 16:13:26 INFO NettyServerCodecThread_8 - NETTY SERVER PIPELINE: channelInactive, the channel[x.x.x.x:1260] 2022-01-07 16:13:26 INFO NettyServerCodecThread_8 - NETTY SERVER PIPELINE: channelUnregistered, the channel[x.x.x.x:1260]

store存储信息： 2022-01-07 15:47:02 WARN main - found a illegal magic code 0x0 2022-01-07 15:47:02 INFO main - recover physics file end, /data/rocketMq/rocketmq4.9.1/store/commitlog/00000000000000000000 2022-01-07 15:47:02 WARN main - maxPhyOffsetOfConsumeQueue(41375) >= processOffset(41375), truncate dirty logic files 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: xqts, queueId: 0 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: xqts, queueId: 1 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: xqts, queueId: 2 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: xqts, queueId: 3 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: jiebang, queueId: 0 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: jiebang, queueId: 1 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: jiebang, queueId: 2 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: jsjlr, queueId: 1 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: RMQ_SYS_TRACE_TOPIC, queueId: 0 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: RMQ_SYS_TRACE_TOPIC, queueId: 1 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: RMQ_SYS_TRACE_TOPIC, queueId: 2 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: RMQ_SYS_TRACE_TOPIC, queueId: 3 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: OFFSET_MOVED_EVENT, queueId: 0 2022-01-07 15:47:02 INFO main - load over, and the max phy offset = 41375 2022-01-07 15:47:02 INFO main - [SetReputOffset] maxPhysicalPosInLogicQueue=41375 clMinOffset=0 clMaxOffset=41375 clConfirmedOffset=-1 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: xqts, queueId: 0 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: xqts, queueId: 1 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: xqts, queueId: 2 2022-01-07 15:47:02 INFO ReputMessageService - ReputMessageService service started 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: xqts, queueId: 3 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: jiebang, queueId: 0 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: jiebang, queueId: 1 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: jiebang, queueId: 2 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: jsjlr, queueId: 1 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: RMQ_SYS_TRACE_TOPIC, queueId: 0 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: RMQ_SYS_TRACE_TOPIC, queueId: 1 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: RMQ_SYS_TRACE_TOPIC, queueId: 2 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: RMQ_SYS_TRACE_TOPIC, queueId: 3 2022-01-07 15:47:02 INFO main - Compute logical min offset: 0, topic: OFFSET_MOVED_EVENT, queueId: 0 2022-01-07 15:47:02 INFO AcceptSocketService - AcceptSocketService service started 2022-01-07 15:47:02 INFO GroupTransferService - GroupTransferService service started 2022-01-07 15:47:02 INFO HAClient - HAClient service started 2022-01-07 15:47:02 INFO FlushConsumeQueueService - FlushConsumeQueueService service started 2022-01-07 15:47:02 INFO GroupCommitService - GroupCommitService service started 2022-01-07 15:47:02 INFO main - /data/rocketMq/rocketmq4.9.1/store/abort create OK 2022-01-07 15:47:02 INFO StoreStatsService - StoreStatsService service started 2022-01-07 15:48:02 INFO StoreStatsService - [STORETPS] put_tps get_found_tps get_miss_tps get_transfered_tps 2022-01-07 15:48:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 4, PutMessageDistributeTime [<=0ms]:0 [010ms]:3 [1050ms]:1 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 15:49:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.0 get_miss_tps 5.91617365219565 get_transfered_tps 0.0 2022-01-07 15:49:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 15:50:02 INFO StoreStatsService - [STORETPS] put_tps 0.0666611115740355 get_found_tps 0.0666611115740355 get_miss_tps 5.366219481709857 get_transfered_tps 0.0666611115740355 2022-01-07 15:50:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 4, PutMessageDistributeTime [<=0ms]:1 [010ms]:3 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 15:51:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.016665277893508874 get_miss_tps 5.399550037496875 get_transfered_tps 0.016665277893508874 2022-01-07 15:51:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 15:52:02 INFO StoreStatsService - [STORETPS] put_tps 0.0666611115740355 get_found_tps 0.016665277893508874 get_miss_tps 6.382801433213899 get_transfered_tps 0.016665277893508874 2022-01-07 15:52:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 4, PutMessageDistributeTime [<=0ms]:1 [010ms]:3 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 15:53:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.0 get_miss_tps 6.9160903258061825 get_transfered_tps 0.0 2022-01-07 15:53:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 15:54:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.0 get_miss_tps 6.966202253183122 get_transfered_tps 0.0 2022-01-07 15:54:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 15:55:02 INFO StoreStatsService - [STORETPS] put_tps 0.1999833347221065 get_found_tps 0.14998750104157987 get_miss_tps 6.082826431130739 get_transfered_tps 0.16665277893508876 2022-01-07 15:55:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 12, PutMessageDistributeTime [<=0ms]:4 [010ms]:8 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 15:56:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.03333111125924938 get_miss_tps 6.199586694220385 get_transfered_tps 0.03333111125924938 2022-01-07 15:56:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 15:57:02 INFO StoreStatsService - [STORETPS] put_tps 0.0666611115740355 get_found_tps 0.03333055578701775 get_miss_tps 6.016165319556704 get_transfered_tps 0.03333055578701775 2022-01-07 15:57:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 4, PutMessageDistributeTime [<=0ms]:1 [010ms]:3 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 15:58:02 INFO StoreStatsService - [STORETPS] put_tps 0.13332444503699753 get_found_tps 0.03333111125924938 get_miss_tps 4.533031131257916 get_transfered_tps 0.03333111125924938 2022-01-07 15:58:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 8, PutMessageDistributeTime [<=0ms]:2 [010ms]:6 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 15:59:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.09999166736105325 get_miss_tps 6.299475043746354 get_transfered_tps 0.09999166736105325 2022-01-07 15:59:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:00:02 INFO StoreStatsService - [STORETPS] put_tps 0.1999833347221065 get_found_tps 0.049995833680526625 get_miss_tps 4.332972252312308 get_transfered_tps 0.049995833680526625 2022-01-07 16:00:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 12, PutMessageDistributeTime [<=0ms]:4 [010ms]:8 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:01:02 INFO StoreStatsService - [STORETPS] put_tps 0.4666355576294914 get_found_tps 0.1833211119258716 get_miss_tps 4.699686687554163 get_transfered_tps 0.216652223185121 2022-01-07 16:01:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 28, PutMessageDistributeTime [<=0ms]:9 [010ms]:19 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:02:02 INFO StoreStatsService - [STORETPS] put_tps 0.133322223148071 get_found_tps 0.133322223148071 get_miss_tps 6.21614865427881 get_transfered_tps 0.266644446296142 2022-01-07 16:02:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 8, PutMessageDistributeTime [<=0ms]:3 [010ms]:5 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:03:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.0 get_miss_tps 6.382907806146257 get_transfered_tps 0.0 2022-01-07 16:03:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:04:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.0 get_miss_tps 5.182901424881259 get_transfered_tps 0.0 2022-01-07 16:04:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:05:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.016665277893508874 get_miss_tps 6.649445879510041 get_transfered_tps 0.049995833680526625 2022-01-07 16:05:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:06:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.0 get_miss_tps 5.616292247183521 get_transfered_tps 0.0 2022-01-07 16:06:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:07:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.0 get_miss_tps 5.649529205899508 get_transfered_tps 0.0 2022-01-07 16:07:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:08:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.0 get_miss_tps 6.832763936338638 get_transfered_tps 0.0 2022-01-07 16:08:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:09:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.0 get_miss_tps 6.282914472368509 get_transfered_tps 0.0 2022-01-07 16:09:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:10:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.0 get_miss_tps 6.966086159486709 get_transfered_tps 0.0 2022-01-07 16:10:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:11:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.0 get_miss_tps 6.166255582961136 get_transfered_tps 0.0 2022-01-07 16:11:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:12:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.0 get_miss_tps 5.232897258561787 get_transfered_tps 0.0 2022-01-07 16:12:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:0 [50100ms]:0 [100200ms]:0 [200500ms]:0 [500ms1s]:0 [12s]:0 [23s]:0 [34s]:0 [45s]:0 [510s]:0 [10s]:0 2022-01-07 16:13:02 INFO StoreStatsService - [STORETPS] put_tps 0.0 get_found_tps 0.0 get_miss_tps 5.8662755816278915 get_transfered_tps 0.0 2022-01-07 16:13:02 INFO StoreStatsService - [PAGECACHERT] TotalPut 0, PutMessageDistributeTime [<=0ms]:0 [010ms]:0 [1050ms]:

原提问者GitHub用户yrg5101

展开
收起
芬奇福贵 2023-05-26 10:35:11 2698 0
1 条回答
写回答
取消 提交回答
  • 巴拉巴拉巴拉

    可以先检查一下客户端到broker的网络情况

    原回答者GitHub用户RongtongJin

    2023-05-26 16:55:45
    赞同 展开评论 打赏
问答分类：
消息中间件 存储 JSON Java 数据格式 RocketMQ 云消息队列 MQ
问答标签：
云消息队列 MQ客户端 云消息队列 MQ超时 消息队列RocketMQ版客户端 消息队列RocketMQ版超时 消息队列RocketMQ版客户端超时
问答地址：
开发者社区 > 云原生 > 问答
相关产品：
云消息队列 MQ

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

相关问答
RocketMQ5.0客户端cpp版本，这两个问题不解决吗？
23
0
0
RocketMQ默认超时时间是3000ms。 但是重试了3次，总耗时655ms。就报错了怎么办？
33
0
0
客户端调用rocketmq同步生产 进行压测过程中，一段时间后报错，怎么解决？
7
0
0
MQTT如果连接数达到上限，会怎么样呀，会把此前连接的客户端关闭嘛？
18
1
0
RocketMQ nameserver返回给客户端的broker地址会是内网的？
30
2
0
MQTT客户端上下线消息为啥没有顺序啊,啥时候能优化一下啊？
32
0
0
RocketMQ在生产环境中，会偶发（一两个月发生一次）rocketmq消息发送超时问题？
26
1
0
MQTT平台每隔多长时间 定时检测一次客户端的保活心跳？
66
2
0
MQTT客户端心跳间隔时间最大设置多少？
57
2
0
RocketMQ nodejs版本的客户端有实现PUSH方式的实例吗？
28
2
0

云原生

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践，通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式，助力制造业企业高效上云，实现系统稳定、应用敏捷智能。拥抱云原生，让创新无处不在。

我要提问

相关产品

  • 云消息队列 MQ
    文档详情 产品详情

    • 热门讨论

    热门文章

  • 作为一个经典架构模式，事件驱动在云时代为什么会再次流行呢？
    1817
  • 在图像处理应用场景下，Serverless架构的优势体现在哪些方面？
    2200
  • 如何看待首个 AI 程序员入职科技公司？
    2374
  • Springcloud连接nacos2.2.3一直报错403，user not found，啥原因？
    4751
  • sd从网址安装插件报错：AssertionError: extension access disab
    8054
  • 让 AI 写代码，能做出什么样的项目？
    7691
  • 怎么查看registry.aliyuncs.com/google_containers都有哪些镜像
    1851
  • nacos部署需要开放哪几个端口？
    169
  • 哪位大佬知道stable diffusion生成的图片存在哪个文件夹?
    8044
  • sd界面里为啥没有lora模块选项呀？
    75750
    • 展开全部
  • Docker 镜像加速器
    397545
  • Docker CE 镜像源站
    392325
  • Apache RocketMQ ACL 2.0 全新升级
    187096
  • OpenKruise v1.6 版本解读：增强多域管理能力
    164354
  • 3分钟，了解阿里云热门开发者工具 Cloud Toolkit
    86498
  • 1 名工程师轻松管理 20 个工作流，创业企业用 Serverless 让数据处理流程提效
    64441
  • Docker学习路线图 (持续更新中)
    85513
  • 基于Docker的Tensorflow实验环境
    57260
  • Docker常见故障排查指南 - 阿里云容器服务
    55096
  • SLS 查询新范式：使用 SPL 对日志进行交互式探索
    46289
    • 展开全部

    相关课程

    更多
  • 消息队列 MNS 入门课程
    2268
    9
    去学习
  • RocketMQ知识精讲与项目实战（第一阶段）
    711
    34
    去学习
  • RocketMQ知识精讲与项目实战（第二阶段）
    270
    54
    去学习
  • RocketMQ知识精讲与项目实战（第三阶段）
    308
    60
    去学习
  • 微服务实战-RocketMQ Binder
    1965
    6
    去学习

    • 相关文章

  • 【刷题】 leetcode 2 .两数相加
  • Docker数据集与自定义镜像：构建高效容器的关键要素
  • 【刷题】 leetcode 面试题 01.06 字符串压缩
  • Docker自定义JDK镜像并拉取至阿里云镜像仓库全攻略
  • etcd入门指南

    • 相关电子书

    更多
    • RocketMQ Client-GO 介绍 立即下载
    RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载
    基于 RocketMQ Prometheus Exporter 打造定制化 DevOps 平台 立即下载

    相关实验场景

    更多
  • 消息队列RocketMQ版：消费异常运维排查体验
    173
    1.0小时
    去实验
  • 部署RabbitMQ
    109
    1.0小时
    去实验
  • RocketMQ运维自我实践
    570
    0.5小时
    去实验
  • RocketMQ的常规运维实践应用
    786
    1.0小时
    去实验
  • RocketMQ中使用Java客户端发送消息和消费的应用
    928
    1.0小时
    去实验
  • RocketMQ一站式入门使用
    4343
    1.0小时
    去实验