spring整合rabbitmq的实例

package cn.wuwenfu.rabbitmqdemo.publish; import org.springframework.amqp.core.Message; import org.springframework.amqp.core.MessageBuilder; import org.springframework.amqp.core.MessageProperties; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.amqp.rabbit.support.CorrelationData; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import java.util.UUID; @Service("rabbitTemplatePublishService") public class RabbitTemplatePublishService { @Autowired //RabbitTemplate是AmqpTemplate的一个实现 private RabbitTemplate rmqpTemplate; public void send(String exchange, String routingKey, Object obj) { String msgId = UUID.randomUUID().toString(); Message message = MessageBuilder.withBody(obj.toString().getBytes()) .setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN) .setCorrelationIdString(msgId).build(); CorrelationData date = new CorrelationData(msgId); // TODO 将 msgId 与 message 的关系保存起来,例如放到缓存中 rmqpTemplate.send(exchange, routingKey, message, date); } }