请教使用 rust client 连接失败的问题

[doveq]

同一个机器上安装的 RocketMQ Dashboard 可正常连接管理。但使用的是官方 https://github.com/apache/rocketmq-clients/blob/master/rust/examples/producer.rs 的例子一直提示如下错误：

Compiling testmq v0.1.0 (/root/testmq)
    Finished dev [unoptimized + debuginfo] target(s) in 5.50s
     Running `target/debug/testmq`
Sep 07 03:06:15.214 INFO[/root/.cargo/registry/src/index.crates.io-6f17d22bba15001f/rocketmq-5.0.0/src/session.rs:175:9] create session success, peer: 172.16.0.182:9876, component: session
producer start failed: Client internal error at client.start => send rpc telemetry failed

Context:
    called: session.start

Source: status: Unknown, message: "transport error", details: [], metadata: MetadataMap { headers: {} }

Caused by:
    0: transport error
    1: connection error: stream closed because of a broken pipe
    2: stream closed because of a broken pipe

2个服务的启动方式：

sh mqnamesrv
sh mqbroker -n mqnamesrv:9876 -c /home/rocketmq/conf/broker.conf --enable-proxy

broker.conf 配置如下

# 集群名称
brokerClusterName = DefaultCluster
# 节点名称
brokerName = broker-a
# broker id节点ID， 0 表示 master, 其他的正整数表示 slave，不能小于0 
brokerId = 0
# Broker服务地址        String  内部使用填内网ip，如果是需要给外部使用填公网ip
brokerIP1 = 172.16.0.182
# Broker角色
brokerRole = ASYNC_MASTER
# 刷盘方式
flushDiskType = ASYNC_FLUSH
# 在每天的什么时间删除已经超过文件保留时间的 commit log，默认值04
deleteWhen = 04
# 以小时计算的文件保留时间 默认值72小时
fileReservedTime = 72
# 是否允许Broker 自动创建Topic，建议线下开启，线上关闭
autoCreateTopicEnable=true
# 是否允许Broker自动创建订阅组，建议线下开启，线上关闭
autoCreateSubscriptionGroup=true

请问可能是什么问题？谢谢

[lizhanhui]

看报错，是网络联通性问题。建议用telnet或者其它网络工具验证下。

[doveq]

开始我也判断是网络问题，后来把代码放在跟 RocketMQ Dashboard 服务同一个docker容器里。 Dashboard 能连接成功，但代码还是报这个错误。

[ShadowySpirits]

Rust client 适用于 Proxy 架构的 RocketMQ，请确认下是否正确启动了 Proxy

[doveq]

sh mqbroker -n mqnamesrv:9876 -c /home/rocketmq/conf/broker.conf --enable-proxy ，我理解使用 --enable-proxy 参数是开启了 proxy ， 这样对吗？

[ShadowySpirits]

...create session success, peer: 172.16.0.182:9876...

从你的报错来看是尝试直接连接 nameserver，需要改成 Proxy 的地址

[doveq]

多谢多谢，我单独建一个proxy服务试试看