RadioMQ 下行优化
2023-03-06 20:20:23 77 举报RadioMQ 下行优化
作者其他创作
大纲/内容
LocalBrokerInstance
+ register(group): Flux<MessageRecord>
MessagePushService
- executor: ExecutorService
+ pushAsync(record): Future<>
RoundRobinRule<T>
- nextCounter: AtomicInteger
BrokerCluster
font color=\"#323232\
+ sendOne(message): boolean+ broadcast(message)+ subscribe(group): Flux<MessageRecord>- unsubscribe(group)+ startup()
TcpClient
- connection: Socket
WebSocketPublisher
+ session: WebSocketSession
LocateService
- redisClient
LoadBalancerClient
+ choose(serviceId): ServiceInstance
Nacos.NamingService
+ getAllInstances(serviceName): List<Instance>
MessageRepository
MessageService
- repo: MessageRepository- cluster: BrokerCluster
+ send(font color=\"#323232\
HttpClient
- delegate: WebClient
Publisher
MessagePushTask
+ record: MessageRecord
+ run()
MessageRecord
+ id: String+ topic: String+ groups: List<String>+ content: String+ creationTime: Long
RemoteClient
+ send(record)
ReactorPublisher
+ sink: FluxSink
BrokerInstance
+ id: String+ send(record)
RemoteBrokerInstance
+ client: RemoteClient
收藏
0 条评论
下一页
