首先必须了解Mosquitto是什么，是支持MQTT的消息中间件。可以理解是MQTT的消息服务。 在Windows上安装Mosquitto Broker 注：从MQTT版本3.1.1开始采用的术语服务器而不是代理。 有两种可能性： 快速安装 标准安装 下载Windows安装包 http://mosq ...
Topic：可以理解为一个队列，生产者和消费者面向的都是一个 topic。 Partition：主要为了做负载，实现扩展性，一个非常大的 topic 可以分布到多个 broker（即服务器）上，一个 topic 可以分为多个 partition，每个 partition 是一个有序的队列。 一、to ...
分类：
系统相关 时间：
2019-09-13 17:16:17
阅读次数：
90
一 简介:今天来聊聊celery两大功能之一的异步处理 二 标准流程: 1 建立 config 文件 class Config: ENABLE_UTC = False CELERY_RESULT_BACKEND = 'redis://127.0.0.1:6379/5' BROKER_URL = 'r ...
分类：
其他好文 时间：
2019-09-12 12:54:01
阅读次数：
80
品优购项目--service-sellergoods模块的配置文件 ...
分类：
其他好文 时间：
2019-09-11 00:03:04
阅读次数：
134
一.前言 任何消息队列都是万变不离其宗都是3部分，消息生产者（Producer）、消息消费者（Consumer）和服务载体（在Kafka中用Broker指代）。那么本篇主要讲解Producer端，会有适当的图解帮助理解底层原理。 一.开发应用 首先介绍一下开发应用，如何构建一个KafkaProduc ...
分类：
其他好文 时间：
2019-09-10 22:05:10
阅读次数：
115
Kafka是一个分布式的Streaming处理平台，Kafka可以用于数据库中数据的导入导出，也可以用于实时流的处理，但是Kafka最核心的功能就是作为分布式的消息中间件。 Kafka集群是由多个Broker Server组成的，消息的发送者称为Producer，消息的消费者称为Consumer，t ...
分类：
其他好文 时间：
2019-09-08 22:43:34
阅读次数：
161
1.kafka架构 kafka处理消息大概流程 + 生产者发送消息给kafka服务器 + 消费者从kafka服务器（broker）读取消息 + kafka服务器依靠zookeeper集群进行服务协调管理 2.kafka基本术语 + message （消息） 生产消费的基本单位。 + topic（主题 ...
分类：
其他好文 时间：
2019-09-06 01:45:41
阅读次数：
121
1.生产者： 生产者发送消息到broker，有三种确认方式（request.required.acks）acks = 0: producer不会等待broker（leader）发送ack 。因为发送消息网络超时或broker crash(1.Partition的Leader还没有commit消息 2 ...
分类：
其他好文 时间：
2019-09-03 00:10:47
阅读次数：
141
操作系统：CentOS7(64-bit) 1 EMQ下载 下载地址：https://www.emqx.io/downloads#broker 下载界面如下图所示： 我们此处选择了开原版。 版本号为：v2.3.0 系统和软件：Linux/centos7/zip 下载后的文件为：emqttd-cento ...
分类：
其他好文 时间：
2019-08-30 19:04:51
阅读次数：
414
1.什么是Clelery Celery是一个简单、灵活且可靠的，处理大量消息的分布式系统 专注于实时处理的异步任务队列 同时也支持任务调度 Celery架构： Celery的架构由三部分组成，消息中间件（message broker），任务执行单元（worker）和任务执行结果存储（task res... ...
分类：
其他好文 时间：
2019-08-29 15:55:11
阅读次数：
146
