kafka作用类似于rabbitMQ
一、添加依赖
< dependency>
< groupId>org.springframework.kafka</ groupId>
< artifactId>spring-kafka</ artifactId>
< version>2.2.5.RELEASE</ version>
</ dependency>
二、application.yml的配置
spring:
kafka:
bootstrap-servers: localhost:9092
consumer:
group-id: mygroup//自命名,监听或者发送时用到
三、生产者发送信息
@Autowired
private KafkaTemplate<String, String> kafkaTemplate;
kafkaTemplate.send(“UserMessage”, “mygroup”,”“你好”);
四、注册消费者
@KafkaListener(topics = “UserMessage”,id=“mygroup”)
public void listen(ConsumerRecord<?,String> record) {
String value = record.value(); //value的值是你好
});