淘宝做基础销量网站,凉山州建设网站,北京企业官网建设,网站备案授权一、安装Erlang与Rabbitmq 安装教程本教程是在centos8下试验的#xff0c;其实linux系统的都差不多RabbitMQ官方#xff1a;Messaging that just works — RabbitMQRabbitMQ是开源AMQP实现#xff0c;服务器端用Erlang语言编写#xff0c;Python、Ruby、 NET、Java、JMS、c…一、安装Erlang与Rabbitmq 安装教程本教程是在centos8下试验的其实linux系统的都差不多RabbitMQ官方Messaging that just works — RabbitMQRabbitMQ是开源AMQP实现服务器端用Erlang语言编写Python、Ruby、 NET、Java、JMS、c、PHP、action screcrive AMQP (高级消息队列协议)和高级消息队列协议是APP应用层协议的开放标准是为面向消息的中间件而设计的。消息中间件主要用于组件之间的解耦其中消息的发送方不需要知道消息使用者的存在反之_rabbitmq安装https://blog.csdn.net/weixin_44545251/article/details/128216395
二、在springboot中使用rabbitmq
1.导入依赖 dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId
/dependency 2.编写配置文件 springrabbitmq:host: localhostport: 5672username: guestpassword: guest 3.配置一个队列
package com.example.Rabbtimq.config;import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;Configuration
public class QueueAndExchangeConfig {Bean(myFirstQueue)public Queue getFirstQueue(){return new Queue(my-first-queue);}
}4.编写一个生产者类
package com.example.Rabbtimq.controller;import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;RestController
RequestMapping(producer)
public class RabbitMqController {Autowiredprivate RabbitTemplate rabbitTemplate;GetMapping(producerSendFirstQueue)public String sendMsg(String msg){rabbitTemplate.convertAndSend(my-first-queue,msg);return msg;}}5.编写一个消费者监听队列中的消息
package com.example.Rabbtimq.controller;import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;Component
public class ConsumerHandler {RabbitListener(queues my-first-queue)public void getFirstQueue(String msg){System.out.println(消费者1msg);}
}6.使用接口工具调生产接口 7.查看图形化界面
