首页>代码>Spring Boot整合RabbitMQ发送点对点消息项目demo>/micai-springboot-rabbitmq-7/src/main/java/com/micai/springboot/mq/Sender.java
package com.micai.springboot.mq; import org.springframework.amqp.core.AmqpTemplate; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import java.util.Date; /** * 描述:消息生产者 * <p> * Author: 赵新国 * Date: 2017/11/3 15:37 */ @Component public class Sender extends BaseConfig{ @Autowired private AmqpTemplate rabbitTemplate; public void send(int i) { // 在该生产者,我们会产生一个字符串,并发送到名为hello的队列中 String context = "Hello " + "Rabbit MQ!" + i; System.out.println("发送MQ消息 : " + context); this.rabbitTemplate.convertAndSend(QUEUE_KEY, context); } }