集群docker-compose rocketmq compose
Kafka 集群副本数量调整
Kafka 创建时未指定多个副本或者副本数量过少，都可以在后期手动添加，另外如果副本过多也可以减少，当前调整基于 Kafka 的版本是 2.5.1，但是估计 2.1 ~ 2.5 应该都是兼容的。 下面先来操作一下 Topic 副本减少的过程，首先查看 Kafka Topic 的详情： # 新版本的 ......
docker-compose安装Redis
一、单机版本 1、docker-compose version: '3' services: redis: image: redis:5.0 restart: always privileged: true container_name: redis-java ports: - 6379:6379 ......
【RocketMQ】Rebalance负载均衡总结
消费者负载均衡，是指为消费组下的每个消费者分配订阅主题下的消费队列，分配了消费队列消费者就可以知道去消费哪个消费队列上面的消息，这里针对集群模式，因为广播模式，所有的消息队列可以被消费组下的每个消费者消费不涉及负载均衡，而集群模式一个消息队列同一时间只能分配给组内的一个消费者进行消费。 Rocket ......
【1.0】RocketMQ初识
【一】什么是RocketMQ RocketMQ 是一款功能强大的分布式消息系统，广泛应用于多个领域，包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等。 RocketMQ 源码地址：https://github.com ......
Hadoop集群搭建(完全分布式)
一，Hadoop集群简介 1.1 Hadoop集群整体概述 Hadoop集群包括两个集群:HDFS集群、YARN集群 两个集群逻辑上分离、通常物理上在一起 两个集群都是标准的主从架构集群 Hadoop两种集群内容： 逻辑上分离，物理上合并的理解： 逻辑上分离：两个集群互相之间没有依赖、互不影响 物理 ......
视频监控/视频汇聚/安防视频监控平台EasyCVR配置集群后有一台显示离线是什么原因？
开源EasyDarwin视频监控TSINGSEE青犀视频平台EasyCVR能在复杂的网络环境中，将分散的各类视频资源进行统一汇聚、整合、集中管理，在视频监控播放上，TSINGSEE青犀视频安防监控汇聚平台可支持1、4、9、16个画面窗口播放，可同时播放多路视频流，也能支持视频定时轮播。视频监控汇聚平 ......
视频监控/视频汇聚/安防视频监控平台EasyCVR配置集群后有一台显示离线是什么原因？
服务器时间获取的还是utc时区的时间；因为数据库的时间戳获取的就是utc时间，判断与跟现场数据库获取的时间戳有关 ......
Docker: docker-compose file
docker-compose.yaml: version: '3.3' services: nginx: image: nginx:latest ports: - 8080:80 With regards to the preceding docker-compose file, we have t ......
Docker - Install Docker Compose
Install using the repository Set up the repository. Find distro-specific instructions in: Ubuntu | CentOS | Debian | Raspberry Pi OS | Fedora | RHEL | ......
【RocketMQ】事务实现原理总结
RocketMQ事务的使用场景 单体架构下的事务 在单体系统的开发过程中，假如某个场景下需要对数据库的多张表进行操作，为了保证数据的一致性，一般会使用事务，将所有的操作全部提交或者在出错的时候全部回滚。以创建订单为例，假设下单后需要做两个操作： 在订单表生成订单 在积分表增加本次订单增加的积分记录 ......
RocketMq发送消息之事务消息
概述 事务消息共有三种状态，提交状态、回滚状态、中间状态： TransactionStatus.CommitTransaction: 提交事务，它允许消费者消费此消息。 TransactionStatus.RollbackTransaction: 回滚事务，它代表该消息将被删除，不允许被消费。 Tr ......
kafka集群搭建
应用场景 削峰填谷：就像小米卖手机搞饥饿营销，打开他的官网首页就需要排队，把用户的请求存放到消息队列，后端的服务器过一段时间在去处理异步解耦：京东用户下订单，双十11的时候订单量很大，而后端数据库是没有那么大的处理能力，先把订单放在消息队列，然后让数据库链接消息队列kafka慢慢的把数据写入到数据库 ......
使用 Docker Compose 安装 APISIX
1.基本概念 APISIX 是 Apache 下的一款云原生的 API 网关，支持全生命周期的 API 管理，在应用中可以作为所有 API 调用的统一入口。 APISIX 有一些基础概念如下： Upstream，或者叫做上游，是一组目标主机的抽象，上游一组节点提供实际的业务服务，一般需要指定负载均衡 ......
etcd 集群安装
1.环境准备 下载安装包：https://github.com/etcd-io/etcd/releases/ 这里下载的安装包为：etcd-v3.5.9-linux-amd64.tar.gz，即我们当前安装的 etcd 版本为：3.5.9 这里有 3 个节点，分别为： 10.23.0.21 ec1 ......
kubepi加入集群，生成token
防丢失 https://www.cnblogs.com/Chinori/p/17506348.html kubectl create sa kubepi-user --namespace kube-systemkubectl create clusterrolebinding kubepi-user ......
ZooKeeper集群搭建
ZooKeeper 是一个分布式服务框架，它主要是用来解决分布式应用中经常遇到的一些数据管理问题，如：命名服务、状态同步、配置中心、集群管理等。 消费者模型 0 生产者启动 1 生产者注册至 zookeeper(生产者的代码启动) 2 消费者启动并订阅频道(消费者往那个频道注册的就会到那个频道去找， ......
Consul 集群安装
1.介绍 Consul 是一款服务网络平台，主要实现服务注册、服务发现、服务网格、服务网关、安全网络以及配置管理等多类服务，非常适合做为微服务架构的底层网络平台。 配置中心其实就是一个 KV 存储，我们如果做配置中心的话其实主要就是用 KV 存储部分，但是为了以后的可扩展性，我们可能会使用各种服务网 ......
JMeter 分布式集群远程压测及搭建常见问题
1、JMeter可以在以下场景下使用分布式远程压测： 性能测试：JMeter可以模拟大量用户并发访问，进行性能测试。当需要模拟成千上万的用户请求时，单台机器可能无法承受如此大的负载，此时可以使用分布式远程压测来将测试负载分发到多台机器上，提高测试的效率和准确性。 稳定性测试：在一段时间内持续发送请求 ......
Redis搭建集群架构
使用docker搭建 6.x 版本以后的镜像 docker 支持部署集群模式，由于 Redis 要求集群至少要有三个主节点，因此本次测试搭建了三主三从的 Redis 集群。 不基于 Host 网络模式 配置docker-compose.yml文件 version: "3" networks: red ......
ceph（四）ceph集群管理、pg常见状态总结
1. ceph常见管理命令总结 1.1 只显示存储池 ceph osd pool ls 示例 $ ceph osd pool ls device_health_metrics mypool myrbd1 rbd-data1 1.2 列出存储池并显示id ceph osd lspools 示例 $ c ......
RocketMq发送消息之过滤消息
过滤消息概述 在大多数情况下，TAG是一个简单而有用的设计，其可以来选择您想要的消息。例如： // 定义一个group1的消费者组 DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("group1"); // 订阅 TOPIC 主题 ......
深入理解RocketMQ 广播消费
这篇文章我们聊聊广播消费，因为广播消费在某些场景下真的有奇效。笔者会从基础概念、实现机制、实战案例、注意事项四个方面一一展开，希望能帮助到大家。 1 基础概念 RocketMQ 支持两种消息模式：集群消费（ Clustering ）和广播消费（ Broadcasting ）。 集群消费： 同一 To ......
RocketMq发送消息之批量消息
概述 批量发送消息能显著提高传递小消息的性能。限制是这些批量消息应该有相同的topic，相同的waitStoreMsgOK，而且不能是延时消息。此外，这一批消息的总大小不应超过4MB 发送批量消息 如果您每次只发送不超过4MB的消息，则很容易使用批处理，样例如下： String topic = "B ......
rabbitmq集群搭建-镜像模式
rabbitmq简介 RabbitMQ 采用 Erlang 语言开发，Erlang 语言由 Ericson 设计，Erlang 在分布式编程和故障恢复方面表现出色，电信领域被广泛使用。 Broker: 接收和分发消息的应用，RabbitMQ Server 就是Message Broker，一个Bro ......
RocketMq发送消息之延迟消息
延迟消息 比如电商里，提交了一个订单就可以发送一个延时消息，1h后去检查这个订单的状态，如果还是未付款就取消订单释放库存。 使用限制 对比于rabbitmq中的延迟消息来说，rockermq并不支持任意时间的延迟，需要设置几个固定的延时等级，从1s到2h分别对应着等级1到18级 // org/apa ......
RocketMQ发送消息之同步异步单向
官网教程：https://rocketmq.apache.org/zh/docs/quickStart/01quickstart 基于双主双从异步方式开启的前提下，在maven项目中引入下列依赖 <dependency> <groupId>org.apache.rocketmq</groupId> ......
elasticsearch 集群搭建
elasticsearch 集群搭建 elasticsearch.yml cluster.name: bigdata node.name: node-1 path.data: /usr/local/las/data/elasticsearch path.logs: /usr/local/las/lo ......
MySQL 双主集群搭建
MySQL 双主集群搭建 参考文档： 图文结合带你搞懂MySQL日志之relay log（中继日志） - GreatSQL - 博客园 (cnblogs.com) 一个月后，我们又从 MySQL 双主切换成了主 - 从！ (baidu.com) MySQL 简介 MySQL是一个关系型数据库管理系统 ......
docker-compose 部署 phpmyadmin
docker-compose.yaml version: '3.9' services: phpmyadmin: image: phpmyadmin container_name: phpmyadmin restart: always privileged: true environment: - ......
redis Cluster（主从集群）
redis Cluster（主从集群） Redis的主从同步机制 得分点 psync,全量复制、部分复制 标准回答 Redis主从同步是指任意数量的从节点（slave node）都可以从主节点上（master node）同步数据。而除了多个 slave 可以连接到同一个 master 之外,slav ......