brpc streaming发送数据问题

[dl239]

用brpc streaming发送数据有时候报错
src/brpc/input_messenger.cpp:88] Fail to parse response from xxxx:9991 by streaming_rpc at client-side
src/brpc/input_messenger.cpp:249] Close fd=18 SocketId=1243@xxxx:9991@39948: absolutely wrong message

建立stream时和example一样，用的BAIDU_STD, options.protocol = brpc::PROTOCOL_BAIDU_STD
求教这是什么问题

[dl239]

A给B发RPC请求的时候，A给B发送streaming数据 有问题
A给B发RPC请求的时候，B给A发送streaming数据 正常
从log看是接受包给搞混了？

[chenzhangyi]

上下文有更多日志吗，或者贴下可以复现的代码?

[dl239]

E0709 14:22:49.602311 4389 src/brpc/input_messenger.cpp:88] Fail to parse response from xxxx:9991 by streaming_rpc at client-side
W0709 14:22:49.628439 4389 src/brpc/input_messenger.cpp:249] Close fd=18 SocketId=1243@xxxx:9991@39948: absolutely wrong message
I0709 14:22:49.728741 4390 src/brpc/socket.cpp:2209] Checking SocketId=1243@xxxx:9991
I0709 14:22:49.729141 4380 src/brpc/socket.cpp:2271] Revived SocketId=1243@xxxx:9991

没有打出其他的日志，调用brpc::StreamWrite返回码是 22
实际代码比较复杂，实现就是A一直给B发送普通RPC请求，当A给B再建立stream发送streaming数据时，stream发送一小段数据就有问题了

[dl239]

@jamesge @chenzhangyi 辛苦看下哈

[stale]

This issue has been automatically marked as stale because it's inactive for a long time. It will be closed if no further activity occurs, reopen if you have further ideas. Thank you for your contributions! 由于很久没有活跃，此Issue已被自动标记为过期。之后几天仍无变化的话将会被关闭，若你有新想法则可重新打开。感谢你的贡献!

[unlimitlearning]

我现在也遇到了这个问题，请问楼主找到解决方案了吗

[cstarc]

也遇到了类似问题，当A在给B发送普通rpc请求是，同时发送stream，同一个端口，同一个service，会出现此错误， 分开端口就没问题，是不能同一个端口？

[wwbmmm]

好像是普通rpc和streaming rpc不能混用一个连接，可以考虑把streaming rpc的connection_type设置成pooled试试

[yujun777]

我也遇到这种报错了

[codetrek]

这个问题没有解决方案吗？

[aporix]

这个问题原因是什么，感觉不好理解啊

[aporix]

定位到原因了，stream rpc 建流是特殊的rpc ,请求是PRPC,但是回包是STRM,所以建流和流传输都是回的STRM,如果夹杂普通的PRPC,就会回PRPC包，就会客户端解析失败

[ahnselina]

定位到原因了，stream rpc 建流是特殊的rpc ,请求是PRPC,但是回包是STRM,所以建流和流传输都是回的STRM,如果夹杂普通的PRPC,就会回PRPC包，就会客户端解析失败

你好，我也遇到这个问题了，我这边是偶现的，启动的时候有时会报这个错误，有时又不会，看你的解释，意思是普通的rpc和那种stream的rpc必须分开用不同的接口吗，我这边目前是混用的