一、首先是先创建一个springboot项目:
1、
2、
3、
4、
5、将这几个圈起来的删除
扫描二维码关注公众号,回复:
4184462 查看本文章
6、接下来在pom中添加rabbitmq的maven依赖
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency>
7、在application配置文件中添加如下代码
8、写一个controller类,生产者代码如下
package com.example.rabbitmqdemo.web; import com.example.rabbitmqdemo.entity.User; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; /** * 用于测试的控制类 * Created by yanggm */ @RestController public class SendMessageController { @Autowired private RabbitTemplate rabbitTemplate; /** * http://localhost:8080/send?message=hello * * @param message * @return */ @RequestMapping("/send") public String sendMQ(String message) { rabbitTemplate.convertAndSend("my-queue",message); return "OK!Message send success!"; }
}
9、消费者端代码如下
package com.example.rabbitmqdemo.consumer; import com.example.rabbitmqdemo.entity.User; import com.rabbitmq.client.Channel; import org.springframework.amqp.core.Message; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; import java.io.IOException; /** * Created by yanggm */ @Component public class ReceiveDirect { @RabbitListener(queues = "my-queue") public void receiveMessage(Message message){
String messageRec = new String(message.getBody()); System.out.println("接收到的字符串消息是 => " + messageRec);}
}
10、MqConfig配置类代码如下
package com.example.rabbitmqdemo.config; import org.springframework.amqp.core.*; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; /** * 特别说明:如果在配置文件中声明了 Queue 对象,就不用在控制台创建队列了 * Created by yanggm */ @Configuration public class MqConfig { /** * 声明接收字符串的队列 * * @return */ @Bean public Queue stringQueue() { return new Queue("my-queue"); }
}
11、这样代码就写完了,还要将rabbitmq服务器的5672端口向外开放,然后开始启动项目,并在浏览器访问如下网址
http://localhost:8080/send?message=hello
这样生产者就向rabbitmq服务器中的队列推送了一条消息,消费者也会监听并消费到这条消息后在控制台上打印出相应信息
注意:试验过程中可能会遇到依赖版本不对报错的问题,以下版本是不会报错的,其他版本的不知道:
<parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.5.10.RELEASE</version> <relativePath/> <!-- lookup parent from repository --> </parent>