MOSN不支持反向push的协议，如果自己实现的话代码改动的方向是什么样的呢？

[dhsjgdf]

使用MOSN解析rocketmq协议时发现rocketmq有反向push的请求（就是rocketmq-broker主动发起请求到rocketmq-consumer），但是MOSN不支持此类协议，如果我实现这样能力的话，需要如何改造MOSN呢？

[taoyuanyuan]

需要一个新的network filter扩展，类似 proxy（https://github.com/mosn/mosn/tree/master/pkg/filter/network/proxy）， 这个filter的模型是ping-pong。

[dhsjgdf]

https://github.com/mosn/mosn/tree/master/pkg/filter/network/proxy研究过这个包里面的代码，看完之后感觉没什么帮助；现在rocketmq协议中既有正向的请求(rocketmq-comsuer-->rocketmq-broker)又有反向请求(rocketmq-broker-->rocketmq-comsuer)，我想着从handleFrame方法入手来改，但是mosn多路复用的实现不是想象的是一个map，往里面存就好了，从handleFrame也没法入手，现在不知道该怎么办了

[alpha-baby]

你要做的就是把 upstream 和 downstream 的 tcp 连接给关联起来，当 upstream 的连接来数据过后，直接发给关联的 downstream 连接
如果你想找代码参考，可以看 https://github.com/envoyproxy/envoy/tree/main/contrib/rocketmq_proxy/filters/network/source

[dhsjgdf]

我知道我应该 upstream 和 downstream 的 tcp 连接给关联起来，但是不知道如何下手；envoy是C++写的，之前看过rocktemq那块的功能也看不懂就放弃了