并夕夕商城整合 rabbitmq

妖狐艹你老母 2022-11-26 15:59 242阅读 0赞

> 需要资料私信小编邮箱：`daniel-work@qq.com`

![在这里插入图片描述][20200812155745364.gif_pic_center]

--------------------

### 文章目录 ###

*  商城整合 rabbitmq
 *   *  前提：导入数据库(pb-store)、导入项目(pd-web)
     *  1.1 订单存储的解耦
     *  1.2 生产者-发送订单
     *   *  1.2.1 pom.xml 添加依赖
         *  1.2.2 application.yml
         *  1.2.3 修改主程序 RunPdAPP
         *  1.2.4 修改 OrderServiceImpl
     *  1.3 消费者-接收订单,并保存到数据库
     *   *  1.3.1 项目复制
         *  1.3.2 删除无关代码
         *  1.3.3 新建OrderConsumer
         *  1.3.4 修改 OrderServiceImpl 的 saveOrder() 方法
     *  1.4 手动确认（了解）
     *   *  1.4.1 application.yml
         *  1.4.2 OrderConsumer

--------------------

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center]

# 商城整合 rabbitmq #

当用户下订单时,我们的业务系统直接与数据库通信,把订单保存到数据库中

当系统流量突然激增,大量的订单压力,会拖慢业务系统和数据库系统

我们需要应对流量峰值,让流量曲线变得平缓,如下图

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 1]

## 前提：导入数据库(pb-store)、导入项目(pd-web) ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 2]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 3]

> 1、pom文件，驱动版本1.5.4  
> 2、yml文件，serverTimezone=GMT%2B8  
> 3、MySQL的用户名和密码
> 
> --------------------
> 
> 4、**如果项目启动之后访问不了，要添加下面所示的语句**  
> ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 4]  
> 访问地址：localhost：80

## 1.1 订单存储的解耦 ##

为了进行流量削峰,我们引入 rabbitmq 消息队列, 当购物系统产生订单后,可以把订单数据发送到消息队列;而订单消费者应用从消息队列接收订单消息,并把订单保存到数据库

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 5]  
这样,当流量激增时,大量订单会暂存在rabbitmq中,而订单消费者可以从容地从消息队列慢慢接收订单,向数据库保存

## 1.2 生产者-发送订单 ##

### 1.2.1 pom.xml 添加依赖 ###

spring提供了更方便的消息队列访问接口,它对RabbitMQ的客户端API进行了封装,使用起来更加方便

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

### 1.2.2 application.yml ###

添加RabbitMQ的连接信息

spring:
      rabbitmq:
          host: 192.168.126.129
          port: 5672
          virtualHost: /pd
          username: admin
          password: admin

### 1.2.3 修改主程序 RunPdAPP ###

在主程序中添加下面的方法创建Queue实例

当创建RabbitMQ连接和信道后,Spring的RabbitMQ工具会自动在服务器中创建队列,代码在`RabbitAdmin.declareQueues()`方法中

import org.springframework.amqp.core.Queue;
    /** * spring提供的Queue实例，只用来封装队列信息 * RabbitAutoConfiguration 自动配置类，会自动发现spring的queue实例 * 根据封装的队列信息，去连接rabbitmq服务器，定义队列 * @return */
    @Bean
    public Queue getQueue(){ 
    	Queue queue = new Queue("orderQueue",true);
    	return queue;
    }

### 1.2.4 修改 OrderServiceImpl ###

/** * AmqpTemplate发送消息的工具对象，封装消息发送操作代码 * RabbitAutoConfiguration自动配置类中，创建了这个实例 */
    	@Autowired
    	private AmqpTemplate amqpTemplate;
    
    	public String saveOrder(PdOrder pdOrder) throws Exception { 
    		String orderId = generateId();
    		pdOrder.setOrderId(orderId);
    		/* 转换并发送 转换是将订单对象，转换成byte[]数组再发送； */
    		amqpTemplate.convertAndSend("orderQueue",pdOrder);
    
    	// PdShipping pdShipping = pdShippingMapper.selectByPrimaryKey(pdOrder.getAddId());
    	// pdOrder.setShippingName(pdShipping.getReceiverName());
    	// pdOrder.setShippingCode(pdShipping.getReceiverAddress());
    	// pdOrder.setStatus(1);//
    	// pdOrder.setPaymentType(1);
    	// pdOrder.setPostFee(10D);
    	// pdOrder.setCreateTime(new Date());
    	//
    	// double payment = 0;
    	// List<ItemVO> itemVOs = selectCartItemByUseridAndItemIds(pdOrder.getUserId(), pdOrder.getItemIdList());
    	// for (ItemVO itemVO : itemVOs) { 
    	// PdOrderItem pdOrderItem = new PdOrderItem();
    	// String id = generateId();
    	// //String id="2";
    	// pdOrderItem.setId(id);
    	// pdOrderItem.setOrderId(orderId);
    	// pdOrderItem.setItemId("" + itemVO.getPdItem().getId());
    	// pdOrderItem.setTitle(itemVO.getPdItem().getTitle());
    	// pdOrderItem.setPrice(itemVO.getPdItem().getPrice());
    	// pdOrderItem.setNum(itemVO.getPdCartItem().getNum());
    	//
    	// payment = payment + itemVO.getPdCartItem().getNum() * itemVO.getPdItem().getPrice();
    	// pdOrderItemMapper.insert(pdOrderItem);
    	// }
    	// //保存订单
    	// pdOrder.setPayment(payment);
    	// pdOrderMapper.insert(pdOrder);
    		return orderId;
    	}

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 6]

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 7]

## 1.3 消费者-接收订单,并保存到数据库 ##

### 1.3.1 项目复制 ###

`pd-web`项目复制为`pd-order-consumer`，导入项目

修改 `application.yml`，把端口修改成 81

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 8]

### 1.3.2 删除无关代码 ###

pd-order-consumer项目只需要从 RabbitMQ 接收订单数据, 再保存到数据库即可, 所以项目中只需要保留这部分代码

*  删除 com.pd.controller 包
 *  删除 com.pd.payment.utils 包
 *  删除无关的 Service,只保留 OrderService 和 OrderServiceImpl

### 1.3.3 新建OrderConsumer ###

![在这里插入图片描述][20200812182333549.png_pic_center]

package com.pd;
    
    import com.pd.pojo.PdOrder;
    import com.pd.service.OrderService;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    @Slf4j
    @Component
    public class OrderConsumer { 
        @Autowired
        private OrderService orderService;
    
        //连接rabbitmq，从orderQueue队列接受消息
        //收到的消息自动还原成订单实例，传递到这个方法
        @RabbitListener(queues = "orderQueue")
        public void saveOrder(PdOrder pdOrder) throws Exception { 
            orderService.saveOrder(pdOrder);
            log.info("保存订单完成");
        }
    }

### 1.3.4 修改 OrderServiceImpl 的 saveOrder() 方法 ###

public String saveOrder(PdOrder pdOrder) throws Exception { 
    		//String orderId = generateId();
    		//pdOrder.setOrderId(orderId);
    
    		//从RabbitMQ接收的订单数据,
    		//已经在上游订单业务中生成过id,这里不再重新生成id
    		//直接获取该订单的id，然后执行数据库操作
    		String orderId = pdOrder.getOrderId();
    
    		PdShipping pdShipping = pdShippingMapper.selectByPrimaryKey(pdOrder.getAddId());
    		pdOrder.setShippingName(pdShipping.getReceiverName());
    		pdOrder.setShippingCode(pdShipping.getReceiverAddress());
    		pdOrder.setStatus(1);//
    		pdOrder.setPaymentType(1);
    		pdOrder.setPostFee(10D);
    		pdOrder.setCreateTime(new Date());
    
    		double payment = 0;
    		List<ItemVO> itemVOs = selectCartItemByUseridAndItemIds(pdOrder.getUserId(), pdOrder.getItemIdList());
    		for (ItemVO itemVO : itemVOs) { 
    			PdOrderItem pdOrderItem = new PdOrderItem();
    			String id = generateId();
    			//String id="2";
    			pdOrderItem.setId(id);
    			pdOrderItem.setOrderId(orderId);
    			pdOrderItem.setItemId("" + itemVO.getPdItem().getId());
    			pdOrderItem.setTitle(itemVO.getPdItem().getTitle());
    			pdOrderItem.setPrice(itemVO.getPdItem().getPrice());
    			pdOrderItem.setNum(itemVO.getPdCartItem().getNum());
    
    			payment = payment + itemVO.getPdCartItem().getNum() * itemVO.getPdItem().getPrice();
    			pdOrderItemMapper.insert(pdOrderItem);
    		}
    		//保存订单
    		pdOrder.setPayment(payment);
    		pdOrderMapper.insert(pdOrder);
    		return orderId;
    	}

## 1.4 手动确认（了解） ##

### 1.4.1 application.yml ###

spring:
      rabbitmq:
        listener:
          simple:
            acknowledge-mode: manual

### 1.4.2 OrderConsumer ###

package com.pd;
    
    import org.springframework.amqp.core.Message;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Component;
    
    import com.pd.pojo.PdOrder;
    import com.pd.service.OrderService;
    import com.rabbitmq.client.Channel;
    
    @Component
    public class OrderConsumer { 
        //收到订单数据后,会调用订单的业务代码,把订单保存到数据库
    	@Autowired
    	private OrderService orderService;
    
        //添加该注解后,会从指定的orderQueue接收消息,
        //并把数据转为 PdOrder 实例传递到此方法
    	@RabbitListener(queues="orderQueue")
    	public void save(PdOrder pdOrder, Channel channel, Message message)
    	{ 
    		System.out.println("消费者");
    		System.out.println(pdOrder.toString());
    		try { 
    			orderService.saveOrder(pdOrder);
    			channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
    		} catch (Exception e) { 
    			e.printStackTrace();
    		} 
    	}
    }

[20200812155745364.gif_pic_center]: /images/20221124/0ffdb3921a5d4c738625e35bc0dd957d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center]: /images/20221124/5c567090be2e4cbc8f08db6883532dbe.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 1]: /images/20221124/6b54698a342942a6bae1b3505fc2d18d.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 2]: /images/20221124/5f12cf1cb6114caaa526d46bf6bc9646.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 3]: /images/20221124/848ba217467f4fab93536260c74fdeb4.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 4]: /images/20221124/4dfc1c3641694241904305f68ede731f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 5]: /images/20221124/b373f15e491d45e1b7baaa5ce0b5d17f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 6]: /images/20221124/eac3239b83ba4e28a5b066f61644e075.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 7]: /images/20221124/c01e2582adde44a9b054ec96324fe29f.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxMTgwODgxNDAyNQ_size_16_color_FFFFFF_t_70_pic_center 8]: /images/20221124/a93d311227b9430a84ae12b7231b21b6.png
[20200812182333549.png_pic_center]: /images/20221124/0d028f94c0ef404eb449f988cdd20e9c.png