什么是消息队列 消息队列,即MQ,Message Queue。 消息队列是典型的:生产者、消费者模型。生产者不断向消息队列中生产消息,消费者不断的从队列中获取消息。因为消息的生产和消费都是异步的,而且只关心消息的发送和接收,没有业务逻辑的侵入,这样就实现了生产者和消费者的解耦。 结合前面所说的问题: ...
分类:
其他好文 时间:
2019-07-13 20:05:30
阅读次数:
134
为什么Kafka那么快 原创 2016 07 18 fireflyc 写程序的康德 网上有很多Kafka的测试文章,测试结果通常都是“吊打”其他MQ。感慨它的牛B之余我觉得必要仔细分析一下它如此快速的原因。这篇文章不同于其他介绍Kafka使用或者技术实现的文章,我会重点解释——为什么真快。(当然不是 ...
分类:
其他好文 时间:
2019-07-12 22:29:03
阅读次数:
133
问题:Cannotsend,channelhasalreadyfailed:tcp://ip:61616javax.jms.JMSException:Cannotsend,channelhasalreadyfailed:tcp://ip:61616应用连不上mq#解决方案:一,分析思路:1.现象:通过netstat查看与61616相关的连接状况,发现130多个CLOSE_WAIT2.是什么原因造成
分类:
其他好文 时间:
2019-07-09 21:02:03
阅读次数:
180
解耦神器:MQ MQ是分布式架构中的解耦神器,应用非常普遍。有些分布式事务也是利用MQ来做的。由于其高吞吐量,在一些业务比较复杂的情况,可以先做基本的数据验证,然后将数据放入MQ,由消费者异步去处理后续的复杂业务逻辑,这样可以大大提高请求响应速度,提升用户体验。如果消费者业务处理比较复杂,也可以独立 ...
分类:
其他好文 时间:
2019-07-09 15:13:17
阅读次数:
91
原理场景 MQ在所有项目里面都很常见, 1、减少非紧急性任务对整个业务流程造成的延时; 2、减少高并发对系统所造成的性能上的影响; 举例几个场景: 1、给注册完成的用户派发优惠券、加积分、发消息等(派发优惠券、加积分、发消息这些属于非紧急性任务,可交由MQ进行处理,先让用户完成注册) 2、实时收集用 ...
分类:
其他好文 时间:
2019-07-09 00:04:30
阅读次数:
198
MySQL数据库调优 定位慢查询得到生产环境那些sql语句响应慢,根据执行计划进行分析调优事物管理索引结构(B+树)平衡二叉树、B树、B+树分库分表后,如何解决查询 使用第三方数据库中间件(MyCat、Sharding-JDBC) 什么使用RedisSpring IOC原理 Logstash与MQ实 ...
分类:
编程语言 时间:
2019-07-08 10:50:58
阅读次数:
136
一、查看后台对应进程是否启动 这里以linux上启动active mq为例,ps -ef按名称查,netstat -anp按端口查 1.1 ps -ef|grep activemp 会查出该进程 但是同时该linux命令也被查出 1.2 ps -ef|grep activemq| grep -v g ...
分类:
系统相关 时间:
2019-07-07 14:29:39
阅读次数:
116
综合概述 消息队列 消息队列就是一个消息的链表,可以把消息看作一个记录,具有特定的格式以及特定的优先级。对消息队列有写权限的进程可以向消息队列中按照一定的规则添加新消息,对消息队列有读权限的进程则可以从消息队列中读走消息,而消息队列就是在消息的传输过程中保存消息的容器,你可以简单的把消息队列理解为类 ...
分类:
编程语言 时间:
2019-07-06 19:42:04
阅读次数:
211
首先就是比如rabbitmq、rocketmq、kafka,都有可能会出现消费重复消费的问题,正常。因为这问题通常不是mq自己保证的,是给你保证的。然后我们挑一个kafka来举个例子,说说怎么重复消费吧。 kafka实际上有个offset的概念,就是每个消息写进去,都有一个offset,代表他的序号 ...
分类:
其他好文 时间:
2019-07-03 09:16:07
阅读次数:
106
系统可用性降低? 一旦mq不能使用以后,系统A不能发送消息到mq,系统BCD无法从mq中获取到消息.整个系统就崩溃了. 如何解决: 系统复杂程度增加? 加入mq以后,mq引入来的问题很多,然后导致系统的复杂程度增加. 如何解决 系统的一致性降低? 有人给系统A发送了一个请求,本来这个请求应该系统BC ...
分类:
其他好文 时间:
2019-07-03 00:30:40
阅读次数:
148