当前位置: 首页 > news >正文

好网站你知道的凡科网站登录入口

好网站你知道的,凡科网站登录入口,360建站abc,黔东南网站开发gzklyy消息队列概念&#xff1a;是在消息的传输过程中保存消息的容器。 作用&#xff1a;异步处理、应用解耦、流量控制..... RabbitMQ&#xff1a; SpringBoot继承RabbitMQ步骤&#xff1a; 1.加入依赖 <dependency><groupId>org.springframework.boot</groupId&g…

消息队列概念:是在消息的传输过程中保存消息的容器。

作用:异步处理、应用解耦、流量控制.....

RabbitMQ:

 

 

SpringBoot继承RabbitMQ步骤:

        1.加入依赖

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

         2.配置

spring:rabbitmq:host: 192.168.127.129virtual-host: /  # 指定虚拟主机port: 5672

        3.开启(如果不需要监听消息也就是不消费就不需要该注解开启)

@EnableRabbit

        4.创建队列、交换机、以及绑定它们之间的关系

   

@Configuration
public class MyMQConfig {/*** 创建队列* @return*/@Beanpublic Queue createQueue(){//String name, boolean durable, boolean exclusive, boolean autoDelete, @Nullable Map<String, Object> argumentsQueue queue = new Queue("order.queue",true,false,false);return queue;}/*** 创建交换机* @return*/@Beanpublic Exchange createExchange(){//因为这个交换机需要根据路由进行发送  所以使用TopicExchange//String name, boolean durable, boolean autoDelete, Map<String, Object> argumentsTopicExchange topicExchange = new TopicExchange("order-event-exchange",true,false);return  topicExchange;}/*** 通过路由绑定交换机和队列之间的关系* @return*/@Beanpublic Binding createBinding(){//String destination, Binding.DestinationType destinationType, String exchange, String routingKey, @Nullable Map<String, Object> argumentsBinding binding = new Binding("order.queue",Binding.DestinationType.QUEUE,"order-event-exchange","order.route",null);return binding;}}

        4.发送消息

    @AutowiredRabbitTemplate rabbitTemplate;@ResponseBody@GetMapping("/sendmq")public String sendmq(){OrderEntity orderEntity = new OrderEntity();orderEntity.setOrderSn(UUID.randomUUID().toString());//发送消息  String exchange, String routingKey, Object message, MessagePostProcessor messagePostProcessor, @Nullable CorrelationData correlationDatarabbitTemplate.convertAndSend("order-event-exchange","order.route",orderEntity);return "ok";}

        5.消费消息(监听消息)

@Component
@RabbitListener(queues = "create.queue")
public class OrderCloseListener {@RabbitHandlerpublic void orderClose(OrderEntity orderEntity, Message message, Channel channel) throws IOException {System.out.println("消费消息");}
}

问题1:以上消息发送和消费中,如果传输的数据是java对象,默认使用的jdk序列化机制,我们经常需要使用json传递就需要修改传输格式json

修改方法如下:

@Configuration
public class RabbitConfig {//发送消息为对象的时候  使用json的格式@Beanpublic MessageConverter messageConverter(){return new Jackson2JsonMessageConverter();}}

问题2:在消息的发送和消费还有消息储存过程中,我们需要保证消息的可靠性,避免消息的丢失保证业务数据的正确

        1.消息储存:使用持久化

        1.消息发送:开启消息投靠确认机制

spring:rabbitmq:host: 192.168.127.129virtual-host: /  # 指定虚拟主机port: 5672
#    publisher-confirms: truepublisher-confirm-type: simple # 开启生产者消息确认模式publisher-returns: true
@Configuration
public class RabbitConfig {@AutowiredRabbitTemplate rabbitTemplate;/*** 定制rabbitTemplate* 消息发送确认*/@PostConstruct //表示RabbitConfig对象创建之后执行该方法public void initRabbitTemplate(){//消息成功发送到服务器之后的成功回调rabbitTemplate.setConfirmCallback(new RabbitTemplate.ConfirmCallback() {/**** @param correlationData  消息的唯一id* @param b  消息是否成功* @param s  消息失败的原因*/@Overridepublic void confirm(CorrelationData correlationData, boolean b, String s) {System.out.println("confirm===correlationData:"+ correlationData+ "ack:"+ b);}});//消息发送到队列queue失败执行的回调rabbitTemplate.setReturnCallback(new RabbitTemplate.ReturnCallback() {/**** @param message  消息的内容* @param i    回复的状态码* @param s     回复的文本内容* @param s1    那个交换机* @param s2    那个路由key**              最常见的就是路由key不对*/@Overridepublic void returnedMessage(Message message, int i, String s, String s1, String s2) {System.out.println("fail====>message:"+ message+"状态码:"+i + "错误提示:"+ s+ "交换机:"+s1 + "路由:"+ s2);}});}
}

异常操作之后可以达到消息发送端确认机制

        3.消息消费端的确认机制

spring:rabbitmq:host: 192.168.127.129virtual-host: /  # 指定虚拟主机port: 5672
#    publisher-confirms: truepublisher-confirm-type: simple # 开启生产者消息确认模式publisher-returns: truetemplate:mandatory: truelistener:simple:acknowledge-mode: manual # 开启消费者 手动签收消息功能
@Service
@RabbitListener(queues = "create.queue")
public class OrderCloseListener {@RabbitHandlerpublic void orderClose(OrderEntity orderEntity, Message message, Channel channel) throws IOException {System.out.println("消费消息。。。.");try{//业务逻辑//手动确认消息消费成功,消息不在写人队列channel.basicAck(message.getMessageProperties().getDeliveryTag(),false);}catch (Exception e){//消息消费失败(业务失败),将消息在次写到队列避免消息丢失channel.basicReject(message.getMessageProperties().getDeliveryTag(),true);}}
}

通过以上消息的发送和消费端都确认之后我们消息一定的是可靠的。

案例:

        在实际的开发中我们经常会有取消订单的功能,就可以使用消息队列延迟消费消息,具体实现通过个死信队列,把消息先放到死信队列,当消息到期之后转到到期队列,监听到期队列然后达到订单取消功能

http://www.ritt.cn/news/16293.html

相关文章:

  • 如何设计好酒店网站模板百度收录排名查询
  • 做婚礼请柬的网站有哪些西安全网优化
  • 做企业网站好的网络营销好不好
  • 漯河优惠网站建设价格有哪些平台可以发布推广信息
  • 营销网站怎么做百度搜索关键词排名查询
  • 邯郸网站制作哪里做手机百度搜索引擎入口
  • 免费网站在哪里申请外链代发公司
  • 佛山新网站建设如何福建优化seo
  • 东圃做网站的公司营销和运营的区别是什么
  • 山东网站建站建设每天三分钟新闻天下事
  • 中央经济工作会议2020惠州优化怎么做seo
  • 胶州网站建设哪里有免费广告推广平台
  • 农村电商平台发展现状如何提高网站seo排名
  • 中国电商建站程序关键词汇总
  • 网站模板下载 网盘百度医生在线问诊
  • 商务网站建设与管理网站推广做什么
  • 做图网站有哪些化妆品推广软文
  • 张家界简单的网站建设百度竞价点击软件奔奔
  • wordpress翻译过时了seo咨询岳阳
  • 聊城网站建设哪个好些武汉网站推广优化
  • 选择佛山网站设计网络营销ppt课件
  • wordpress悬浮搜索框北仑seo排名优化技术
  • 做微信扫码网站旅游推广赚佣金哪个平台好
  • Wordpress加720云vr南宁seo公司哪家好
  • wordpress添加快速链接武汉seo网站优化排名
  • 网站开发发布seo优化sem推广
  • 美区国区家庭共享网络优化包括
  • app制作程序长沙网络优化产品
  • 企业营销网站建设规划nba赛程排名
  • 网站建设几种语言对比搜狗搜图