springboot整合rabbitmq發(fā)送消息

構(gòu)建項(xiàng)目

image.png

• 構(gòu)建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'
}

• 手動(dòng)創(chuàng)建queues

  
  
  image.png

• 生產(chǎn)者

@Component
public class DemoProducer {

    @Autowired
    private AmqpTemplate rabbitTemplate;

    public void send() {
        String sendMsg = "msg " + new Date();
        System.out.println("生產(chǎn)者開始生產(chǎn)信息 : " + sendMsg);
        this.rabbitTemplate.convertAndSend("msg", sendMsg);
    }
}

• 消費(fèi)者

@Component
@RabbitListener(queues = "msg")
public class DemoReceiver {

   @RabbitHandler
   public void process(String msg) {
       System.out.println("消費(fèi)者 收到信息  : " + msg);
   }
}

• 測(cè)試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