消息队列(Message Queue,简称MQ),从字面意思上看,本质是个队列,FIFO先入先出,只不过队列中存放的内容是message而已。 其主要用途:不同进程Process/线程Thread之间通信。 为什么会产生消息队列?有几个原因: 不同进程(process)之间传递消息时,两个进程之间耦 ...
分类:
其他好文 时间:
2020-04-17 20:05:56
阅读次数:
148
概述 场景 服务解耦 削峰填谷 异步化缓冲:最终一致性/柔性事务 MQ应用思考点 生产端可靠性投递 消费端幂等:消息只能消费一次 高可用、低延迟、可靠性 消息堆积能力 可扩展性 业界主流MQ ActiveMQ:适合传统需求,并发性差 RabbitMQ:扩展性差 RocketMQ:扩展性强 Kafka ...
分类:
编程语言 时间:
2020-04-15 00:32:15
阅读次数:
107
摘抄自简书:https://www.jianshu.com/p/9feddd4af8ee RabbitMQ是目前主流的消息中间件,非常适用于高并发环境。各大互联网公司都在使用的MQ技术,晋级技术骨干、团队核心的必备技术! 谈到消息的可靠性投递,无法避免的,在实际的工作中会经常碰到,比如一些核心业务需 ...
分类:
编程语言 时间:
2020-04-14 14:03:32
阅读次数:
77
做消息持久化 借助 jdbc, kahadb或 leveldb+zookeeper首先将将消息发送设置为持久化发送(mq自带的属性),然后再借助jdbc kahadb leveldb+zookeeper等做消息的存储来持久化。思想都是发送者(消息生产者)将消息发送出去后,消息中心首先将消息存储到本地 ...
分类:
其他好文 时间:
2020-04-10 22:48:34
阅读次数:
232
上一篇讲解了MQTT协议在JS实现,通过和Unity3D交互实现通信,因为对JS不是特别精通,所以讲得比较粗略。这一篇中,介绍Unity3D实现MQTT协议通信,将细致讲解过程MQTT是IBM开源的一个通讯方式,是一个基于TCP的发布订阅协议,MQTT使用类似MQ常用的发布/订阅模式,起到应用程序解耦,异步消息,削峰填谷的作用。优点:使用发布/订阅模式,提供一对多的消息发布,使消息发送者和接收者在
分类:
编程语言 时间:
2020-04-10 10:24:46
阅读次数:
257
1.问题出现 搭完mq单主单从集群之后,美滋滋想发一下message, 没想到碰到一个坑爹的问题: com.alibaba.rocketmq.client.exception.MQBrokerException: CODE: 14 DESC: service not available now, m ...
分类:
系统相关 时间:
2020-04-10 00:36:42
阅读次数:
616
一、需求描述: 系统中,如果有一些数据发生异常的情况需要及时处理掉。比如: 跟其他系统对接时候发生异常! 二、思路: 利用切面捕获到某些特定业务接口产生的异常信息,然后 发送到MQ中,MQ获取到异常信息,发送到接收异常报告的邮箱。 末尾有Github地址~ 代码部分 : 三、自定义异常日志的注解 主 ...
分类:
编程语言 时间:
2020-04-09 17:56:30
阅读次数:
89
作者:卓庆森 http://www.cnblogs.com/zhuoqingsen/p/MQ.html 我走过最长的路是你的套路 女:二号男嘉宾,假如我们牵手成功后,你会买名牌包包给我吗? 男:那你会听话吗? 女:会 听话。 男:听话 咱不买! OK那么消息队列MQ有什么套路呢? (这个话题转换生硬 ...
分类:
其他好文 时间:
2020-04-08 16:22:42
阅读次数:
83
在整个JavaWeb项目开发中,事务是用来开发可靠性网络应用程序的最关键部分。当应用程序与后端资源进行交互时,就会用到事务,这里的后端资源包括数据库、MQ、ERP等。而数据库事务是最常见的类型,而我们常说的事务也就是狭义上的与关系型数据库交互的事务。
事务主要分为本地事务和全局事务。全局事务又称分... ...
分类:
数据库 时间:
2020-04-06 10:13:30
阅读次数:
116
项目中使用的PHP,但由于长耗时的任务,前端提交以后,需要服务端异步响应。 服务器异步有多种方案,包括MQ,fsocket,Swoole等。 (推荐学习: swoole视频教程) Swoole 使用纯 C 语言编写,提供了 PHP 语言的异步多线程服务器,异步 TCP/UDP 网络客户端,异步 My ...
分类:
Web程序 时间:
2020-04-05 22:26:08
阅读次数:
87