spring boot 2.6.3快速集成RabbitMq 踩坑点（Win10）

在win10系统安装RabbitMq是需要erlang环境的，选择安装目录一直下一步就行了

链接: https://pan.baidu.com/s/1qM5N7bqOwoIg0ckw4vtzuA
提取码: fc8h

安装完成之后可以看到如下信息，然后启动服务访问 http://localhost:15672 便可看到可视化控制台，默认账号密码都是 guest

依赖

  
   	  org.springframework.boot
      spring-boot-starter-amqp
  
  
    com.fasterxml.jackson.datatype
       jackson-datatype-jsr310
  
  
       com.fasterxml.jackson.core
       jackson-core
   
   
       com.fasterxml.jackson.core
       jackson-annotations
   
   
       com.fasterxml.jackson.core
       jackson-databind
  

yaml配置

spring:
  rabbitmq:
    host: localhost
    port: 5672
    publisher-returns: true 
    publisher-/confirm/i-type: correlated #确认机制类型
    #publisher-/confirm/is: true 		  改用上面配置
    listener:
      simple:
        acknowledge-mode: manual #ack为手动应答方式
        retry:
          max-attempts: 3 #重试最大次数
          enabled: true   #开启重试

不要忘记在Spring boot上面加上 @EnableRabbit 注解

@Configuration
public class RabbitConfiguration  {

    
    @Bean
    public MessageConverter getMessageConverter(Jackson2ObjectMapperBuilder builder) {
        ObjectMapper objectMapper = builder.createXmlMapper(false).build();
        objectMapper.configure(SerializationFeature.WRITE_DATES_AS_TIMESTAMPS, true);
        return new Jackson2JsonMessageConverter(objectMapper);
    }

    

	//此处不配置Rabbit callBack回调是因为会出现循环依赖问题
}

@Component
public class RabbitCallbackConfiguration {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    
    @PostConstruct
    public void initRabbitTemplate() {
        rabbitTemplate.set/confirm/iCallback(new RabbitTemplate./confirm/iCallback() {

            
            @Override
            public void /confirm/i(CorrelationData correlationData, boolean ack, String cause) {
                
                if (!ack) {
                    System.out.println("correlationData【" + correlationData + "】===>ack【" + ack + "】===>cause【" + cause + "】");
                }
            }
        });

        rabbitTemplate.setReturnCallback(new RabbitTemplate.ReturnCallback() {

            
            @Override
            public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) {
                System.out.println("message【" + message + "】===>replyCode【" + replyCode + "】===>replyText【" + replyText + "】===》exchange【" + exchange + "】===》routingKey【" + routingKey + "】");
            }
        });
    }
}

@Autowired
private RabbitTemplate rabbitTemplate;

public void sendUserAccountData() {
        //交换机 - routingKey - 消息
      rabbitTemplate.convertAndSend("sourceUserDataExchange", "userKey", "hello Wold");
}

@Component
public class SourceUserAccountDataListener {

    @RabbitListener(queues = "队列")
    public void userAccountListener(JssdmallUserAccount jssdmallUserAccount, Channel channel, Message message) {
        try {
            //相关业务处理

			//手动Ack应答处理
            channel.basicAck(message.getMessageProperties().getDeliveryTag(), false);
        } catch (Exception e) {
            try {
                //手动Ack应答处理，重新回队列
                channel.basicReject(message.getMessageProperties().getDeliveryTag(), true);
            } catch (IOException ioException) {
                ioException.printStackTrace();
            }
        }
    }
}

关于Spring boot 2.6.3集成 RabbitMq 消息转换器配置和发送端回调处理踩坑点以上解决思路。