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

建站服务昆明网站开发

建站服务,昆明网站开发,网站后台 编辑器 调用,做网站怎么加入索引功能在Java中#xff0c;可以使用消息队列来实现消息的异步处理#xff0c;其中常用的消息队列有 RabbitMQ、ActiveMQ、Kafka 等。 什么是幂等性#xff1f; 幂等性是指无论操作执行多少次#xff0c;都是得到相同的结果#xff0c;而不会产生其他副作用。 在rabbitMQ中 什…在Java中可以使用消息队列来实现消息的异步处理其中常用的消息队列有 RabbitMQ、ActiveMQ、Kafka 等。 什么是幂等性 幂等性是指无论操作执行多少次都是得到相同的结果而不会产生其他副作用。 在rabbitMQ中 什么是消息重复消费 同一条消息在MQ中被消费多次 出现重复消费的原因 生产者发送一条消息到rabbitMQ但rabbitMQ尚未收到消费者的确认会认为消息消费未被消费而重新发送。 网络不稳定、消费者故障、网络分区、消息重复传递策略、消费者超时设置不当 为什么需要避免重复消费 业务错误我本来写的业务逻辑就是只要执行一次 数据重复数据插入重复破坏数据唯一性 资源浪费占用系统资源降低系统性能 如何避免消息重复消费 消息去重 通过记录已经消费过的消息在消息到达时检查它是否已经在记录中存在从而避免重复处理。 if (!processedMessages.contains(message)) {processMessage(message);processedMessages.add(message);} 消息幂等性 分布式锁(消息幂等性) 使用UUID生成唯一Id 作为messageId 使用了唯一的消息ID来确保同一条消息只会被处理一次。 AMQP.BasicProperties properties new AMQP.BasicProperties().builder().messageId(UUID.randomUUID().toString()) // 唯一标识.build();if (!isMessageProcessed(messageId)) {processMessage(message);saveProcessedMessage(messageId);} 消费者先查询该消息是否已经被处理过如果没有被处理过则调用processMessage()方法处理该消息并使用 saveProcessedMessage()方法保存已经处理过的消息。 //手动ackchannel.basicAck(message.getMessageProperties().getDeliveryTag(),false在处理完消息后还需要调用channel.basicAck(envelope.getDeliveryTag(), false)方法确认消息已经被消费。这是因为RabbitMQ是一个消息的投递机制只有在消费者确认了消息已经被处理后才会从消息队列中删除该消息。 使用redis实现避免重复消费 生产者 AMQP.BasicProperties properties new AMQP.BasicProperties().builder().deliveryMode(1) // 指定消息是否需要持久化 1-需要 2-不需要.messageId(UUID.randomUUID().toString()) // 唯一标识.build();消费者 String result jedis.set(messageId, 0, NX, EX, 10);if (result ! null result.equalsIgnoreCase(OK)){System.out.println(接收到消息 new String(body,UTF-8));//消费成功 set messageId - 1jedis.set(messageId,1);channel.basicAck(envelope.getDeliveryTag(),false);}else {//如果1中的setnx失败获取key对应的value如果是1设置ack 如果是0 returnString s jedis.get(messageId);if (1.equalsIgnoreCase(s)){//消费完了channel.basicAck(envelope.getDeliveryTag(),false);}}spring-boot 如果存在设置value为1如果value是1ack 事务性消费 消费状态追踪
http://wiki.neutronadmin.com/news/241849/

相关文章:

  • 池州市建设工程质量安全监督局网站网站在线qq代码
  • 珠海网站开发维护科技公司长沙百度网站制作
  • 网站开发培训费多少网站建设实验报告
  • sql数据库环境网站搭建教程php做的大型网站
  • 苏州网站建站推广搜好资源网
  • 网站后台 源码公司专业网站建设
  • iis7 添加网站国际域名注册查询
  • php电商网站开发贴吧福州制作网站企业
  • 电器网站建设策划书怎样做艾条艾柱网站
  • 手机网站设计要求重庆建设工程安全协会网站
  • 河南建设建设监理协会网站一个公司可以做两个网站不
  • 宁波网站建设多少钱一个石台做网站
  • 网站关键词的选择wordpress 类似建站
  • 公司网站建设需要提供什么材料远程访问群晖wordpress
  • wordpress发布文章添加新字段seo收录排名
  • 国外网站开发技术青岛外贸假发网站建设
  • 给别人做网站别人违法经营6杭州做网站的优质公司哪家好
  • wordpress二维码手工南昌seo排名外包
  • 网站建设增长率济南10大互联网公司排名
  • 企业手机网站 案例网站查询是否安全
  • 新手怎么样学做网站wordpress学校模板
  • linux 网站建设深圳品牌男装有哪些
  • 东莞wordpress建站登封做网站
  • 网站建设企业排行网站建设优化保定
  • 重庆一品建设集团有限公司网站wordpress安全性
  • 做编程网站有哪些苏州高新区建设局网站管网
  • 长葛网站建设自己做网站后台
  • 成都公司展厅设计公司引擎优化seo
  • 企业网站建设的类型主要有网站多个页面要加引导
  • 网站建设洽谈问题建公司网站要多少钱