本文共 2021 字，大约阅读时间需要 6 分钟。

工作中的使用：

编辑消息发送配置文件

spring/applicationContext-rabbitmq-send.xml

配置消息接收配置文件

spring/applicationContext-rabbitmq-receive.xml

定义消息发送

@Servicepublic class OrderServiceImpl implements DubboOrderService {		@Autowired	private OrderMapper orderMapper;		@Autowired	private OrderItemMapper orderItemMapper;		@Autowired	private OrderShippingMapper orderShippingMapper;	@Autowired	private RabbitTemplate rabbitTemplate;	/**	 * 1.将order对象通过rabbitMQ实现数据的传递	 * 2.需要返回orderId	 */	@Override	public String saveOrder(Order order) {		String orderId = order.getUserId() + "" + System.currentTimeMillis();		order.setOrderId(orderId);		String  routingKey = "save.order";		//表示消息的发送		rabbitTemplate.convertAndSend(routingKey,order);		System.out.println("订单消息发送完成");		return orderId;	}

定义消息的接收

public class RabbitMQOrderService {	@Autowired	private OrderMapper orderMapper;		@Autowired	private OrderItemMapper orderItemMapper;		@Autowired	private OrderShippingMapper orderShippingMapper;		public void saveOrder(Order order) {		String orderId = order.getOrderId();		//实现订单的入库操作		order.setOrderId(orderId);		order.setStatus(1);		order.setCreated(new Date());		order.setUpdated(order.getCreated());		orderMapper.insert(order);		System.out.println("订单入库成功!!");				//实现订单物流信息入库		OrderShipping orderShipping = order.getOrderShipping();		orderShipping.setOrderId(orderId);		orderShipping.setCreated(order.getCreated());		orderShipping.setUpdated(order.getCreated());		orderShippingMapper.insert(orderShipping);		System.out.println("订单物流信息入库成功!!!");				//实现订单商品入库		List
   
     orderItems = order.getOrderItems();		for (OrderItem orderItem : orderItems) {			orderItem.setOrderId(orderId);			orderItem.setCreated(order.getCreated());			orderItem.setUpdated(order.getCreated());			orderItemMapper.insert(orderItem);		}				System.out.println("消息队列执行成功!!!!!!");	}}
   

转载地址：http://zjijn.baihongyu.com/