网站建设接单技巧,广东网站设计有名的公司,快对小程序入口,佛山有那些定制网站建设公司1.RabbitMQ消息的消费端服务
RabbitMQ懒加载模式#xff0c; 需要配置消费者监听才会创建 RabbitListener(queues test.queue)另外一种方式(若Mq中无相应名称的队列,会自动创建Queue),改为如下 RabbitListener(queuesToDeclare { Queue(value test.queu…1.RabbitMQ消息的消费端服务
RabbitMQ懒加载模式 需要配置消费者监听才会创建 RabbitListener(queues test.queue)
另外一种方式(若Mq中无相应名称的队列,会自动创建Queue),改为如下 RabbitListener(queuesToDeclare { Queue(value test.queue,durable true, autoDelete false) })
2.RabbitMQ消息的生产端服务 Beanpublic RabbitAdmin rabbitAdmin(ConnectionFactory defaultConnectionFactory){return new RabbitAdmin(defaultConnectionFactory);}使用rabbitAdmin.declareQueue方法 Beanpublic Queue queueGps() {// durable:是否持久化,默认是false,持久化队列会被存储在磁盘上当消息代理重启时仍然存在暂存队列当前连接有效// exclusive:默认也是false只能被当前创建的连接使用而且当连接关闭后队列即被删除。此参考优先级高于durable// autoDelete:是否自动删除当没有生产者或者消费者使用此队列该队列会自动删除。//一般设置一下队列的持久化就好,其余两个就是默认falseQueue queue new Queue( test.queue, true);rabbitAdmin.declareQueue(queue);return queue;}
