副本 策略 消息kafka
dotnet core 3.1 将 UWP 控件嵌入到 WPF 应用 收到 UIA 消息主线程卡住
本文记录一个问题，此问题是在 .NET Core 3.1 的 WPF 应用里面，嵌入 UWP 控件之后，在收到 UIA 的消息时，可能让主线程卡住。暂时此问题还不知道具体的复现步骤，此问题不确定是否真的和 WPF 或 UWP 相关，此问题可能仅仅只是 UIA 模块的问题 此问题没有在 dotnet ......
php 小程序信息推送公众号消息模版
1.登录公众号，新建消息推送模版 2.打开微信官方文档 ->找到模版消息接口 https://developers.weixin.qq.com/doc/offiaccount/Message_Management/Template_Message_Interface.html 3. 代码 /** * ......
Kafka基础学习笔记
一、Kafka： 1、简介： Kafka是由Apache开源，具有分布式、分区的、多副本的、多订阅者，基于Zookeeper协调的分布式处理平台，由Scala和Java语言编写。最大的特性就是可以实时并高速的处理大量数据来满足需求，同时对消息数据进行持久化存储。 2、优点： Kafka与其他消息队列 ......
kafka代码实践
安装kafka： Windows安装kafka, 详情见：https://blog.csdn.net/sinat_32502451/article/details/133067851 Linux 安装kafka，详情见：https://blog.csdn.net/sinat_32502451/art ......
kafka代码示例
安装kafka： Windows安装kafka, 详情见：https://blog.csdn.net/sinat_32502451/article/details/133067851 Linux 安装kafka，详情见：https://blog.csdn.net/sinat_32502451/art ......
Angular 的版本升级策略
Angular 是一个流行的前端框架，它经常会发布新的版本来改进性能、增加新功能、修复漏洞和改进开发者体验。在这篇文章中，我将解释 Angular 版本升级的策略和升级周期，以及提供一些示例来说明这些概念。 Angular 版本升级策略 Angular 采用了一种半年度的版本发布策略，这意味着它每隔 ......
设计模式05:状态模式、策略模式、访问者模式、中介者模式
1.State状态模式 示例代码： package State13; /** * 状态模式 * 意图： 允许一个对象在其内部状态改变的时候改变它的行为。对象看起来似乎修改了它的类 * 适用于： * 一个对象的行为决定于它的状态，并且它需要在运行时刻根据状态改变它的行为 * */ public cla ......
redis过期删除策略和内存淘汰策略
过期删除策略 Redis 是可以对 key 设置过期时间的，因此需要有相应的机制将已过期的键值对删除，而做这个工作的就是过期键值删除策略。 如何设置过期时间？ 先说一下对 key 设置过期时间的命令。 设置 key 过期时间的命令一共有 4 个： expire <key> <n>：设置 key 在 ......
设计模式-策略模式
参考：https://blog.51cto.com/u_16125162/6329805 定义: 策略模式(StrategyPattern)：定义一系列算法，将每一个算法封装起来，并让它们可以相互替换。是一种对象行为型模式。 打个比方说，我们出门的时候会选择不同的出行方式，比如骑自行车、坐公交、坐火 ......
NetCore之基于Azure Service Bus的消息服务
什么是Azure服务总线？ Azure服务总线是完全托管的企业消息代理，包括消息队列和发布订阅(命名空间). Service Bus通常被用来解耦应用程序和服务，控制跨服务和应用程序间安全路由和传输数据。 本篇从实战出发介绍如何通过Service Bus发送接收及消费消息。 1、创建API.Azur ......
完美打通聚宽 joinquant 策略实盘，EasyTrader已经不能用了
思路就是： 1、通过winform 内置浏览器，实现自动登录，拿到登录的token 2、登录之后，往浏览器注入js, 每隔10秒去拿 https://www.joinquant.com/algorithm/live/transactionDetail 接口的数据 3、把数据保存到本地日志路径里面 4 ......
Kafka 在分布式系统中的 7 大应用场景
Kafka 介绍 Kafka 是一个开源的分布式流式平台，它可以处理大量的实时数据，并提供高吞吐量，低延迟，高可靠性和高可扩展性。Kafka 的核心组件包括生产者（Producer），消费者（Consumer），主题（Topic），分区（Partition），副本（Replica），日志（Log）， ......
MQTT——具有.NET Core的消息队列遥测传输协议
转自：https://blog.csdn.net/mzl87/article/details/109910991 目录 介绍 什么是MQTT REST是什么？ 体系结构 有效载荷 安全 代码样例 代理 发布者 订阅者 执行 概要 Git存储库链接 参考文献 介绍 发布/订阅模式是解耦软件的常见要求。 ......
K8s - 安装部署Kafka、Zookeeper集群教程（支持从K8s外部访问）
本文演示如何在K8s集群下部署Kafka集群，并且搭建后除了可以K8s内部访问Kafka服务，也支持从K8s集群外部访问Kafka服务。服务的集群部署通常有两种方式：一种是 StatefulSet，另一种是 Service&Deployment。本次我们使用 StatefulSet 方式搭建 Zoo ......
消息发送源码
SendResult sendResult = MQClientAPIImpl.this.processSendResponse(brokerName, msg, response); if (context != null && sendResult != null) { context.setS ......
kafka基于SCRAM认证，快速配置启用ACL
启动和停止服务 zookeeper /usr/local/apache-zookeeper-3.8.2-bin/bin/zkServer.sh start /usr/local/apache-zookeeper-3.8.2-bin/bin/zkServer.sh stop kafka /usr/lo ......
kafka-ACL
本文档时在centos7直接部署添加认证的kafka文件基础上，做下面的修改实现ACL访问控制topic 参考：https://www.seaxiang.com/blog/Qpsqii 一. 添加多个kafka用户及相关的配置文件 1.kafka_server_jaas.conf KafkaServ ......
helm部署kafka鉴权以及ACL
官方文档 https://github.com/bitnami/charts/tree/main/bitnami/kafka https://blog.csdn.net/u011618288/article/details/129105777 (包含zookeeper与broker认证、鉴权流程) ......
centos7直接部署添加认证的kafka
前言 测试服务器：10.255.60.149 一. 安装jdk 官网下载jdk1.8版本以上的 https://www.oracle.com/java/technologies/downloads/ 测试系统版本为centos7，选择了最后一个下载后，使用rpm -ivh即可安装 二. 安装zook ......
docker-compose部署SASL认证的kafka
前言 测试服务器：10.255.60.149 一. 编写docker-compose文件 1.docker-compose.yml version: '3.8' services: zookeeper: image: wurstmeister/zookeeper volumes: - /data/z ......
Kafka Server之kafka-consumer-groups.sh
消费者组查询 在 kafka server中查看有哪些消费者：./kafka-consumer-groups.sh --list --bootstrap-server localhost:9092 查询到有2个消费者组 消费者组描述 在 kafka server中查看指定消费者组信息：./kafka ......
【虹科干货】Redis 开发者需要了解的缓存驱逐策略
缓存驱逐是指从缓存中删除特定数据的过程。当缓存达到最大存储容量时，必须删除一些数据，为新数据腾出空间。本文将深入探讨与缓存驱逐有关的细节，并就如何选择合适的缓存驱逐策略给出建议。 ......
kafka：brokers are down
producer发布消息失败 由于使用脚本：./kafka-server-stop.sh and ./zookeeper-server-stop.sh 关闭kafka后，jps查询服务还在，就打算把重启系统。 重启后，往kafka上发布消息失败，报错代码：brokers are down 。 一顿操 ......
Chromium 消息循环和线程池详解
Chromium 中的多线程机制由 base 库提供，要理解 Chromium 中的多线程机制，首先要理解的概念就是 base::MessageLoop 和 base::TaskScheduler ，它们两个是 Chromium 多线程的基础 1. MessageLoop详解 base::Messa ......
R语言逻辑回归Logistic选股因素模型交易策略及沪深300指数实证|附代码数据
全文链接：http://tecdat.cn/?p=32071 原文出处：拓端数据部落公众号 最近我们被客户要求撰写关于交易策略的研究报告，包括一些图形和统计输出。 随着中国的证券市场规模的不断壮大、市场创新不断深化、信息披露不断完善、市场监管不断强化，随着现代投资组合理论的发展和计算机技术的进步，投 ......
版本偏差策略
前言 一个软件得到官方的支持是非常重要的，因为软件有bug、缺陷，只有官方人员的修复才最可靠。一旦说这个版本不被官方支持了，也就意味着有问题也不会修复了。 总结几个时间点 官方文档docs是能看到最近5个版本的文档，但是能看到文档不代表这5个版本都还被官方支持。 一个版本（例如1.28）从开始开发到 ......
MongoDB分片+副本集高可用集群的启停步骤
■■ 集群启动步骤 1、先启动各节点的 config server mongod -f ${MongoDir}/conf/config.conf 2、再启动各节点的 shard server mongod -f ${MongoDir}/conf/shard1.conf 3、再启动各节点的 mongo ......
内存中的消息队列-disruptor
一、介绍工作中遇到项目使用Disruptor做消息队列,对你没看错,不是Kafka,也不是rabbitmq;Disruptor有个最大的优点就是快,还有一点它是开源的。Disruptor 是英国外汇交易公司LMAX开发的一个高性能队列。 Disruptor是一个开源的Java框架，它被设计用于在生产 ......
添加Kafka的Ranger访问权限策略
原文链接：https://support.huaweicloud.com/intl/zh-cn/eu-west-0-cmpntguide-lts-mrs/mrs_01_1861.html 操作场景 Ranger管理员可通过Ranger为Kafka用户配置Kafka主题的读、写、管理权限以及集群的管理 ......