Skip to content
This repository has been archived by the owner on Jun 1, 2023. It is now read-only.

阿里云非ONSAddr接入方式 #59

Open
awyd234 opened this issue Dec 2, 2019 · 5 comments
Open

阿里云非ONSAddr接入方式 #59

awyd234 opened this issue Dec 2, 2019 · 5 comments

Comments

@awyd234
Copy link

awyd234 commented Dec 2, 2019

现在的阿里云RocketMQ新建示例已经不再使用ONSAddr接入方式,请问是否有办法支持新的接入方式
image
使用旧的实例中的ons接入方式是可以跑通的,使用新版的接入方式一直报No route info of this topic

@messense
Copy link
Owner

messense commented Dec 2, 2019

Use set_namesrv_addr I think?

def set_namesrv_addr(self, addr):

@awyd234
Copy link
Author

awyd234 commented Dec 2, 2019

No effect in the newly created instance, and it raise "No route info of this topic"

@messense
Copy link
Owner

messense commented Dec 2, 2019

Take a look at ~/logs/rocketmq-cpp/*.log and paste some logs here if you can.

@awyd234
Copy link
Author

awyd234 commented Dec 2, 2019

Some logs here, replaced sensitive parameters like group_id as ${GROUP_ID}, and ignored some retry

[2019-Dec-02 16:42:34.463180](info):m_tcpConnectTimeout:3000, m_tcpTransportTryLockTimeout:3, m_pullThreadNum:8[TcpRemotingClient:61]
[2019-Dec-02 16:42:34.463346](info):MQClient start,groupname:${GROUP_ID},clientID:6442-${LOCAL_INTERNAL_IP}@DEFAULT,instanceName:DEFAULT,nameserveraddr:${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080[start:141]
[2019-Dec-02 16:42:34.463372](info):DefaultMQProducer:${GROUP_ID} start[start:69]
[2019-Dec-02 16:42:34.463388](info):updateNameServerAddressList: [${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080][updateNameServerAddressList:123][2019-Dec-02 16:42:34.463356](info):TcpRemotingClient::boost asio async service running[boost_asio_work:67]
[2019-Dec-02 16:42:34.463404](info):update Namesrv:${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080[updateNameServerAddressList:148]
[2019-Dec-02 16:42:34.463418](info):user specfied name server address: ${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080[registerProducer:332]
[2019-Dec-02 16:42:34.463429](info):MQClientFactory:6442-${LOCAL_INTERNAL_IP}@DEFAULT start[start:68]
[2019-Dec-02 16:42:34.463471](warning):sendheartbeat brokeradd is empty[sendHeartbeatToAllBroker:703]
[2019-Dec-02 16:42:34.463552](info):updateTopicRouteInfoFromNameServer start:${MY_TOPIC}[updateTopicRouteInfoFromNameServer:159]
[2019-Dec-02 16:42:34.463571](info):start scheduled task:6442-${LOCAL_INTERNAL_IP}@DEFAULT[startScheduledTask:803]
[2019-Dec-02 16:42:34.463619](info):namesrvIndex is:1, index:0, namesrvaddrlist size:1[CreateNameServerTransport:379]
[2019-Dec-02 16:42:34.463861](info):try to connect to fd:15, addr:${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com[connect:172]
[2019-Dec-02 16:42:34.473792](warning):sendheartbeat brokeradd is empty[sendHeartbeatToAllBroker:703]
[2019-Dec-02 16:42:34.490490](info):eventcb: received event:80 on fd:15[eventCallback:191]
[2019-Dec-02 16:42:34.490575](info):eventcb: connect to fd:15 successfully[eventCallback:193]
[2019-Dec-02 16:42:34.490630](info):connect server with addr:${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080 success[CreateTransport:348]
[2019-Dec-02 16:42:34.517449](info):updateTopicRouteInfoFromNameServer with default[tryToFindTopicPublishInfo:141]
[2019-Dec-02 16:42:34.517505](info):updateTopicRouteInfoFromNameServer start:${MY_TOPIC}[updateTopicRouteInfoFromNameServer:159]
[2019-Dec-02 16:42:34.544419](warning):tryToFindTopicPublishInfo null:${MY_TOPIC}[tryToFindTopicPublishInfo:146]
[2019-Dec-02 16:42:34.544503](warning):Retry many times, still failed[sendDefaultImpl:376]
[2019-Dec-02 16:42:34.544520](info):updateTopicRouteInfoFromNameServer start:${MY_TOPIC}[updateTopicRouteInfoFromNameServer:159]
[2019-Dec-02 16:42:34.571434](info):updateTopicRouteInfoFromNameServer with default[tryToFindTopicPublishInfo:141]
[2019-Dec-02 16:42:34.571515](info):updateTopicRouteInfoFromNameServer start:${MY_TOPIC}[updateTopicRouteInfoFromNameServer:159]
[2019-Dec-02 16:42:34.598445](warning):tryToFindTopicPublishInfo null:${MY_TOPIC}[tryToFindTopicPublishInfo:146]
[2019-Dec-02 16:42:34.598537](warning):Retry many times, still failed[sendDefaultImpl:376]
[2019-Dec-02 16:42:34.761287](error):msg: No route info of this topic: ${MY_TOPIC},error:-1,in file </tmp/rocketmq-client-cpp/src/producer/DefaultMQProducer.cpp> line:379[send:115]
[2019-Dec-02 16:42:34.764294](info):DefaultMQProducer shutdown[shutdown:96]
[2019-Dec-02 16:42:34.764478](info):disconnect:${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080 start. event:0xf78e90[disconnect:132]
[2019-Dec-02 16:42:34.764526](info):disconnect:${INSTANCE_ID}.cn-zhangjiakou.mq-internal.aliyuncs.com:8080 completely[disconnect:135]
[2019-Dec-02 16:42:34.764748](error):TcpRemotingClient::stopAllTcpTransportThread End, m_tcpTable:0[stopAllTcpTransportThread:119]
[2019-Dec-02 16:42:34.764771](info):MQClientFactory:6442-${LOCAL_INTERNAL_IP}@DEFAULT shutdown[shutdown:298]
[2019-Dec-02 16:42:34.764784](info):MQClientFactory:6442-${LOCAL_INTERNAL_IP}@DEFAULT destruct[~MQClientFactory:50]

@messense
Copy link
Owner

messense commented Dec 2, 2019

I tried it and it indeed raises No route info of this topic exception, the log isn't very helpful.

It might be a issue with https://github.com/apache/rocketmq-client-cpp , in the mean time you can try https://github.com/apache/rocketmq-client-python to see if it also suffers from this problem.

Sign up for free to subscribe to this conversation on GitHub. Already have an account? Sign in.
Labels
None yet
Projects
None yet
Development

No branches or pull requests

2 participants