Spring Cloud消息驱动整合

  • 时间:
  • 浏览:2
  • 来源:5分排列5_5分排列3

@ServiceActivator

@StreamListener

@Output

MessgeChannel

配置kafka以及Stream Destination

激活用户消息接口

整合kafka

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

User 模型实现序列化接口

用户消息Stream接口定义

近义词:Producer、Publisher

Sink:Stream接收器

近义词:Consumer、Subscriber

Processor

编程模型

激活:- @EnableBinding

利用kafkaTemplate实现消息发送

@StreamListener 实现

配置发送源管道

换成用户消息接口

实现消息发送到 RabbitMQ

换成 User 消息监听器

SubscribableChannel 实现

ServiceActivator 实现

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

统一抽象

编程模型

Sink

启动 Rabbit MQ

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

替换依赖

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

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

增加kafka依赖

引入 spring-cloud-stream-binder-kafka

2.Binder抽象

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

4.消费分组支持

5.分区支持