消息 拷贝 状态kafka
ceph集群状态 pgs not scrubbed in time
检查集群状态 ``` # ceph -s cluster: id: 83738b81-56e4-4d34-bdc2-3a60d789d224 health: HEALTH_WARN 75 pgs not scrubbed in time services: mon: 3 daemons, quoru ......
kafka安装部署与使用
##前言 ###1.kafka简介 Kafka是一个开源的分布式消息引擎/消息中间件，同时Kafka也是一个流处理平台。Kakfa支持以发布/订阅的方式在应用间传递消息，同时并基于消息功能添加了Kafka Connect、Kafka Streams以支持连接其他系统的数据(Elasticsearch ......
Kafka-基础
## 1. 简介 **Kafka（Apache Kafka）** 是一种分布式流数据平台，最初由LinkedIn开发，并于后来捐赠给Apache软件基金会，成为了一个Apache顶级项目。它被设计用于处理大规模、实时的数据流，并为构建高吞吐量、容错性强的数据流应用程序提供支持。Kafka的特点使得它 ......
零拷贝
小林coding《什么是零拷贝》笔记 参考： The Linux Kernel Linux ：Concepts overview 兰新宇 : Linux中的mmap映射 [一] ALEX XU 徐旭 ：Why is Kafka fast? 每个存储器只和相邻的一层存储器设备打交道，并且存储设备为了追 ......
使用JSON.parseObject深拷贝
public void copy(){ EtcCardApplyOrderDto dto1 = new EtcCardApplyOrderDto(); EtcObuOrderDataDto etcObuOrderDataDto1 = new EtcObuOrderDataDto(); etcObuO ......
车间设备互联，实现设备状态的可视化，就是打造工厂的数字化基因，是企业实现数字化、智能化转型升级的基础
车间设备互联，实现设备状态的可视化，就是打造工厂的数字化基因，是企业实现数字化、智能化转型升级的基础 ......
动态规划状态转移方程
【技术积累】算法中的动态规划【一】 合集 - 【技术积累】数据结构和算法(11) 1.【技术积累】数据结构中的基本概念【一】06-212.【技术积累】算法中的基本概念【一】06-213.【技术积累】数据结构中栈与队列及其相关算法【一】07-094.【技术积累】数据结构中的二叉树及其相关算法【一】06 ......
c# 使用webhook推送消息给钉钉机器人
c# 使用webhook推送消息给钉钉机器人 2023-08-04 08:31·opendotnet 在项目中将某个操作后的数据Webhook 发送给钉钉机器人。 Webhook 是一个 API 概念，是微服务 API 的使用范式之一，也被成为反向 API，即前端不主动发送请求，完全由后端推送；举个 ......
使用SpringBootAdmin监控项目基本状态
一、概述 当项目上线以后，开发/运维人员想要快速了解项目运行的健康状态。此时要怎么办，可以敲命令行查看服务器以及项目状态，单这样做太过于繁琐，且不够一目了然。有没有好心人帮我们把这块简化并且有可视化界面呢。答案当然是肯定的。那就是社区给出的开源插件SpringBootAdmin。非常简单，只需要两三 ......
【Kafka3.0】消费者Consumer
[toc] ## kafak消费者 ### 消费者总体工作流程 - **kafka消费方式：**consumer采用从broker中主动拉取的方式去消费数据（pull）。为什么不是broker主动推送呢（push），是因为由broker决定发送速率很难适应所有消费者。pull模式的缺点是kafka没 ......
【kafka3.0】生产者producer
[toc] ## kafka生产者 ### 生产者消息发送流程 #### 发送原理 在消息发送的过程中，涉及到了两个线程——main 线程和 Sender 线程。在 main 线程中创建了一个双端队列 RecordAccumulator。main 线程将消息发送给 RecordAccumulat ......
键盘LED灯的状态
不适用ioctl()从内核中获取Led灯的状态时，可以试下使用以下方式： 步骤： 1. cd /sys/class/leds/ 进去此目录下看是否有灯的对应的文件夹，例如input4::numlock(这个是我自己的调试设备中系统生成的文件夹)， 存在则表示键盘已经接入，不存在则键盘没插入; 2. ......
钉钉消息已读、未读咋实现的嘞？
## 前言 一款app，消息页面有：钱包通知、最近访客等各种通知类别，每个类别可能有新的通知消息，实现已读、未读功能，包括多少个未读，这个是怎么实现的呢？比如用户A访问了用户B的主页，难道用rabitmq给B发通知消息吗？量大了成本受得了吗？有没有成本低的方案呢  # 背景 为了让业务团队可以更好的跟踪自己消息的生产和消费状态，需要一个类似于表格视图的消息列表，用户可以直观的看到发送的消息；同时点击详情后也能查到消息的整个 ......
【Apollo】【三】发布配置的过程-变更配置消息的发送与消费
1 前言 上节我们看了下发布配置的 Portal 以及 Admin Service的变化过程，我们看到Admin Service 的 messageSender.sendMessage()，发送消息以及消费消息，那么这节我们继续看。 2 MessageSender 发送消息 2.1 ReleaseM ......
MySQL 使用Navicat delete/insert into/update 大量数据表锁死，kill的线程后线程处于killed状态问题解决
MySQL 使用delete/insert into/update 大量数据表锁死，kill的线程后线程处于killed状态问题解决 实际生产环境问题描述： 使用Navicat备份BigData数据表时不小心点到了取消按钮，导致数据表被锁。 查看MySQL线程队列，找到刚刚执行的SQL看是属于什么状 ......
【Kafka3.0】broker、producer、consumer详解
# kafka3.0 [toc] ## 1. 什么是kafka？ - Kafka传 统定义：Kafka是一个分布式的基于发布/订阅模式的消息队列（MessageQueue），主要应用于大数据实时处理领域。 - Kafka最 新定义 ： Kafka是 一个开源的 分布式事件流平台 （Event Str ......
问题，Netty 程序发现大量 TCPV6 及 CLOSE_WAIT 状态连接
问题，Netty 程序发现大量 TCPV6 及 CLOSE_WAIT 状态连接? 1. ps -ef | grep "程序名" ,找到程序进程Id 2.lsof -Ki -p 进程号 | grep tcpv6|wc -l ,找到异常的连接清单 异常问题如何处理? Netty 程序发现大量 TCPV6 ......
C#中的浅拷贝与深拷贝
## 前言 众所周知，C#中有两种类型变量：那就是**值类型**和**引用类型**。对于值类型而言，copy就相当于是全盘复制了，真正的实现了复制，属于**深拷贝**；而对于引用类型而言，一般的copy只是**浅拷贝**，只是copy到了引用对象的地址，相当于值传递了一个引用指针，==新的对象通过地 ......
30s无痛进入状态
来源：[让状态切换和喝水一样简单，30s停止胡思乱想](https://www.bilibili.com/video/BV1NN411z7id/?spm_id_from=333.1007.top_right_bar_window_view_later.content.click&vd_source= ......
linux服务器TCP端口连接状态统计netstat命令
一、查看哪些IP连接本机 netstat -an 二、查看TCP连接数 1）统计80端口连接数 netstat -nat | grep -i "80" | wc -l 2）统计httpd协议连接数 ps -ef | grep httpd | wc -l 3）统计已连接上的，状态为“establish ......
StatefulWidget StatelessWidget 有状态 无状态
StatefulWidget class - widgets library - Dart API https://api.flutter.dev/flutter/widgets/StatefulWidget-class.html StatelessWidget class - widgets li ......
消息推送 架构设计
文章很长，且持续更新，建议收藏起来，慢慢读！[**疯狂创客圈总目录 博客园版**](https://www.cnblogs.com/crazymakercircle/p/9904544.html) 为您奉上珍贵的学习资源 ： 免费赠送 :[**《尼恩Java面试宝典》**](https://www. ......
kafka安装以及参数
kafka 安装 安装JDK yum install -y java-1.8.0-openjdk.x86_64 查看版本 java -version kafka是分布式的，需要多台机器，并且保证机器之间是免密登录同时需要用zookeeper集群负责管理。 1、kafka版本选择，从官网下载即可，我这 ......
Kafka在企业级应用中的实践
前言 前面说了很多Kafka的性能优点，有些童鞋要说了，这Kafka在企业开发或者企业级应用中要怎么用呢？今天咱们就来简单探究一下。 1、 使用 Kafka 进行消息的异步处理 Kafka 提供了一个可靠的消息传递机制，使得企业能够将不同组件之间的通信解耦，实现高效的异步处理。在企业级应用中，可以通 ......
kafka经验
使用kafka经验 前言 本篇文章主要介绍的关于本人从刚工作到现在使用kafka的经验，内容非常多，包含了kafka的常用命令，在生产环境中遇到的一些场景处理，kafka的一些web工具推荐等等。由于kafka这块的记录以及经验是从我刚开始使用kafka，从2017年开始，可能里面有些内容过时，请见 ......