search

alibaba / alibaba-rsocket-broker

Alibaba RSocket Broker: Mesh, Streaming & IoT
https://alibroker.info
Apache License 2.0
761 stars 167 forks source link

使用 p2p-service，必须在 application.properties，同时通过 rsocket.routes[0] 指定 provider 才生效 #223

Open songshuohua opened 1 year ago

songshuohua commented 1 year ago

Describe the bug RSocketAutoConfiguration 中，UpstreamManager 早于 CloudEventsProcessor 实例化。前者初始化时，会创建与 broker 的连接，如果 requester 指定了 p2pService，与 broker 建立连接的同时，broker 会立即推送 ServiceInstancesChangedEvent 给当前 App。但此时 CloudEventsProcessor 尚未实例化，无法消费事件，故 UpstreamManager 无法在应用启动时更新 p2pservice 的相关 cluster。

Environment

在目前使用中，我是通过如下方式暂时规避该问题： 在 requester 的 application.properties 中，除了 p2p-services，同时使用 rsocket.routes[0] 指定服务提供方的路由信息。后续如有新的provider 上线，requester 可以通过 CloudEventsProcessor 消费 ServiceInstancesChangedEvent，完成 UpstreamManager 的更新

rsocket.p2p-services=com.alibaba.user.UserService:1.0.0 rsocket.routes[0].service=com.alibaba.user.UserService rsocket.routes[0].version=1.0.0 rsocket.routes[0].uris=tcp://localhost:19999

大佬 @linux-china ，不知是否是我的理解有偏差，可有更直接的办法使用 p2p-services，毕竟通过 rsocket.routes[0] 方式，需要提前知晓 provider 的 url 才行

linux-china commented 1 year ago

这个我确认一下再同步给你，感谢！