Spring Cloud消息驱动整合

  • 时间:
  • 浏览:2
  • 来源:uu直播快3_UU快3直播平台

近义词:Producer、Publisher

Sink:Stream接收器

近义词:Consumer、Subscriber

Processor

@ServiceActivator

@StreamListener

启动 Rabbit MQ

改造 user-service-provider 消息接收器( Stream Binder : Rabbit MQ)

替换依赖

@StreamListener 实现

激活用户消息接口

实现消息发送到 RabbitMQ

编程模型

Sink

整合kafka

改造 user-service-client 消息发送源(Kafka 原生 API)

User 模型实现序列化接口

改造 user-service-client 消息发送源( Stream Binder : Rabbit MQ)

增加 spring-cloud-stream-binder-rabbitmq 依赖

引入 spring-cloud-stream-binder-kafka

统一抽象

编程模型

激活:- @EnableBinding

ServiceActivator 实现

利用kafkaTemplate实现消息发送

2.Binder抽象

3.持久化 发布/订阅支持

4.消费分组支持

5.分区支持

用户消息Stream接口定义

配置发送源管道

再加用户消息接口

再加 User 消息监听器

SubscribableChannel 实现

增加kafka依赖

配置kafka以及Stream Destination

实现kafka序列化器:Java序列化协议

@Output

MessgeChannel