# 运维管理 ### 1 集群搭建#### 1.1 单Master模式这种方式风险较大，一旦Broker重启或者宕机时，会导致整个服务不可用。不建议线上环境使用,可以用于本地测试。##### 1）启动 NameServer```bash### 首先启动Name Server$ nohup sh mq ...
分类：
其他好文 时间：
2019-12-24 13:56:26
阅读次数：
80
第一步 创建Zookeeper 下载完成后 修改 Zookeeper中的 zoo.cfg 修改 dataDir 、dataLogDir 集群模式 server.1=ServerIP:2888:3888 第二步 创建 kafka 检查 server.properties 是否正确 第三步 启动 Zoo ...
分类：
其他好文 时间：
2019-12-24 13:33:09
阅读次数：
128
最佳实践 1 生产者 1.1 发送消息注意事项 1 Tags的使用 一个应用尽可能用一个Topic，而消息子类型则可以用tags来标识。tags可以由应用自由设置，只有生产者在发送消息设置了tags，消费方在订阅消息时才可以利用tags通过broker做消息过滤：message.setTags("T ...
分类：
其他好文 时间：
2019-12-24 13:31:38
阅读次数：
76
# 基本概念 ## 1 消息模型（Message Model）RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。Broker 在实际部署过程中对应一台服务器，每个 Br ...
分类：
其他好文 时间：
2019-12-24 13:23:29
阅读次数：
53
目标 1、交换机 2、RabbitMQ整合springCloud 交换机 蓝色区域 生产者 红色区域 Server：又称Broker，接受客户端的连接，实现AMQP实体服务 绿色区域 消费者 黄色区域 就是我们的交换机以及队列 由生产者投递信息到RabbitMQ Server里面某一个交换机对应的队 ...
分类：
编程语言 时间：
2019-12-23 00:55:32
阅读次数：
134
1. 消息生产者、消息者、队列 消息生产者Producer：发送消息到消息队列。 消息消费者Consumer：从消息队列接收消息。 Broker：概念来自与Apache ActiveMQ，指MQ的服务端，帮你把消息从发送端传送到接收端。 消息队列Queue：一个先进先出的消息存储区域。消息按照顺序发 ...
分类：
其他好文 时间：
2019-12-17 22:01:53
阅读次数：
62
WARN - The configuration 'zookeeper.connect' was supplied but isn't a known config.WARN - The configuration 'input.topic' was supplied but isn't a kno ...
分类：
其他好文 时间：
2019-12-17 11:52:26
阅读次数：
2471
二、Celery基本使用 创建一个celery application 用来定义你的任务列表，创建一个任务文件就叫tasks.py吧 from celery import Celery # 配置好celery的backend和broker app = Celery('task1', backend= ...
分类：
编程语言 时间：
2019-12-13 17:54:40
阅读次数：
172
高性能 存储原理 零拷贝 数据结构与存储逻辑 刷盘策略 长轮询PULL RocketMQ的Consumer都是从Broker拉消息来消费，但是为了能做到实时收消息，RocketMQ使用长轮询方式，可以保证消息实时性同Push方式一致。 这里需要注意的是，长轮询与长连接是两个不同的概念。长轮询表示，当 ...
分类：
其他好文 时间：
2019-12-10 20:59:22
阅读次数：
104
官网： https://docs.emqx.io/broker/v3/cn/getstarted.html#mqtt-clients 一、安装启动 # 各平台下载https://www.emqx.io/downloads/broker?osType=Linux # 解压（例子linux） ， win ...
分类：
其他好文 时间：
2019-12-09 21:39:31
阅读次数：
2476
