机制 消息
7.Kafka，构建TB级异步消息系统
1.阻塞队列 BlockingQueue 解决线程通信的问题。 阻塞方法：put、take。 生产者消费者模式 生产者：产生数据的线程。 消费者：使用数据的线程。 实现类 ArrayBlockingQueue LinkedBlockingQueue PriorityBlockingQueue、Syn ......
spring-retry 重试机制
引用pom.xml <dependency> <groupId>org.springframework.retry</groupId> <artifactId>spring-retry</artifactId> <version>1.3.4</version> </dependency> 注：本人测 ......
垃圾回收机制
垃圾回收机制（GC) 垃圾回收机制（简称GC）是Python解释器自带的一种机制 专门用来回收不可用的变量值所占用的内存空间（在内存中，没有变量名指向的数据都是垃圾数据） （1）引用计数 name = 'dhy' # 'dhy' 的 引用计数就是 1 a = name # 'dhy' 的 引用计数就 ......
js的运行机制
1.单线程 js是单线程的，一个任务执行完才会执行下一个任务 for (let i = 0; i < 2000; i++) { console.log(1); } setTimeout(() => { console.log(2); }, 0); setTimeout(() => { console ......
基于源码去理解Iterator迭代器的Fail-Fast与Fail-Safe机制
原创/朱季谦 在Java编程当中，Iterator迭代器是一种用于遍历如List、Set、Map等集合的工具。这类集合部分存在线程安全的问题，例如ArrayList，若在多线程环境下，迭代遍历过程中存在其他线程对这类集合进行修改的话，就可能导致不一致或者修改异常问题，因此，针对这种情况，迭代器提供了 ......
如何封装一个通用的kafka消息中间件模块？
在微服务中, 服务和服务之间往往通过消息中间件来进行业务交流。如果每个服务都需要自己再去编写一套消费业务消息或者发送业务消息的代码，每个模块都会出现许多重复的代码，所以可以把和kafka相关的代码，集成到一个基础模块之中，去形成整洁的代码架构。 下面的图片是一个模块划分示例。 为什么进行精细化的模块 ......
【golang】怎么在Go语言中实现锁机制
Go语言的锁 在Go语言中，最常用的锁是互斥锁（Mutex）。互斥锁是一种特殊的二进制信号量，用于控制对共享资源的访问。Go语言通过标准库中的"sync"包提供了互斥锁的功能。互斥锁的类型定义如下： type Mutex struct { state int32 sema uint32 } 其中st ......
[手机端RPA]监听闲鱼消息，实现秒回客户，不怕错过任何消息
你好，我是盆子，00年的国企程序员。目前正在探索各种副业，分享互联网一些有意思的东西，微信 pzistart1。 文末有总结。 前言 最近一个月在弄闲鱼无货源的项目，遵循着一机一卡一号的原则，手机从 1 台也变成了 3 台。 频繁的切换手机看闲鱼 app，看有没有客户发来咨询，是一件十分很繁琐的事情 ......
公众号发送模板消息案例
后台代码 //注意公众号的openid和小程序的 openid不是同一个 $this->sendmuban($openid); public function sendmuban($openid){ // 公众号的 $appId = '**************'; $appSecret = '* ......
小程序发送订阅消息（前后端）
uniapp代码 uni.requestSubscribeMessage({ tmplIds: ['*****你的订阅消息模板ID1****', '******你的订阅消息模板ID2****' ], success(res) { if (res['******你的订阅消息模板ID1****'] 'a ......
Python消息队列之Huey
缘起: 之前在Python中使用最多的就是Celery, 同样的在这次项目中使用了Celery+eventlet的方式,但是由于具体执行的逻辑是使用的异步编写的, 当时就出现了一个问题,当使用httpx的AsyncClient发送一个网络请求的时候, 发生了阻塞, 导致整个程序无法完整执行. 于是就 ......
ubuntu20.04模板机制作
VMware安装ubuntu20.04 镜像下载：https://releases.ubuntu.com/focal/ubuntu-20.04.6-live-server-amd64.iso 创建虚拟机 执行安装过程 选择系统语言 继续而不更新 配置键盘布局 配置网络连接 根据实际情况配置网络参数， ......
消息队列RabbitMQ之防止消息丢失
大家好，我是joker，希望你快乐。 消息队列组成 使用消息队列会有三部分：消息生产者，消息队列，消息消费者，接下来说下各部分防止消息丢失的方法。 生产者 消息生产者发送消息失败。发布确认机制，RabbitMQ会返回一个ACK标识。 消费者 消息消费者获取消息后，消费失败。开启手动确认的方式，消息成 ......
消息队列RabbitMQ简介
大家好，我是joker，希望你快乐。 RabbitMQ是什么 RabbitMQ是基于AMQP(Advanced Message Queue Protocol)高级消息队列协议实现的一种消息队列。 重要组件 Exchange: message 到达MQ的第一站，根据分发规则，配查询表中的 routin ......
2、jvm虚拟机垃圾回收机制
一、首先了解一下堆栈内存 1、jvm内存结构 从上图可以看出，整个JVM内存是由栈内存、堆内存和永久代构成。 年轻代（New generation） = eden + s0 + s1堆内存 = 年轻代 + 老年代（Old generation）JDK1.8以前： JVM内存 = 栈内存 + 堆内存 ......
安防LiteCVR监控视频云平台支持按时间查询告警列表消息
智慧安防平台LiteCVR平台采用了开放式的网络结构，平台能在局域网、公网、专网等复杂的网络环境中，将场景中分散的海量网络监控设备进行统一接入与汇聚管理。 ......
分享两种Pulsar消息积压topic级别策略老化办法
本文分享自华为云社区《Pulsar消息积压topic级别策略老化的两种方案》，作者： 张俭。 Pulsar像大多数消息中间件一样,支持按时间和大小对消息积压进行老化。但是默认的策略只能在namespace级别配置。本文将介绍如何在topic级别实现老化策略的两种方案。 方案一：开启 TopicLev ......
垃圾回收机制
一般说来，我们要解决三个问题： 1、回收哪些内存？ 2、什么时候回收？ 3、如何回收？ 首先我们来看Java的四种引用类型： 强引用：代码中普遍存在的，只要强引用还存在，垃圾收集器就不会回收掉被引用的对象。 软引用：SoftReference，软引用是介于强引用和弱引用之间的引用类型。当系统内存不足 ......
云服务器比传统服务器更安全的原因与实现机制
随着互联网的普及和云计算技术的发展，越来越多的企业和组织选择使用云服务器来提供和存储数据。与传统服务器相比，云服务器在安全性方面具有诸多优势。本文将围绕云服务器比传统服务器更安全的原因，探讨其实现机制。 ......
Chrome扩展程序是如何进行消息传递的
一个复杂的 Chrome 扩展程序通常由 `content_scripts`，`background`，`action popup`，`side panel`，`options page`，`devtools` 等部分组成，这些部分所负责的功能各不相同，所处的运行环境各不相同，所能访问的 `chro... ......
flutter 桌面通知 气泡消息数量
先上效果 原理 Android 操作系统提供的 NotificationManager 接口来设置应用程序图标上的徽章 iOS 操作系统提供的 UIApplication.shared.applicationIconBadgeNumber 使用flutter flutter pub add flut ......
cgo 机制
Go语言是通过自带的一个叫CGO的工具来支持C语言函数调用，同时我们可以用Go语言导出C动态库接口给其它语言使用。 基于 C 标准库实现最简单的 CGO 程序 // hello.go package main //#include <stdio.h> import "C" func main() { ......
jdk和dubbo的SPI机制
jdk和dubbo的SPI机制 转载自：https://www.cnblogs.com/wyq178/p/12171881.html 前言：开闭原则一直是软件开发领域中所追求的,开闭原则中的"开"是指对于组件功能的扩展是开放的,是允许对其进行功能扩展的,“闭”,是指对于原有代码的修改是封闭的,即不应 ......
linux修改内核参数禁止OOM机制
Linux内核有个机制叫OOM killer（Out-Of-Memory killer），该机制会监控那些占用内存过大，尤其是瞬间很快消耗大量内存的进程，为了防止内存耗尽,内核会把该进程杀掉，监控是正常的。 防止重要的系统进程触发(OOM)机制而被杀死：可以设置参数/proc/PID/oom_adj ......
Apache RocketMQ，构建云原生统一消息引擎
在云计算和开源双轮驱动下，RocketMQ 在阿里外部完成全面规模化，帮助千行百业完成数字化转型，产品能力也得到进一步的飞跃。2022 年 5.0 正式发布，Apache RocketMQ 正式迈进云原生时代。 ......
Eureka Server 自我保护机制
https://blog.csdn.net/u012410733/article/details/112303048 下面是官方提供的 Eureka 架构图： 1、什么是自我保护机制默认情况下，如果Eureka Server在一定时间内（默认 90 秒，其实不止 90 秒）没有接收到某个微服务实例的 ......
centos6和7的模板机制作
centos6（安装操作系统直接最小化安装就行） 1.进入网卡配置文件将网卡的MAC和UUID删除（网卡需要开机自启的话，只要把ONBOOT=no改为ONBOOT=yes就行） 2.挂在光盘，临时挂在 3.制作yum源 yum clean all #清楚yum源的缓存 yum makecache # ......
RabbitMQ中消息发布与权衡
1. 原生Java客户端进行消息通信 客户端需要amqp-client-5.0.0.jar和slf4j-api-1.6.1.jar 建议使用Maven: <dependency> <groupId>com.rabbitmq</groupId> <artifactId>amqp-client</art ......
自定义消息转换器对请求报文的统一解密处理
1.自定义拦截器Interceptor package com.example.springbootdemo.config; import lombok.extern.slf4j.Slf4j; import org.springframework.web.servlet.HandlerInterce ......