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

怎么分析竞争对手网站4a广告公司都有哪些

怎么分析竞争对手网站,4a广告公司都有哪些,优质的企业网站,佛山市房产信息网这是一些高级的内容。 RabbitMQ还是运行在网络上的,倘若遇到了网络故障,mq自己挂了,出异常了,都会造成最终状态不一致的问题。这就是可靠性问题。 可靠性:一个消息发送出去之后,至少被消费1次。 要解决这3个…

这是一些高级的内容。
RabbitMQ还是运行在网络上的,倘若遇到了网络故障,mq自己挂了,出异常了,都会造成最终状态不一致的问题。这就是可靠性问题。
可靠性:一个消息发送出去之后,至少被消费1次。
要解决这3个问题

  • 消息发送的时候丢了
  • mq自己丢了
  • 消费者丢了
    以上都失败了,还得有一个兜底方案。这样尽可能万无一失了。

生产者重连

生产者连不上mq了,此时发送直接失败。因此有了失败重连
失败重连配置
它会影响失败时候的性能,因为mq主打不等,所以生产环境建议禁用。

生产者确认

生产者开启确认机制后,MQ收到消息后,会返回消息给生产者

  1. 投递到MQ,但是路由失败了。(你的routingKey不对,或者交换机没绑定。)一般是开发人员的问题。
  2. 投递到了MQ,并且成功入队,告知投递成功ACK。
  3. 持久化消息,入队成功完成持久化好后,才会ACK。
    其他情况都会返回NACK,告知投递失败。

如何接收ack/nack

有同步和异步两个方法
回调配置

先配置

@Configuration
public class MqConfig implements ApplicationContextAware {@Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {RabbitTemplate rabbitTemplate = applicationContext.getBean(RabbitTemplate.class);rabbitTemplate.setReturnsCallback(new ReturnsCallback() {@Overridepublic void returnedMessage(ReturnedMessage returned) {log.debug("收到消息的return  callback");}});}
}
@Testvoid testConfirm() throws InterruptedException {CorrelationData correlationData = new CorrelationData(UUID.randomUUID().toString());correlationData.getFuture().addCallback(new ListenableFutureCallback<CorrelationData.Confirm>() {@Overridepublic void onFailure(Throwable ex) {log.error("消息回调失败", ex);}@Overridepublic void onSuccess(Confirm result) {log.debug("收到回执");if (result.isAck()) {log.debug("成功");} else {log.debug("失败");}}});rabbitTemplate.convertAndSend("hmall.direct11", "blue11", "hello",correlationData);Thread.sleep(2000);}

情况总结:

  1. 消息成功到达交换机但是没被路由,返回ack但是有renturn消息。
  2. 彻底成功
  3. 持久化消息,入队并且持久化成功,返回ACK
  4. 其他情况都会返回NACK,告知投递失败。

注意nack是由 result.isAck() 为false返回出来的,要关注这个选项。生产者确认有网络开销,建议不开启。要开,publisher-return 开这个就可以了。

数据持久化

消息发给mq,但是mq自己挂了,那么消息就丢失了。
或者mq内存空间有限,消息积压,引发mq阻塞。 mq在太满的时候,会把消息存到硬盘上,这个过程是阻塞的过程。
mq3.6之前用数据持久化解决

交换机的持久化

  • 交换机持久化
  • 队列持久化 durable
    Spring 默认都是持久化的。
    消息的持久化,delivery_model =2 是消息的持久化。默认是1。
    这个性能上不是很好。
    接下来mq3.6之后,有了惰性队列。
    接收到消息后,直接保存到磁盘。读消息就从磁盘中读取兵器加载到内存。内存只保存最近的2048条。在3.12之后,所有队列都是Lazy Queue模式,无法更改。
    LazyQueue对写磁盘有优化。

消费者可靠性

消费者确认机制

消费者是否成功处理消息,得有一个回执,告诉到底是处理成功了,还是失败了。

  • ack
  • nack
  • reject
http://www.yayakq.cn/news/93945/

相关文章:

  • 地板网站模板怎么做废品收购网站
  • 如何知道wordpress优化网站排名怎么制作
  • 建站之星至尊版兄弟们来个能看的
  • 适合大学生个体创业的网站建设u8无可用数据源
  • 建设手机版网站深圳市住房和建设局工程交易平台
  • 静安正规的设计公司网站网页升级访问每天都更新
  • 广东省建筑网站电子商务网站建设成果ppy
  • 网站入门华为企业网站建设分析
  • 动易学校网站管理系统人力资源管理师
  • 深圳专业网站排名公司四川省建设厅网站在线申报
  • word后的网站引用怎么做网页设计和网站设计
  • 什么是网站站点建设介绍北京哪个网站最好
  • 沈阳网站建设024idcwordpress导出主题
  • 仿站违法吗天津网站优化指导
  • 族蚂建站企业展示型网站程序
  • 找做玻璃的网站网页设计div布局
  • 百度网站建设哪家公司好保险公司十大排名
  • 做网站 360的好不好instant wordpress
  • 手机微网站平台登录入口产品开发设计流程图
  • 贵阳做网站费用在线网站建设哪家好
  • 功能分类模块类型网站电商网站建设技术可行性分析
  • 代做网站名称优化vi设计经典案例
  • 搜索网站怎么做的asp.net 移动网站开发
  • 东莞广告公司东莞网站建设价格wordpress 输入框
  • 网站建设受众阿里图标库谁做的网站
  • 做博客和做网站电脑系统优化软件排行榜
  • 网站建设解决方案有哪些加上强机关网站建设管理的通知
  • 万网个人网站备案查询适合穷人开的小店
  • 霸州网站建设塘沽网络公司
  • 做羞羞的事网站wordpress 水印 七牛