中间件集群协议msgpack /// <author>cxg 2020-8-5</author> /// 集群协议 /// broker：代理服务器 unit groupProtocol; interface uses SysUtils, MsgPack ,classes ; const //命令字 ...
分类：
其他好文 时间：
2020-08-05 16:53:29
阅读次数：
75
1.文件目录布局 Kafka消息以日志文件的形式存储，不同主题下不同分区的消息分开存储，同一个分区的不同副本分布在不同的broker上存储 逻辑上看来日志是以副本为单位的，每个副本对应一个log对象，实际在物理上，一个log划分为多个logSegment 创建一个topic为3个分区，会在log.d ...
分类：
其他好文 时间：
2020-08-05 00:12:43
阅读次数：
100
一次机房停电引发的思考今天早上到公司的时候，接到开发反馈DEV环境所有接口都卡，耗时都在一分钟以上，严重影响开发正常工作，然后通过网关的日志定位到原因是因为kafka集群不可用（总共3个broker，前一天晚上机房停电导致leader节点挂了），导致网关的反爬过滤器里面发送kafka消息的代码kafkaTemplat.send阻塞了60s，当时在想这个send方法不是异步的吗，为什么会阻塞60s？
分类：
其他好文 时间：
2020-07-31 01:13:59
阅读次数：
93
11G DG ORA-00600: internal error code, arguments: [kdsgrp1] 备库 Thu Feb 14 09:00:32 2019Errors in file /u01/app/oracle/diag/rdbms/trstdb/trstdb/trace/t ...
分类：
其他好文 时间：
2020-07-29 15:09:55
阅读次数：
78
基于分布式异步框架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
一、创建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
一.消息的可靠投递 在使用RabbitMq的时候，作为消息发送方希望杜绝任何消息丢失或者投递失败的场景。RabbitMQ为我们提供了两种方式用来控制消息的投递可靠性 rabbitMQ 整个消息投递过程为： producer -> rabbitMQ broker -> exchange -> queu ...
分类：
其他好文 时间：
2020-07-27 17:53:27
阅读次数：
116
1.主库 [oracle@xag1124a ~]$ sqlplus / as sysdba SQL> select protection_mode,protection_level,log_mode,open_mode,flashback_on from v$database; PROTECTION ...
分类：
数据库 时间：
2020-07-25 23:57:18
阅读次数：
177
1、任务（tasks）–用户定义的函数，用于实现用户的功能，比如执行一个耗时很长的任务 2、中间介（Broker）–用于存放tasks的地方，但是这个中间介需要解决一个问题，就是可能需要存放非常非常多的tasks，而且要保证Worker能够从这里拿取 3、执行者（Worker）–用于执行tasks， ...
分类：
其他好文 时间：
2020-07-23 15:52:53
阅读次数：
69
DG管理和维护 DG管理和维护1.DG角色在线转换1.1 角色（主备）1.2 角色切换（主备切换）2.切换前准备2.1 确定主备相关参数：2.1.1 查看主库角色和保护模式及级别2.1.2 通过参数查看主库对应的备库信息2.1.3 查看主库对应的convert参数2.1.4 查看主库归档位置以及对应... ...
分类：
其他好文 时间：
2020-07-22 16:22:10
阅读次数：
102
