Apache Kafka 架构和相关概念 Apache Kafka 是一款开源的分布式消息引擎系统 消息引擎的同类 ActiveMQ RabbitMQ WebSphere MQ Rocket MQ JMS仅仅是一组 API 协议 消息引擎的作用 削峰填谷 缓冲上下游瞬时突发流量,使其更平滑.特别是对 ...
分类:
Web程序 时间:
2020-07-28 00:19:27
阅读次数:
86
基于分布式异步框架celery 前文已知,celery可以执行异步任务、延时任务、定时任务。 broker:'redis://127.0.0.1:6379/2' # 消息队列(中间件) broker 可以使用Redis、RabbitMQ backend:'redis://127.0.0.1:6379 ...
分类:
其他好文 时间:
2020-07-27 23:58:21
阅读次数:
99
一 Redis基础 1.1 Redis安装 #1 key-value的存储方式, value有很多数据类型:5大:string(字符串)、list(链表)、set(集合)、zset(sorted set --有序集合)和hash(哈希类型 #2 非关系型内存数据库 #3 与Memcached比较: ...
分类:
其他好文 时间:
2020-07-27 23:52:58
阅读次数:
78
一、创建celery包 1、新建一个包,任意命名,如,celery_task。 2、包内创建celery对象,指定命名为celery.py: from celery import Celery broker = 'redis://127.0.0.1:6379/1' backend = 'redis: ...
分类:
其他好文 时间:
2020-07-27 23:34:07
阅读次数:
76
Celery 官方 Celery 官网:http://www.celeryproject.org/ Celery 官方文档英文版:http://docs.celeryproject.org/en/latest/index.html Celery 官方文档中文版:http://docs.jinkan. ...
分类:
其他好文 时间:
2020-07-27 17:55:00
阅读次数:
98
一.消息的可靠投递 在使用RabbitMq的时候,作为消息发送方希望杜绝任何消息丢失或者投递失败的场景。RabbitMQ为我们提供了两种方式用来控制消息的投递可靠性 rabbitMQ 整个消息投递过程为: producer -> rabbitMQ broker -> exchange -> queu ...
分类:
其他好文 时间:
2020-07-27 17:53:27
阅读次数:
116
celery的使用 # 1 异步任务框架,执行异步任务,执行延迟任务,执行定时任务 # 2 Celery is a project with minimal funding, so we don’t support Microsoft Windows. Please don’t open any i ...
分类:
其他好文 时间:
2020-07-26 23:15:34
阅读次数:
64
事件总线 什么是事物 例如:事物 所有看到的一切都是事物,不能看到的也是事物 例如:团队微服务,成员微服务,聚合微服务,网关api,认证中心等等包括类,对象 所有的事件都是事物变化的结果 大家接触事件最早就是在js 或者是c#高级特性。大家对于事件不默认,但是对于事件不是很好理解 什么是事件 事件就 ...
分类:
其他好文 时间:
2020-07-26 01:25:30
阅读次数:
85
RabbitMq保证消息可靠性之确认模式 前提 完成 SpringBoot 整合 RabbitMq 中的Topic通配符模式 一、更改Producer工程的application.yml文件 spring: rabbitmq: host: localhost port: 5672 virtual-h ...
分类:
其他好文 时间:
2020-07-26 01:04:06
阅读次数:
114
RabbitMq保证消息可靠性之回退模式 前提 完成 SpringBoot 整合 RabbitMq 中的Topic通配符模式 一、更改Producer工程的application.yml文件 spring: rabbitmq: host: localhost port: 5672 virtual-h ...
分类:
其他好文 时间:
2020-07-26 01:03:17
阅读次数:
81