RabbitMQ使用规范「建议收藏」

RabbitMQ使用规范「建议收藏」RabbitMQ使用规范命名exchange:{模块名}.{功能名}queue:{word}.{word}routingkey:{word}.{word},例:merge.request,原因:.之间的会被认为是一个单词,便于通过*和#来匹配一个或多个单词序列化默认情况下RabbitMQ发送的消息是为字节码,我们采用统一的JSON格式的消息使用MessageConvert自动转换为JSON如果规定了消息的格式为JSON,并使用消息转换器,则会自动将消息转化为JSON格式而不需要每次

大家好,又见面了,我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

RabbitMQ使用规范

命名

  1. exchange:{模块名}.{功能名}
  2. queue:{word}.{word}
  3. routing key:{word}.{word},例:merge.request,原因:.之间的会被认为是一个单词,便于通过*和#来匹配一个或多个单词

序列化

默认情况下RabbitMQ发送的消息是为字节码,我们采用统一的JSON格式的消息

使用MessageConvert自动转换为JSON

如果规定了消息的格式为JSON,并使用消息转换器,则会自动将消息转化为JSON格式而不需要每次手动进行转换。RabbitTemplate默认使用SimpleMessageConverter作为自己的消息转化器,而SimpleMessageConverter并不能满足JSON消息的需求。我们可以使用Jackson2JsonMessageConverter作为默认的消息转换器。

特别注意:

  • 生产者和消费者需要使用相同的MessageConvert,消息类型可通过header中的content-type来确认

  • 对于String类型的消息,SimpleMessageConverterJackson2JsonMessageConverter的处理策略是不一样的,具体提现为:

    • content-type:分别是text/plainapplication/json

    • Jackson2JsonMessageConverter会多出两个双引号" "从而导致字符串大变样,示例如下:

      生产者代码

      String context = "hello \"rabbitMQ\" ";
      rabbitTemplate.convertAndSend("hello", context);
      

      当使用SimpleMessageConverter时,rabbitMQ队列中的消息:hello "rabbitMQ"

      当使用Jackson2JsonMessageConverter时,rabbitMQ队列中的消息:"hello \"rabbitMQ\" "

  • 如果想要在发送消息时自定义格式,请使用send而不是conertAndSend方法,接收方也请使用receive而不是receiveAndConvert

为RabbitTemplate配置MessageConverter:

@Configuration
public class RabbitConfig { 
   

    @Bean
    public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) { 
   
        final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
        rabbitTemplate.setMessageConverter(jsonMessageConverter());
        return rabbitTemplate;
    }

    @Bean
    public Jackson2JsonMessageConverter jsonMessageConverter() { 
   
        return new Jackson2JsonMessageConverter();
    }
}

配置优化

生产者消息确认机制

spring:
	rabbitmq:
		#确认消息已发送到交换机(Exchange)
		publisher-confirms: true
		#确认消息已发送到队列(Queue)
		publisher-returns: true
@Slf4j
@Configuration
public class RabbitConfig { 

@Bean
public RabbitTemplate rabbitTemplate(ConnectionFactory connectionFactory) { 

final RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
rabbitTemplate.setMessageConverter(jsonMessageConverter());
// 开启交换机确认
rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() { 

@Override
public void confirm(CorrelationData correlationData, boolean ack, String cause) { 

log.info("=======ConfirmCallback=========");
log.info("correlationData = " + correlationData);
log.info("ack = " + ack);
log.info("cause = " + cause);
log.info("=======ConfirmCallback=========");
}
});
// 开启队列失败确认
rabbitTemplate.setReturnCallback(new RabbitTemplate.ReturnCallback() { 

@Override
public void returnedMessage(Message message, int replyCode, String replyText, String exchange, String routingKey) { 

log.info("--------------ReturnCallback----------------");
log.info("message = " + message);
log.info("replyCode = " + replyCode);
log.info("replyText = " + replyText);
log.info("exchange = " + exchange);
log.info("routingKey = " + routingKey);
log.info("--------------ReturnCallback----------------");
}
});
return rabbitTemplate;
}
}

本地重试确认机制

spring:  
rabbitmq:
listener:
simple:
retry:
# 开启本地重试机制,默认3次,避免内存泄漏
enabled: true
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/186246.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)


相关推荐

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号