You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by "kongguyoulan3 (via GitHub)" <gi...@apache.org> on 2025/10/25 07:53:30 UTC
[D] 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了 [rocketmq]
GitHub user kongguyoulan3 created a discussion: 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了
rocketmq version: 5.3.3
GitHub link: https://github.com/apache/rocketmq/discussions/9782
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了 [rocketmq]
Posted by "kongguyoulan3 (via GitHub)" <gi...@apache.org>.
GitHub user kongguyoulan3 closed a discussion: 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了
rocketmq version: 5.3.3
GitHub link: https://github.com/apache/rocketmq/discussions/9782
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了，内网可以正常访问 [rocketmq]
Posted by "huangjuncong (via GitHub)" <gi...@apache.org>.
GitHub user huangjuncong added a comment to the discussion: 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了，内网可以正常访问
8081 8080 放开了吗？
GitHub link: https://github.com/apache/rocketmq/discussions/9782#discussioncomment-15058057
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了，内网可以正常访问 [rocketmq]
Posted by "kongguyoulan3 (via GitHub)" <gi...@apache.org>.
GitHub user kongguyoulan3 added a comment to the discussion: 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了，内网可以正常访问
brokerIP在broker.conf中配置了，配置为公网ip，现在外网能访问进来了，但是内网中的消费者却不能消费了
GitHub link: https://github.com/apache/rocketmq/discussions/9782#discussioncomment-15044655
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了，内网可以正常访问 [rocketmq]
Posted by "kongguyoulan3 (via GitHub)" <gi...@apache.org>.
GitHub user kongguyoulan3 added a comment to the discussion: 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了，内网可以正常访问
在内网mq的服务器上抓包可以抓到，公网映射到内网的网络是通的
GitHub link: https://github.com/apache/rocketmq/discussions/9782#discussioncomment-14778749
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了，内网可以正常访问 [rocketmq]
Posted by "kongguyoulan3 (via GitHub)" <gi...@apache.org>.
GitHub user kongguyoulan3 reopened a discussion: 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了，内网可以正常访问
rocketmq version: 5.3.3
broker.conf 配置信息如下:
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
storePathRootDir=/opt/rocketmq/store
storePathCommitLog=/opt/rocketmq/store/commitlog
namesrvAddr=0.0.0.0:9876
autoCreateTopicEnable=false
authenticationEnabled = true
authenticationProvider = org.apache.rocketmq.auth.authentication.provider.DefaultAuthenticationProvider
initAuthenticationUser = {"username":"rocketmq","password":"12345678"}
innerClientAuthenticationCredentials = {"accessKey":"rocketmq","secretKey":"12345678"}
authenticationMetadataProvider = org.apache.rocketmq.auth.authentication.provider.LocalAuthenticationMetadataProvider
authorizationEnabled = true
authorizationProvider = org.apache.rocketmq.auth.authorization.provider.DefaultAuthorizationProvider
authorizationMetadataProvider = org.apache.rocketmq.auth.authorization.provider.LocalAuthorizationMetadataProvider
rmq-proxy.json 配置信息如下:
{
"rocketMQClusterName": "DefaultCluster",
"authenticationEnabled": true,
"remotingListenPort": 8080,
"grpcServerPort": 8081,
"authenticationProvider": "org.apache.rocketmq.auth.authentication.provider.DefaultAuthenticationProvider",
"authenticationMetadataProvider": "org.apache.rocketmq.proxy.auth.ProxyAuthenticationMetadataProvider",
"innerClientAuthenticationCredentials": "{\"accessKey\":\"rocketmq\", \"secretKey\":\"12345678\"}",
"authorizationEnabled": true,
"authorizationProvider": "org.apache.rocketmq.auth.authorization.provider.DefaultAuthorizationProvider",
"authorizationMetadataProvider": "org.apache.rocketmq.proxy.auth.ProxyAuthorizationMetadataProvider"
}
客户端连接rocketmq报错信息:
Exception in thread "main" java.lang.IllegalStateException: Expected the service ProducerImpl-0 [FAILED] to be RUNNING, but the service has FAILED
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractService.checkCurrentState(AbstractService.java:384)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractService.awaitRunning(AbstractService.java:308)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractIdleService.awaitRunning(AbstractIdleService.java:160)
at org.apache.rocketmq.client.java.impl.producer.ProducerBuilderImpl.build(ProducerBuilderImpl.java:93)
at org.example.ProducerSingleton.buildProducer(ProducerSingleton.java:68)
at org.example.ProducerSingleton.getInstance(ProducerSingleton.java:75)
at org.example.ProducerNormalMessageExample.main(ProducerNormalMessageExample.java:38)
Caused by: java.util.concurrent.CancellationException: Task was cancelled.
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.cancellationExceptionWithCause(AbstractFuture.java:1560)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:590)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:571)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.FluentFuture$TrustedFuture.get(FluentFuture.java:91)
at org.apache.rocketmq.client.java.impl.ClientImpl.startUp(ClientImpl.java:188)
at org.apache.rocketmq.client.java.impl.producer.ProducerImpl.startUp(ProducerImpl.java:119)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractIdleService$DelegateService.lambda$doStart$0(AbstractIdleService.java:64)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.Callables.lambda$threadRenaming$3(Callables.java:105)
at java.lang.Thread.run(Thread.java:750)
GitHub link: https://github.com/apache/rocketmq/discussions/9782
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了，内网可以正常访问 [rocketmq]
Posted by "kongguyoulan3 (via GitHub)" <gi...@apache.org>.
GitHub user kongguyoulan3 edited a discussion: 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了，内网可以正常访问
rocketmq version: 5.3.3
broker.conf 配置信息如下:
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
storePathRootDir=/opt/rocketmq/store
storePathCommitLog=/opt/rocketmq/store/commitlog
namesrvAddr=0.0.0.0:9876
autoCreateTopicEnable=false
authenticationEnabled = true
authenticationProvider = org.apache.rocketmq.auth.authentication.provider.DefaultAuthenticationProvider
initAuthenticationUser = {"username":"rocketmq","password":"12345678"}
innerClientAuthenticationCredentials = {"accessKey":"rocketmq","secretKey":"12345678"}
authenticationMetadataProvider = org.apache.rocketmq.auth.authentication.provider.LocalAuthenticationMetadataProvider
authorizationEnabled = true
authorizationProvider = org.apache.rocketmq.auth.authorization.provider.DefaultAuthorizationProvider
authorizationMetadataProvider = org.apache.rocketmq.auth.authorization.provider.LocalAuthorizationMetadataProvider
rmq-proxy.json 配置信息如下:
{
"rocketMQClusterName": "DefaultCluster",
"authenticationEnabled": true,
"remotingListenPort": 8080,
"grpcServerPort": 8081,
"authenticationProvider": "org.apache.rocketmq.auth.authentication.provider.DefaultAuthenticationProvider",
"authenticationMetadataProvider": "org.apache.rocketmq.proxy.auth.ProxyAuthenticationMetadataProvider",
"innerClientAuthenticationCredentials": "{\"accessKey\":\"rocketmq\", \"secretKey\":\"12345678\"}",
"authorizationEnabled": true,
"authorizationProvider": "org.apache.rocketmq.auth.authorization.provider.DefaultAuthorizationProvider",
"authorizationMetadataProvider": "org.apache.rocketmq.proxy.auth.ProxyAuthorizationMetadataProvider"
}
客户端连接rocketmq报错信息:
Exception in thread "main" java.lang.IllegalStateException: Expected the service ProducerImpl-0 [FAILED] to be RUNNING, but the service has FAILED
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractService.checkCurrentState(AbstractService.java:384)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractService.awaitRunning(AbstractService.java:308)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractIdleService.awaitRunning(AbstractIdleService.java:160)
at org.apache.rocketmq.client.java.impl.producer.ProducerBuilderImpl.build(ProducerBuilderImpl.java:93)
at org.example.ProducerSingleton.buildProducer(ProducerSingleton.java:68)
at org.example.ProducerSingleton.getInstance(ProducerSingleton.java:75)
at org.example.ProducerNormalMessageExample.main(ProducerNormalMessageExample.java:38)
Caused by: java.util.concurrent.CancellationException: Task was cancelled.
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.cancellationExceptionWithCause(AbstractFuture.java:1560)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.getDoneValue(AbstractFuture.java:590)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractFuture.get(AbstractFuture.java:571)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.FluentFuture$TrustedFuture.get(FluentFuture.java:91)
at org.apache.rocketmq.client.java.impl.ClientImpl.startUp(ClientImpl.java:188)
at org.apache.rocketmq.client.java.impl.producer.ProducerImpl.startUp(ProducerImpl.java:119)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.AbstractIdleService$DelegateService.lambda$doStart$0(AbstractIdleService.java:64)
at org.apache.rocketmq.shaded.com.google.common.util.concurrent.Callables.lambda$threadRenaming$3(Callables.java:105)
at java.lang.Thread.run(Thread.java:750)
GitHub link: https://github.com/apache/rocketmq/discussions/9782
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了，内网可以正常访问 [rocketmq]
Posted by "kongguyoulan3 (via GitHub)" <gi...@apache.org>.
GitHub user kongguyoulan3 edited a discussion: 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了，内网可以正常访问
rocketmq version: 5.3.3
broker.conf 配置信息如下:
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
storePathRootDir=/opt/rocketmq/store
storePathCommitLog=/opt/rocketmq/store/commitlog
namesrvAddr=0.0.0.0:9876
autoCreateTopicEnable=false
authenticationEnabled = true
authenticationProvider = org.apache.rocketmq.auth.authentication.provider.DefaultAuthenticationProvider
initAuthenticationUser = {"username":"rocketmq","password":"12345678"}
innerClientAuthenticationCredentials = {"accessKey":"rocketmq","secretKey":"12345678"}
authenticationMetadataProvider = org.apache.rocketmq.auth.authentication.provider.LocalAuthenticationMetadataProvider
authorizationEnabled = true
authorizationProvider = org.apache.rocketmq.auth.authorization.provider.DefaultAuthorizationProvider
authorizationMetadataProvider = org.apache.rocketmq.auth.authorization.provider.LocalAuthorizationMetadataProvider
rmq-proxy.json 配置信息如下:
GitHub link: https://github.com/apache/rocketmq/discussions/9782
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org
Re: [D] 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了 [rocketmq]
Posted by "kongguyoulan3 (via GitHub)" <gi...@apache.org>.
GitHub user kongguyoulan3 edited a discussion: 内网部署了rocketmq5.3.3版本，客户端通过访问公网映射到内网的这个rocketmq，连接失败了
rocketmq version: 5.3.3
broker.conf 配置信息如下:
brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH
storePathRootDir=/opt/rocketmq/store
storePathCommitLog=/opt/rocketmq/store/commitlog
namesrvAddr=0.0.0.0:9876
autoCreateTopicEnable=false
authenticationEnabled = true
authenticationProvider = org.apache.rocketmq.auth.authentication.provider.DefaultAuthenticationProvider
initAuthenticationUser = {"username":"rocketmq","password":"12345678"}
innerClientAuthenticationCredentials = {"accessKey":"rocketmq","secretKey":"12345678"}
authenticationMetadataProvider = org.apache.rocketmq.auth.authentication.provider.LocalAuthenticationMetadataProvider
authorizationEnabled = true
authorizationProvider = org.apache.rocketmq.auth.authorization.provider.DefaultAuthorizationProvider
authorizationMetadataProvider = org.apache.rocketmq.auth.authorization.provider.LocalAuthorizationMetadataProvider
rmq-proxy.json 配置信息如下:
GitHub link: https://github.com/apache/rocketmq/discussions/9782
----
This is an automatically sent email for dev@rocketmq.apache.org.
To unsubscribe, please send an email to: dev-unsubscribe@rocketmq.apache.org