项目用到rqueue，虽然知道和redis相关，但是肯定有不一样的地方，做个笔记。

maven依赖

网上找个能用的版本就行，如：

<dependency><groupId>com.github.sonus21</groupId><artifactId>rqueue-spring-boot-starter</artifactId><version>2.13.2-RELEASE</version>
</dependency>

引入监听器

属于配置类，可以考虑和StartupApplication同目录。

@Component
public class MessageSender implements ApplicationListener<RqueueBootstrapEvent> {@Autowiredprivate RqueueEndpointManager rqueueEndpointManager;@Overridepublic void onApplicationEvent(RqueueBootstrapEvent event) {if (!event.isStartup()) {return;}String[] a = new String[]{"ARCHIVES-CHECK-QUEUE","ARCHIVES-CONVERSION-QUEUE"};for (String queue : a) {String[] priorities = getPriority(queue);if (!rqueueEndpointManager.isQueueRegistered(queue)) {rqueueEndpointManager.registerQueue(queue, priorities);}}}private String[] getPriority(String queue) {
//        return new String[]{"high", "medium", "low"};return new String[]{};}
}

注入和发送消息

接收消息

属性配置