show-cloud(十一)添加删除帐套的mq队列

野性酷女 2023-06-20 09:29 70阅读 0赞

第一步：配置队列  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXlvbmdsaWFuZ184MTM_size_16_color_FFFFFF_t_70]  
第二步：确认队列是否创建，登陆到rabbitMq的web管理界面  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXlvbmdsaWFuZ184MTM_size_16_color_FFFFFF_t_70 1]

第三步：对show-cloud-users-service添加相应对依赖

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

第四步：添加mq处理类，也就是队列监听  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXlvbmdsaWFuZ184MTM_size_16_color_FFFFFF_t_70 2]

package org.go.show.users.rabitMqHandler;
    
    import lombok.extern.slf4j.Slf4j;
    import org.go.show.common.constants.LogQueue;
    import org.go.show.users.i.AccountService;
    import org.go.show.users.pojo.Account;
    import org.springframework.amqp.rabbit.annotation.RabbitHandler;
    import org.springframework.amqp.rabbit.annotation.RabbitListener;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Component;
    
    /**
     * 从mq队列消费日志数据
     *
     *
     */
    @Component
    @Slf4j
    public class RabitMqHandler {
    
    
    	@Value("${goshow.log.logServiceBean:logServiceDBImpl}")
    	String logServiceBean;
    
    	@Autowired
    	AccountService accountService;
    
    
    	/**
    	 * 监听帐套删除队列
    	 *
    	 * @param accountId
    	 */
    	@RabbitHandler
    	@RabbitListener(queues = LogQueue.DEL_ACCOUNT_QUEUE) // 监听队列
    	public void delAccountHandler(String accountId) {
    		try {
    			accountService.delAccountRelInfo(accountId);
    		} catch (Exception e) {
    			log.error("删除帐套操作，日志：{}，异常：{}", accountId, e);
    		}
    	}
    }

第五步：实现关联信息的删除操作。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXlvbmdsaWFuZ184MTM_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191209233217548.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXlvbmdsaWFuZ184MTM=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXlvbmdsaWFuZ184MTM_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20191209233340985.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXlvbmdsaWFuZ184MTM=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXlvbmdsaWFuZ184MTM_size_16_color_FFFFFF_t_70 2]: https://img-blog.csdnimg.cn/20191210000321200.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXlvbmdsaWFuZ184MTM=,size_16,color_FFFFFF,t_70