JanYork
JanYork
> > > > 你是否启用了rocketmq-proxy? > > > > > > > > > 不清楚,rocketmq-proxy是什么,怎么看是否启用,以及怎么取消。 > > > @JanYork > > > > 如果你使用新版本的rocketmq-client,也就是grpc版本的客户端,那么需要开启rocketmq-proxy才可以成功连接,端口也不在是直连nameserve,而是连接proxy的端口,你可以看看官方文档 > > 好的,谢谢。我们现在用的是4.x的。等升级版本启用proxy后再看看。 4.x版本只能支持remoting协议,之前4.x node版本的client是基于之前的cpp版本的,而且处于dev状态,如果你要在node中使用rocketmq,我建议升级5.x。
> > 现在新版本的nodejs,哥们有没有测试过消息发送速率,我测试700条每秒,发送效率不如之间cpp版本的nodejs-client > > 现在新版本的nodejs,哥们有没有测试过消息发送速率,我测试700条每秒,发送效率不如之间cpp版本的nodejs-client This phenomenon should be normal, before it is based on node.js cpp extension implementation, the execution rate of the cpp language is relatively better...
Perhaps you could try putting the consumer and producer into a node.js worker to avoid the latency caused by the single-threaded event loop. I'm not sure if the latency is...
Maybe it shouldn't be like that, group is an abstraction of the isolated situation of topic, and topic is the largest level of business classification, according to your needs, I...
@fengmk2 Hello, could I kindly ask you to spare some of your valuable time to take a look at this issue? It seems the error is being thrown deliberately, and...
> This is an error returned by the rocketmq server. Can you tell me why this happens? I didn't do anything to the server, just started it. But this problem...
2024-09-19 19:53:36 INFO ClientHousekeepingScheduledThread1 - clear handle of this client when client unregister. group:task-to-pool, clientChannelInfo:ClientChannelInfo [channel=GrpcClientChannel{clientId=JanYorkMacBook-Pro.local@6593@1@m198e8vo, remoteAddress=169.254.95.59:54910, localAddress=169.254.95.59:8081}, clientId=JanYorkMacBook-Pro.local@6593@1@m198e8vo, language=HTTP, version=473, lastUpdateTimestamp=1726746690044] 2024-09-19 19:53:36 INFO ClientHousekeepingScheduledThread1 - remove grpc channel...
> Do you have any other questions? If there are no more, the issue will be closed. How to get the `reason` parameter when the connection is disconnected? Like node...
> ```go > io.On("disconnect", func(reason ...any) { > utils.Log().Info(`socket %s disconnected due to %s`, socket.Id(), reason[0]) > }) > ``` Thanks, And, How can I get all socket instances in...
proxy logs: ``` 2024-09-19 19:53:36 INFO ClientHousekeepingScheduledThread1 - clear handle of this client when client unregister. group:task-to-pool, clientChannelInfo:ClientChannelInfo [channel=GrpcClientChannel{clientId=JanYorkMacBook-Pro.local@6593@1@m198e8vo, remoteAddress=169.254.95.59:54910, localAddress=169.254.95.59:8081}, clientId=JanYorkMacBook-Pro.local@6593@1@m198e8vo, language=HTTP, version=473, lastUpdateTimestamp=1726746690044] 2024-09-19 19:53:36 INFO ClientHousekeepingScheduledThread1 -...