副本 策略 消息kafka
基于RiceQuant的期货多因子策略实现(一)
### 前言 基于多因子模型理论，介绍其在国内期货的应用，并使用米宽（RiceQuant）的RQFactor进行实现。 ### 理论基础 CAMP： 资产的预期超额收益由 市场组合的预期超额收益 与 资产对市场风险的暴露决定  ### 痛点背景 #### 业务场景 > 假设有这么一个需求，用户下单后如果30分钟未支付，则该订单需要被关闭。你会怎么做？ #### 之前方案 > **最简单的做法，可以服务端启动个定时器，隔个几秒扫描数据库中待支 ......
扩展SpringMVC框架的消息转化器
1、消息转化器 请求和响应都有对应的body，而这个body就是需要关注的主要数据。 请求体与请求的查询参数或者表单参数是不同的，请求体的表述一般就是一段字符串，而查询参数可以看作url的一部分，这两个是位于请求报文的不同地方。表单参数可以按照一定格式放在请求体中，也可以放在url上作为查询参数。总 ......
Feign和消息队列（MQ）的区别
Feign和消息队列（MQ）是两个不同的概念，它们分别用于不同的目的。下面我将分别介绍它们的作用和特点。 Feign是一个在微服务架构中用于实现服务间通信的轻量级、声明式的HTTP客户端。它由Netflix开源，并且与Spring Cloud集成得非常紧密。Feign可以让开发人员以类似于编写本地方 ......
马丁策略与硬币抛掷：一场数学和哲学的探索
在概率和统计的世界里，似乎每一个数字都有自己的故事，每一次尝试都探索着不确定性的边界。今天，我想与你分享一次我对“马丁策略”（Martingale Strategy）的探索之旅，这一旅程将带我们走过数学的原野，穿越哲学的迷雾。 #### **第一章：硬币的秘密** **1.1 对称与公平** 抛硬币 ......
【转载】八种生成学习策略
**本文发表于《数字教育》2016年第3期（总第9期）域外观察 栏目，页码：86-92.** 摘 要：生成学习意味着学习者会积极尝试去理解所呈现的材料内容。学习者会通过在学习时对所呈现材料进行相关部分的“选择”，在工作记忆中进行心理表征的“组织”，再将所组织的材料与长时记忆中激活的已有知识进行“整合 ......
复习消息队列之RabbitMQ
概念： RabbitMQ是使用Erlang语言开发的开源消息队列系统，基于AMQP协议来实现。 AMQP的主要特征是面向消息、队列、路由（包括点对点和发布/订阅）、可靠性、安全。 AMQP协议更多用在企业系统内对数据一致性、稳定性和可靠性要求很高的场景，对性能和吞吐量的要求还在其次。对比： Rabb ......
HarmonyOS系统级推送服务，打造消息通知新体验
8月4日，第五届华为开发者大会 2023(HDC.Together)再次启航。在本次大会上，华为为广大用户带来了HarmonyOS 4.0全新升级的体验，同时，针对HarmonyOS应用的开发，此次也全面升级了HarmonyOS SDK开放能力。[账号服务](https://developer.hu ......
mongodb副本集模式的单机修改ip(update方式)
环境:OS:Centos 7mongodb:4.4.22 1.停掉当前运行的mongodb/usr/local/services/mongodb/bin/mongo localhost:29001use admindb.shutdownServer() 2.网络层面修改ip地址[root@local ......
golang之操作kafka
安装第三方包: go get github.com/IBM/sarama 生产者实例: package main import ( "fmt" "github.com/IBM/sarama" ) func main() { //1.生产者配置 config := sarama.NewConfig() ......
mongodb副本集模式的单机部署+修改ip
环境:OS:Centos 7mongodb:4.4.22 1.解压[root@localhost soft]# tar -xvf mongodb-linux-x86_64-rhel70-4.4.22.tgz[root@localhost soft]# mv mongodb-linux-x86_64- ......
策略模式
策略模式（Strategy Pattern）是一种行为型设计模式，它允许在运行时根据不同的情况选择算法的行为。这意味着可以定义一系列算法，并能够在运行时根据需要动态切换使用的算法，而不需要更改使用算法的客户端代码。 策略模式在现实生活中的例子包括支付方式的选择（现金、信用卡、支付宝等），排序算法的选 ......
如何在风控引擎中快速增加策略
风控策略是由规则和模型组成的、用以实现风险控制目标的集合。模型与规则相辅相成，相互补充，在不同的业务阶段彼此的侧重点不同。新业务上线期，数据量不足，策略以规则为主；当业务运行一段时候后，数据有了一定积累，就可以构建专属模型，实现模型与规则的并驾齐驱。 风控策略包含的规则包含设备维度规则、行为数据规则 ......
C#股票策略一二
//information //Console.WriteLine("Hello, World!"); //double[] price = new double[] { 1.10, 1.12, 1.15, 1.16, 1.17, 1.18, 1.17, 1.15, 1.16, 1.17, 1.18 ......
Kafka数据对接
1、数据流向：被动接收数据 特点：及时性高，数据延迟小，Kafka的数据发送和接收都是毫秒级的。 2、接入参数 kafka: security.protocol: SSL ssl.endpoint.identification.algorithm: ssl: protocol: SSL key-st ......
kafka注解开发
代码 参数：实体id和支付方式 @KafkaListener(topics = {KafkaInitialConfig.TOPIC_REMOVE_BLACKLIST}, groupId = KafkaInitialConfig.GROUP_ID_STORE_BFF) public void remo ......
RocketMQ - 顺序消息/事务消息/延迟消息
顺序消息 生产端顺序生产 消费端顺序消费 一般都是局部顺序消息。生产端根据 shardingkey 对队列数量取模，把同一个 shardingkey 的消息发送到同一个队列 而消费端也要确保消费这个队列时是一个线程消费的 首先是 consumer 中注册的 Listener 来指定是顺序消息消费还是 ......
kafka启动报错Caused by: java.net.UnknownHostException: Cent65: Cent65: Name or service not known【原创】
故障描述： 上周云服务器重启了，上面的kafka再启动时就报错“Caused by: java.net.UnknownHostException: Cent65: Cent: Name or service not known” 而且看kafka-monitor，也不再群集里。 解决办法：在本机ho ......
kafka集群监控EFAK搭建
源码包准备 1.上传包 export KE_HOME=/home/secure/prom/kafka-eagle-bin-3.0.1/efak-web-3.0.1 export PATH=$PATH:$KE_HOME/bin source /etc/profile 2.安装mysql EFAK配置修 ......
C#程序的启动显示方案（无窗口进程发送消息） - 开源研究系列文章
今天继续研究C#的WinForm的实例显示效果。 我们上次介绍了Winform窗体的唯一实例运行代码（见博文：基于C#的应用程序单例唯一运行的完美解决方案 - 开源研究系列文章 ）。这就有一个问题，程序已经打开了，这时候再次运行该应用程序，我们的方案是将该应用的主窗体显示出来。这个在单例运行方案中已 ......
Windows11使用docker desktop安装kafka&zookeeper集群
# docker-compose安装zookeeper集群 参考文章：http://t.csdn.cn/TtTYI https://blog.csdn.net/u010416101/article/details/122803105?spm=1001.2014.3001.5501 准备工作： 在 ......
kafka 入门最佳实践
认识 kafka kafka简介 Kafka 是一个分布式流媒体平台，kafka官网：http://kafka.apache.org/ （1）流媒体平台有三个关键功能： 发布和订阅记录流，类似于消息队列或企业消息传递系统。 以容错的持久方式存储记录流。 记录发生时处理流。 （2）Kafka通常用于两 ......
Zookeeper 集群 + Kafka 集群
[toc] ## 一、Zookeeper 概述 ### 1. Zookeeper 定义 Zookeeper是一个开源的分布式的，为分布式框架提供协调服务的Apache项目 ### 2. Zookeeper 工作机制 Zookeeper从设计模式角度来理解： 是一个基于观察者模式设计的分布式服务管理框 ......
Kafka集群
Kafka集群使用消息队列，通过异步处理请求，从而缓解系统的压力。消息队列常应用于异步处理，流量削峰，应用解耦，消息通讯等场景。 目录 1.Kafka 概述 2.消息队列好处 3.消息队列的模式 4.Kafka 的特性 5.Kafka 系统架构 6.部署 kafka 集群 7.总结 1.Kafka ......
kafka_demo
参考： 概念：https://zhuanlan.zhihu.com/p/74063251 代码运用：https://zhuanlan.zhihu.com/p/114209326 参考 kafka 在windows 平台的搭建和简单实用_一代键客的博客-CSDN博客，先验证本地是否能使用kafka成功 ......
vue--day54--todolist 中的MyItem 和App 消息发布实现通信
1.App.vue <template> <div id="root"> <div class="todo-container"> <div class="todo-wrap"> <!-- @addTodo 事件名 addTodo 回调名--> <MyHeader @addTodo="addTodo ......
Mongodb主从复制/ 副本集/分片集群介绍
来源： https://cloud.tencent.com/developer/article/1026185 前面的文章介绍了Mongodb的安装使用，在 MongoDB 中,有两种数据冗余方式,一种 是 Master-Slave 模式（主从复制）,一种是 Replica Sets 模式（副本集） ......