mq地址为域名时RebalanceService解析报错

[cyejing]

rocketmq/remoting/src/main/java/org/apache/rocketmq/remoting/common/RemotingHelper.java

Line 56 in a5d72be

String[] s = addr.split(":");

如地址为: http://xxx:8080/xxx
这段代码不能解析出正确的端口

[devsong]

tcp socket address,like ip:port(eg:127.0.0.1:8080),not http url pattern

[lindzh]

If you want to use http for nameserver discovery,please see here.

    public static final String WS_DOMAIN_NAME = System.getProperty("rocketmq.namesrv.domain", DEFAULT_NAMESRV_ADDR_LOOKUP);
    public static final String WS_DOMAIN_SUBGROUP = System.getProperty("rocketmq.namesrv.domain.subgroup", "nsaddr");
    // http://jmenv.tbsite.net:8080/rocketmq/nsaddr
    public static final String WS_ADDR = "http://" + WS_DOMAIN_NAME + ":8080/rocketmq/" + WS_DOMAIN_SUBGROUP;

other wise please go to http://rocketmq.apache.org/docs/simple-example/ for message pub/sub usage documentation.

[zhouxinyu]

As @devsong said, this addr is a TCP socket address.

And the Apache RocketMQ community is global, we recommend using English as our preferred language~