前置知识 以RocketMQ为例 使用IDR启动RocketMQ,参考Eclpse启动RocketMq 大多数消息中间件都支持固定延时队列,比如RocketMQ支持的默认延时等级messageDelayLevel=1s 5s 10s 30s 1m 2m 3m 4m 5m 6m 7m 8m 9m 10 ...
分类:
其他好文 时间:
2020-07-22 15:55:58
阅读次数:
67
Redis 参考链接: Http://redis.io/ http://www.redis.cn/ 介绍 Remote Dictionary Server(远程字典服务器) 它可以用作数据库、缓存和消息中间件。 它支持多种类型的数据结构,如 字符串(strings), 散列(hashes), 列表( ...
分类:
其他好文 时间:
2020-07-22 02:17:22
阅读次数:
143
一.rabbitmq基础 1.简介 RabbitMQ是使用Erlang语言来编写的,并且RabbitMQ是基于AMQP协议的。Erlang语言在数据交互方面性能优秀,有着和原生Socket一样的延迟,这也是RabbitMQ高性能的原因所在 2.典型应用场景 (1)异步处理。把消息放入消息中间件中,等 ...
分类:
其他好文 时间:
2020-07-21 23:24:11
阅读次数:
106
工欲善其事,必先利其器。 什么是Celery Celery是一个简单、灵活且可靠的,处理大量消息的分布式系统,专注于实时处理的异步任务队列,同时也支持任务调度。 上面的图是一个利用Celery进行异步处理的架构,属于生产者-消费者模式,架构由三部分组成: 消息中间件(message broker): ...
分类:
其他好文 时间:
2020-07-19 00:54:19
阅读次数:
106
图灵学院 java架构师学习路线 概述 ActiveMQ有支持两种事务, JMS transactions - the commit() / rollback() methods on a Session (which is like doing commit() / rollback() on a ...
分类:
其他好文 时间:
2020-07-08 14:56:33
阅读次数:
72
MQ主要流程 解耦,异步,消峰 其中目的地主要为队列或者主题 队列点对点 消息的生产者 或者 这时消息的生产者名字已经出来 并且入队的数量变成了3 上述完成的也就是这部分 消息的消费者 前四步大同小异 这里需要和消息发送者的类型一致,所以需要强转一下 其中等待接收可以设置为一直等或者设置时长 最后再 ...
分类:
其他好文 时间:
2020-07-06 12:33:08
阅读次数:
64
redis持久化存储 redis多被用于缓存和消息中间件,当被用作缓存时,数据的读写都是在内存中进行的,而内存一旦在主机断电或者主机重启时里面的数据将被清空,为保证数据不被丢失,redis为我们提供两种数据持久化存储方式:RDB,AOF。 RDB持久化存储 RDB持久化是按配置文件中指定的时间间隔, ...
分类:
其他好文 时间:
2020-07-03 23:08:07
阅读次数:
75
一、Redis 简介: Redis是一个开源的、基于内存的数据结构存储器,可以用作数据库、缓存和消息中间件。 Redis是一个key-value存储系统。和Memcached类似,它支持存储的value类型相对更多,包括string(字符串)、list(链表)、set(集合)、zset(sorted ...
分类:
数据库 时间:
2020-07-03 17:09:08
阅读次数:
77
1. 消息中间件概述 1.1. 什么是消息中间件 MQ全称为Message Queue,消息队列是应用程序和应用程序之间的通信方法。 为什么使用MQ 在项目中,可将一些无需即时返回且耗时的操作提取出来,进行异步处理,而这种异步处理的方式大大的节省了服务器的请求响应时间,从而提高了系统的吞吐量。 开发 ...
分类:
其他好文 时间:
2020-07-03 09:16:22
阅读次数:
72