做暧视频免费网站,企业形象设计logo,wordpress 工单,做网站挣外快背景
主要解决不同消息中间件切换问题。实现不同中间件的代码解耦。 链接: 支持的中间件 后文使用kafka测试。
引入依赖 dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-stream/artifactId/depende…背景
主要解决不同消息中间件切换问题。实现不同中间件的代码解耦。 链接: 支持的中间件 后文使用kafka测试。
引入依赖 dependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-stream/artifactId/dependencydependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-starter-stream-kafka/artifactId/dependencydependencyManagementdependenciesdependencygroupIdorg.springframework.cloud/groupIdartifactIdspring-cloud-dependencies/artifactIdversion2021.0.3/versiontypepom/typescopeimport/scope/dependency/dependencies/dependencyManagement编写配置文件
配置文件
参考说明
spring:application:name: streamDemocloud:function:definition: streamDemostream:bindings:streamDemo-out-0:destination: streamDemogroup: ${spring.application.name}streamDemo-in-0:destination: streamDemogroup: ${spring.application.name}kafka:binder:auto-create-topics: truereplication-factor: 1brokers: kafkaServer:9092生产者代码
Service
Slf4j
public class MiddleMessageProducer {private static final String pvRecordChannel streamDemo-out-0;Resourceprivate StreamBridge streamBridge;public void saveLogInfo(String msg) {streamBridge.send( pvRecordChannel, MessageBuilder.withPayload(msg).build());}}消费者代码
Slf4j
Component
public class MessageConsumer{Beanpublic ConsumerString streamDemo() {return request - {log.info(收到消息{},request);};}
}验证
