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

深圳网站建设公司简介下载优化大师并安装

深圳网站建设公司简介,下载优化大师并安装,网站建设者属于广告经营者吗,网站都有备案号吗死信队列 死信的概念 先从概念解释上搞清楚这个定义,死信,顾名思义就是无法被消费的消息,字面意思可以这样理解,一般来说,producer 将消息投递到 broker 或者直接到queue 里了,consumer 从 queue 取出消息…

死信队列

死信的概念

先从概念解释上搞清楚这个定义,死信,顾名思义就是无法被消费的消息,字面意思可以这样理解,一般来说,producer 将消息投递到 broker 或者直接到queue 里了,consumer 从 queue 取出消息进行消费,但某些时候由于特定的原因导致queue 中的某些消息无法被消费,这样的消息如果没有后续的处理,就变成了死信,有死信自然就有了死信队列.

应用场景:为了保证订单业务的消息数据不丢失,需要使用到 RabbitMQ 的死信队列机制,当消息消费发生异常时,将消息投入死信队列中.还有比如说: 用户在商城下单成功并点击去支付后在指定时间未支付时自动失效

造成死信的原因

  • 消息 TTL 过期
  • 队列达到最大长度(队列满了,无法再添加数据到 MQ 中)
  • 消息被拒绝(basic.reject 或 basic.nack)并且 requeue=false.

死信架构图

在这里插入图片描述

代码实战

  • TTL过期

    package com.vmware.rabbit.demo8;import com.rabbitmq.client.BuiltinExchangeType;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.DeliverCallback;
    import com.vmware.rabbit.utils.RabbitUtil;import java.util.HashMap;public class Consumer {//普通交换机private static final String NORMAL_EXCHANGE = "normal_exchange";//死信交换机private static final String DEAD_EXCHANGE = "dead_exchange";//普通队列private static final String NORMAL_QUEUE = "normal_queue";//死信队列private static final String DEAD_QUEUE = "dead_queue";public static void main(String[] args) throws Exception {Connection connection = RabbitUtil.getConnection();Channel channel = connection.createChannel();//创建普通队列死信分发参数HashMap<String,Object> arguments= new HashMap<>();arguments.put("x-dead-letter-exchange",DEAD_EXCHANGE);arguments.put("x-dead-letter-routing-key","lisi");//创建普通交换机与队列并绑定channel.exchangeDeclare(NORMAL_EXCHANGE, BuiltinExchangeType.DIRECT);channel.queueDeclare(NORMAL_QUEUE,false,false,false,arguments);channel.queueBind(NORMAL_QUEUE,NORMAL_EXCHANGE,"zhangsan");//创建死信交换机和队列并绑定channel.exchangeDeclare(DEAD_EXCHANGE,BuiltinExchangeType.DIRECT);channel.queueDeclare(DEAD_QUEUE,false,false,false,null);channel.queueBind(DEAD_QUEUE,DEAD_EXCHANGE,"lisi");DeliverCallback deliverCallback= (tag,msg)->{String message = new String(msg.getBody());System.out.println("接收到消息:"+message);}};//创建消费者channel.basicConsume(NORMAL_QUEUE,false,deliverCallback,(tag)->{});}
    }
    
    package com.vmware.rabbit.demo8;import com.rabbitmq.client.AMQP;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.vmware.rabbit.utils.RabbitUtil;public class Producer {private static final String EXCHANGE_NAME = "normal_exchange";private static final String ROUTING_KEY = "zhangsan";public static void main(String[] args) throws Exception {Connection connection = RabbitUtil.getConnection();System.out.println("已连接到RabbitMQ服务器....");Channel channel = connection.createChannel();//设置超时为10秒AMQP.BasicProperties basicProperties = new AMQP.BasicProperties().builder().expiration("10000").build();for (int i = 0; i < 10; i++) {String message = "msg" + i;channel.basicPublish(EXCHANGE_NAME, ROUTING_KEY, basicProperties, message.getBytes());System.out.println("消息:"+message+"发送成功!");}}
    }
    
  • 队列达到最大长度

    package com.vmware.rabbit.demo8;import com.rabbitmq.client.BuiltinExchangeType;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.DeliverCallback;
    import com.vmware.rabbit.utils.RabbitUtil;import java.util.HashMap;public class Consumer {//普通交换机private static final String NORMAL_EXCHANGE = "normal_exchange";//死信交换机private static final String DEAD_EXCHANGE = "dead_exchange";//普通队列private static final String NORMAL_QUEUE = "normal_queue";//死信队列private static final String DEAD_QUEUE = "dead_queue";public static void main(String[] args) throws Exception {Connection connection = RabbitUtil.getConnection();Channel channel = connection.createChannel();//创建普通队列死信分发参数HashMap<String,Object> arguments= new HashMap<>();arguments.put("x-dead-letter-exchange",DEAD_EXCHANGE);arguments.put("x-dead-letter-routing-key","lisi");//设置队列最大长度arguments.put("x-max-length",5);//创建普通交换机与队列并绑定channel.exchangeDeclare(NORMAL_EXCHANGE, BuiltinExchangeType.DIRECT);channel.queueDeclare(NORMAL_QUEUE,false,false,false,arguments);channel.queueBind(NORMAL_QUEUE,NORMAL_EXCHANGE,"zhangsan");//创建死信交换机和队列并绑定channel.exchangeDeclare(DEAD_EXCHANGE,BuiltinExchangeType.DIRECT);channel.queueDeclare(DEAD_QUEUE,false,false,false,null);channel.queueBind(DEAD_QUEUE,DEAD_EXCHANGE,"lisi");DeliverCallback deliverCallback= (tag,msg)->{String message = new String(msg.getBody());System.out.println("消息:"+message+"被拒绝");};//创建消费者channel.basicConsume(NORMAL_QUEUE,false,deliverCallback,(tag)->{});}
    }
    
    package com.vmware.rabbit.demo8;import com.rabbitmq.client.AMQP;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.vmware.rabbit.utils.RabbitUtil;public class Producer {private static final String EXCHANGE_NAME = "normal_exchange";private static final String ROUTING_KEY = "zhangsan";public static void main(String[] args) throws Exception {Connection connection = RabbitUtil.getConnection();System.out.println("已连接到RabbitMQ服务器....");Channel channel = connection.createChannel();for (int i = 0; i < 10; i++) {String message = "msg" + i;channel.basicPublish(EXCHANGE_NAME, ROUTING_KEY, null, message.getBytes());System.out.println("消息:"+message+"发送成功!");}}
    }
    
  • 消息被拒

    package com.vmware.rabbit.demo8;import com.rabbitmq.client.BuiltinExchangeType;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.DeliverCallback;
    import com.vmware.rabbit.utils.RabbitUtil;import java.util.HashMap;public class Consumer {//普通交换机private static final String NORMAL_EXCHANGE = "normal_exchange";//死信交换机private static final String DEAD_EXCHANGE = "dead_exchange";//普通队列private static final String NORMAL_QUEUE = "normal_queue";//死信队列private static final String DEAD_QUEUE = "dead_queue";public static void main(String[] args) throws Exception {Connection connection = RabbitUtil.getConnection();Channel channel = connection.createChannel();//创建普通队列死信分发参数HashMap<String,Object> arguments= new HashMap<>();arguments.put("x-dead-letter-exchange",DEAD_EXCHANGE);arguments.put("x-dead-letter-routing-key","lisi");//创建普通交换机与队列并绑定channel.exchangeDeclare(NORMAL_EXCHANGE, BuiltinExchangeType.DIRECT);channel.queueDeclare(NORMAL_QUEUE,false,false,false,arguments);channel.queueBind(NORMAL_QUEUE,NORMAL_EXCHANGE,"zhangsan");//创建死信交换机和队列并绑定channel.exchangeDeclare(DEAD_EXCHANGE,BuiltinExchangeType.DIRECT);channel.queueDeclare(DEAD_QUEUE,false,false,false,null);channel.queueBind(DEAD_QUEUE,DEAD_EXCHANGE,"lisi");DeliverCallback deliverCallback= (tag,msg)->{String message = new String(msg.getBody());if (message.equals("msg5")){System.out.println("消息:"+message+"被拒绝");channel.basicReject(msg.getEnvelope().getDeliveryTag(),false);}else {System.out.println("接收到消息:"+message);channel.basicAck(msg.getEnvelope().getDeliveryTag(),false);}};//创建消费者channel.basicConsume(NORMAL_QUEUE,false,deliverCallback,(tag)->{});}
    }
    
    package com.vmware.rabbit.demo8;import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.rabbitmq.client.DeliverCallback;
    import com.vmware.rabbit.utils.RabbitUtil;public class Consumer2 {private static final String DEAD_QUEUE_NAME = "dead_queue";public static void main(String[] args)throws Exception {Connection connection = RabbitUtil.getConnection();Channel channel = connection.createChannel();DeliverCallback deliverCallback=(tag,msg)->{String message= new String(msg.getBody());System.out.println("队列:"+DEAD_QUEUE_NAME+"\t收到消息:"+message);};channel.basicConsume(DEAD_QUEUE_NAME,true,deliverCallback,(tag)->{});}
    }
    
    package com.vmware.rabbit.demo8;import com.rabbitmq.client.AMQP;
    import com.rabbitmq.client.Channel;
    import com.rabbitmq.client.Connection;
    import com.vmware.rabbit.utils.RabbitUtil;public class Producer {private static final String EXCHANGE_NAME = "normal_exchange";private static final String ROUTING_KEY = "zhangsan";public static void main(String[] args) throws Exception {Connection connection = RabbitUtil.getConnection();System.out.println("已连接到RabbitMQ服务器....");Channel channel = connection.createChannel();for (int i = 0; i < 10; i++) {String message = "msg" + i;channel.basicPublish(EXCHANGE_NAME, ROUTING_KEY, null, message.getBytes());System.out.println("消息:"+message+"发送成功!");}}
    }
    
http://www.zhongyajixie.com/news/17997.html

相关文章:

  • 怎么在网上做公司网站全网推广平台有哪些
  • 制作校园网站百度软件下载中心官方网站
  • 莲塘网站建设枫树seo
  • 五莲网站建设公司引擎搜索大全
  • 国内代理ip地址重庆黄埔seo整站优化
  • 企业邮箱哪个好用和安全seo的主要工作是什么
  • 面包屑网站导航怎么做淘宝推广平台有哪些
  • 做网站怎么挣钱威海seo优化公司
  • 创意设计专业重庆seo排名电话
  • 开发网站的申请怎么写怎么去优化关键词
  • 济南企业网站搭建浙江网站建设营销
  • 电商运营是干嘛的网站推广优化外包公司哪家好
  • 怎么做关于易烊千玺的网站郑州网站seo外包公司
  • 为网站添加isapi扩展网站快速收录
  • 黑彩网站自己可以做么苹果被曝开发搜索引擎对标谷歌
  • 企业级网站建设外贸推广方式
  • 上海网站建设制作微信百度免费收录提交入口
  • 自贡网站制作网络销售管理条例
  • 自己网站做搜索引擎优化运营网站
  • 网站快照描述推广竞价的公司有哪些
  • wordpress wptitle班级优化大师app下载
  • 高端设计网站平台销售
  • 爱站网源码百度竞价广告
  • 上海网站优化上站长之家下载
  • 东莞网站优化关键词费用太原网站排名推广
  • qq是哪个公司开发出来的怎么制作seo搜索优化
  • 家装效果图网站谷歌商店下载官网
  • 曹县网站建设无锡网站制作无锡做网站
  • 启航做网站怎么样seo网站外链平台
  • 网站开发未来活动营销的方式有哪些