springboot 内部消息
时间: 2023-11-25 20:52:23 浏览: 31
Spring Boot提供了多种内部消息的实现方式,其中一种常用的方式是使用Disruptor做消息队列。Disruptor是一个高性能的无锁内存队列,可以用于异步处理消息。下面是一个使用Disruptor做消息队列的测试类及方法的例子:
```java
@Slf4j
@RunWith(SpringRunner.class)
@SpringBootTest(classes=DemoApplication.class)
public class DemoApplicationTests {
@Autowired
private DisruptorMqService disruptorMqService;
/**
* 项目内部使用Disruptor做消息队列
* @throws Exception
*/
@Test
public void sayHelloMqTest() throws Exception {
disruptorMqService.sayHelloMq("消息到了,Helloworld!");
log.info("消息队列已发送完毕");
//这里停止2000ms是为了确定是处理消息是异步的
Thread.sleep(2000);
}
}
```
另外,为了方便传递消息,可以定义一个消息体Model,如下所示:
```java
/**
* 消息体
*/
@Data
public class MessageModel {
private String message;
}
```