springboot整合rabbitmq发送消息
构建项目
image.png
- 构建gradle
repositories {
mavenCentral()
}
ext{
springBootVersion = "2.0.3.RELEASE"
}
dependencies {
compile("org.springframework.boot:spring-boot-starter-amqp:1.5.2.RELEASE")
compile("org.springframework.boot:spring-boot-starter-web:$springBootVersion")
compile("org.springframework.boot:spring-boot-starter-undertow:$springBootVersion")
}
//排除tomcat
configurations {
compile.exclude module: 'spring-boot-starter-tomcat'
}
-
手动创建queues
image.png 生产者
@Component
public class DemoProducer {
@Autowired
private AmqpTemplate rabbitTemplate;
public void send() {
String sendMsg = "msg " + new Date();
System.out.println("生产者开始生产信息 : " + sendMsg);
this.rabbitTemplate.convertAndSend("msg", sendMsg);
}
}
- 消费者
@Component
@RabbitListener(queues = "msg")
public class DemoReceiver {
@RabbitHandler
public void process(String msg) {
System.out.println("消费者 收到信息 : " + msg);
}
}
- 测试controller
@Controller
@RequestMapping("/rabbit")
public class DemoController {
@Autowired
private DemoProducer demoProducer;
@RequestMapping("/hello")
@ResponseBody
public String hello(HttpServletRequest request) {
demoProducer.send();
return "success";
}
}
- yml配置
spring:
rabbitmq:
host: ######
port: ######
username: ######
password: ######
virtual-host: /
server:
port: 9000
