RocketMQ目前配置了proxy的地址,但好像还是一直有那个日志,是不是我们的java组件有问题呢?
RocketMQ的Proxy在架构中扮演着重要的角色,它主要负责协议适配、权限管理、消息管理等计算功能,而Broker则更专注于存储。因此,如果Proxy的配置出现问题或者运行状态异常,可能会导致相关日志持续出现。
首先,您需要确认Proxy的配置是否正确,这包括检查Proxy的端口和配置文件等是否正确。此外,也需要关注Proxy的运行状态,如其日志是否正常,以及Proxy与Broker的网络连接状况等。
另一方面,为了支持长远的云原生发展,RocketMQ引入了无状态的Proxy模块,同时新的架构图中Producer/Consumer不再需要注册到NameServer,而是由Proxy跟NameServer进行交互,如查询TopicRouteData。因此,如果您使用的是这一版本的客户端,也必须使用Proxy作为endpoint。
最后,请注意,如果Proxy和Broker是在同一进程中部署(即本地模式),那么主要的集群配置仍然以Broker为基础进行。
看起来走的是remoting协议啊,proxy你要走grpc协议 ,此回答整理自钉群“群2-Apache RocketMQ 中国开发者钉钉群”
如果在配置了RocketMQ Proxy的地址后仍然看到相关的日志,可能是Java组件在处理Proxy地址时存在问题。建议检查以下方面:
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/