开发者社区 > 云原生 > 云消息队列 > 正文

麻烦各位老师有没有遇到过?Apache RocketMQ中mq4.7.0版本,部署集群,多网络 服务

麻烦各位老师有没有遇到过?Apache RocketMQ中mq4.7.0版本,部署集群,多网络 服务器1:公网IP配置在brokerIP1,内网IP配置在brokerIP2 服务器2:内网IP配置在brokerIP1(没有公网EIP,不能直接访问服务器1的公网IP) 结果: 服务器1:可以另一网络调用并生产数据 服务器3:应用程序调用服务器2的mq,无法获取到生产数据

展开
收起
真的很搞笑 2023-06-18 18:49:00 137 0
3 条回答
写回答
取消 提交回答
  • 根据您提供的信息,我理解您的部署情况如下:

    • 服务器1:公网IP配置在 brokerIP1,内网IP配置在 brokerIP2。
    • 服务器2:内网IP配置在 brokerIP1(没有公网EIP,不能直接访问服务器1的公网IP)。
    • 服务器3:应用程序调用服务器2的 MQ,但无法获取到生产的数据。

    根据这个情况,可能有以下几个原因导致服务器3无法获取到生产的数据:

    1. 网络连接问题:请确保服务器3能够与服务器2进行网络通信,包括检查网络连通性、防火墙设置、路由配置等。您可以尝试通过 ping 命令来测试服务器2是否能够正常访问。

    2. NameServer 配置问题:请确保服务器3的 NameServer 配置正确,可以连接到正确的 NameServer 地址。您可以检查服务器3的 namesrvAddr 配置,确保其指向正确的 NameServer 地址。

    3. 消费者订阅问题:请确保服务器3的消费者正确订阅了生产者所发送的消息。您可以检查消费者的订阅逻辑。

    2023-06-20 08:09:41
    赞同 展开评论 打赏
  • 在 Apache RocketMQ 中,如果使用多网络配置集群,存在公网和内网两种 IP 地址时,可能会出现一些通信问题。根据您所描述的情况,似乎是由于内网和公网之间的网络访问限制导致了生产者无法发送消息到消费者。

    要解决这个问题,可以尝试以下方法:

    1. 检查防火墙和网络规则:如果服务器之间存在内网和公网两种网络环境,那么可能需要对防火墙和网络规则进行相应的配置。例如,如果服务器2无法访问服务器1的公网IP,可以检查服务器1的安全组设置和路由表配置是否正确,并确保公网IP可以正常访问。

    2. 配置 Broker 监听地址:在启动 Broker 时,可以通过指定相应的监听地址来调整 Broker 的网络配置。例如,在您的案例中,可以将服务器1的公网 IP 配置为 Broker 的 brokerIP1,并将内网 IP 配置为 brokerIP2,以便客户端能够通过公网 IP 访问 Broker。

    3. 配置 Name Server:如果您使用了 Name Server 进行 Broker 路由,那么需要在启动 Name Server 时设置正确的监听地址,以便客户端能够访问到 Broker。例如,可以将 Name Server 的监听地址设置为公网 IP 或者内网 IP,具体的设置需要根据实际情况进行调整。

    需要注意的是,多网络配置集群需要对网络环境和安全性方面有较高的要求,并且需要进行相应的测试和验证。如果您在使用 RocketMQ 时遇到了问题,可以参考以上方法进行排查和解决,或者咨询专业人员的支持和建议。

    2023-06-18 21:06:53
    赞同 展开评论 打赏
  • 北京阿里云ACE会长

    Apache RocketMQ 中,部署了一个由多个 Broker 组成的集群,在不同的服务器上,其中某些服务器存在多个网络接口。其中服务器1配置了公网IP和内网IP,而服务器2只配置了内网IP。您在服务器1上可以成功地生产消息,并在应用程序中调用服务器1的 Broker 进行消费,但在服务器2上调用 Broker 时,无法获取到生产的消息,是这样吗?

    如果确实存在这样的问题,可能是由于 Broker 节点之间的网络通信存在问题。在 RocketMQ 中,Broker 节点之间的数据同步是通过主从同步实现的。在您的情况下,由于服务器1存在两个网络接口,可能导致 Broker 节点之间的数据同步出现问题,从而导致服务器2无法获取到生产的消息。

    为了解决这个问题,您可以尝试以下步骤:

    禁用服务器1上的公网IP,只使用内网IP进行通信,确保所有 Broker 节点之间只使用内网IP进行数据同步。

    在服务器2上,检查 Broker 的配置文件中的参数,确保它们与服务器1上的 Broker 配置一致,特别是 Broker 的地址、端口、名称等参数。

    在服务器2上,检查应用程序中使用的 Broker 地址,确保它与服务器1上的 Broker 地址一致。

    检查服务器2是否可以访问服务器1的内网IP,并且服务器1的防火墙设置是否允许来自服务器2的请求。

    如果以上步骤都没有解决问题,可以尝试重新部署 RocketMQ 集群,使用内网IP进行通信。

    2023-06-18 19:49:05
    赞同 展开评论 打赏

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

相关产品

  • 云消息队列 MQ
  • 相关电子书

    更多
    Apache Flink技术进阶 立即下载
    Apache Spark: Cloud and On-Prem 立即下载
    Hybrid Cloud and Apache Spark 立即下载

    相关镜像