SpringBoot RabbitMQ

pom.xml

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

Sender

/**
 * 消息发送者
 */
@Component
public class Sender {

    @Autowired
    private AmqpTemplate rabbitAmqpTemplate;

    /**
     * 发送消息方法
     */
    public void send(String msg) {
        //向消息队列中发送消息
        //参数一: 队列名称
        //参数二: 消息
        this.rabbitAmqpTemplate.convertAndSend("hello-queue", msg);
    }
}

Receiver

HelloController
import com.swifter.Sender;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class HelloController {

    @Autowired
    private Sender sender;

    @RequestMapping("quick")
    public String quick() {
        sender.send("hello world");
        return "Hello world!";
    }
}

--EOF--