You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by "41405465 (via GitHub)" <gi...@apache.org> on 2023/09/20 08:46:02 UTC

[GitHub] [rocketmq-clients] 41405465 created a discussion: rocketmq5.0代理模式grpc连接C++客户端多个IP配置问题

GitHub user 41405465 created a discussion: rocketmq5.0代理模式grpc连接C++客户端多个IP配置问题

broker端采用local模式部署，开启代理模式，grpc端口是18081，共两台机器：ip1:18081;ip2:18081
c++客户端配置endpoint的时候，是只能配一个，还是要配两个，目前发现c++客户端配两个这样的ip会报错：ip1:18081;ip2:18081
broker上面proxy.log报错如下：
![image](https://github.com/apache/rocketmq-clients/assets/24800419/7a91f909-5142-4577-a0a2-8693f01c0593)
2023-09-20 10:03:30 ERROR GrpcRouteThreadPool-0 - internal server error
java.lang.IllegalArgumentException: Unparseable port number: 172.26.240.17:18081,172.26.240.18
        at com.google.common.net.HostAndPort.fromString(HostAndPort.java:201)
        at com.google.common.net.HostAndPort.fromParts(HostAndPort.java:134)
        at org.apache.rocketmq.proxy.grpc.v2.route.RouteActivity.convertToAddressList(RouteActivity.java:198)
        at org.apache.rocketmq.proxy.grpc.v2.route.RouteActivity.queryRoute(RouteActivity.java:65)
        at org.apache.rocketmq.proxy.grpc.v2.DefaultGrpcMessingActivity.queryRoute(DefaultGrpcMessingActivity.java:99)
        at org.apache.rocketmq.proxy.grpc.v2.GrpcMessagingApplication.lambda$queryRoute$2(GrpcMessagingApplication.java:204)
        at org.apache.rocketmq.proxy.grpc.v2.GrpcMessagingApplication$GrpcTask.run(GrpcMessagingApplication.java:447)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)

客户端报错如下：
![0fb2b60ec1c373349f19c3442a666f6](https://github.com/apache/rocketmq-clients/assets/24800419/90252be1-8b29-44d4-98c4-53275065fbab)



GitHub link: https://github.com/apache/rocketmq-clients/discussions/605

----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org

[GitHub] [rocketmq-clients] 41405465 closed a discussion: rocketmq5.0代理模式grpc连接C++客户端多个IP配置问题

Posted by "41405465 (via GitHub)" <gi...@apache.org>.
GitHub user 41405465 closed a discussion: rocketmq5.0代理模式grpc连接C++客户端多个IP配置问题

broker端采用local模式部署，开启代理模式，grpc端口是18081，共两台机器：ip1:18081;ip2:18081
c++客户端配置endpoint的时候，是只能配一个，还是要配两个，目前发现c++客户端配两个这样的ip会报错：ip1:18081;ip2:18081
broker上面proxy.log报错如下：
![image](https://github.com/apache/rocketmq-clients/assets/24800419/7a91f909-5142-4577-a0a2-8693f01c0593)
2023-09-20 10:03:30 ERROR GrpcRouteThreadPool-0 - internal server error
java.lang.IllegalArgumentException: Unparseable port number: 172.26.240.17:18081,172.26.240.18
        at com.google.common.net.HostAndPort.fromString(HostAndPort.java:201)
        at com.google.common.net.HostAndPort.fromParts(HostAndPort.java:134)
        at org.apache.rocketmq.proxy.grpc.v2.route.RouteActivity.convertToAddressList(RouteActivity.java:198)
        at org.apache.rocketmq.proxy.grpc.v2.route.RouteActivity.queryRoute(RouteActivity.java:65)
        at org.apache.rocketmq.proxy.grpc.v2.DefaultGrpcMessingActivity.queryRoute(DefaultGrpcMessingActivity.java:99)
        at org.apache.rocketmq.proxy.grpc.v2.GrpcMessagingApplication.lambda$queryRoute$2(GrpcMessagingApplication.java:204)
        at org.apache.rocketmq.proxy.grpc.v2.GrpcMessagingApplication$GrpcTask.run(GrpcMessagingApplication.java:447)
        at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
        at java.util.concurrent.FutureTask.run(FutureTask.java:266)
        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)
        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)
        at java.lang.Thread.run(Thread.java:745)

客户端报错如下：
![0fb2b60ec1c373349f19c3442a666f6](https://github.com/apache/rocketmq-clients/assets/24800419/90252be1-8b29-44d4-98c4-53275065fbab)



GitHub link: https://github.com/apache/rocketmq-clients/discussions/605

----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org

[GitHub] [rocketmq-clients] lizhanhui closed the discussion with a comment: rocketmq5.0代理模式grpc连接C++客户端多个IP配置问题

Posted by "lizhanhui (via GitHub)" <gi...@apache.org>.
GitHub user lizhanhui closed the discussion with a comment: rocketmq5.0代理模式grpc连接C++客户端多个IP配置问题

https://github.com/apache/rocketmq-clients/issues/606 

GitHub link: https://github.com/apache/rocketmq-clients/discussions/605#discussioncomment-7065272

----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org