java嵌入式持久化消息队列SMQ，改造自FQueue
一、说明 之前项目中一直使用ConcurrentLinkedQueue做为缓冲队列（主要是单个项目内，单条改批量的场景，多个项目间使用的是rocketmq），虽然用着方便但是是纯内存的， 如果项目发生异常崩溃内存队列中的数据就会全部丢失（只能从日志中恢复）。所以一直想找一个简单高效支持持久化的嵌入式 ...
kafka-消息中间键(springboot集成)
特性 追求高吞吐量，适合产生大量数据的互联网服务的数据收集业务 kafka入门 1.导入依赖 <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter ...
RabbitMQ消息队列入门及解决常见问题
RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面向消息的中间件）。RabbitMQ服务器是用Erlang语言编写的，而集群和故障转移是构建在开放电信平台框架上的。所有主要的编程语言均有与代理接口通讯的客户端库。 ...
react生命周期
总结-旧生命周期 初始化阶段: 由ReactDOM.render()触发 初次渲染 constructor() componentWillMount() render() componentDidMount() > 常用 一般在这个钩子中做一些初始化的事,例如:开启定时器,发送网络请求,订阅消息 更 ...
rust写一个im聊天服务
工作之余，想搞一些东西，于是写了这么一个服务。目标是做一个通用的聊天程序，包含群聊、单聊、群聊天增删成员这些必须功能，以及支持各种类型的聊天等。 后端使用 rust ，前端使用 react 这一套，ui 上做的比较简单，主要是验证一下后端能力，展示使用。 主要功能有：用户体系，聊天组，组成员和消息， ...
欠你们的 → k8s 集群搭建，除夕奉上！
开心一刻 有一天，qq收到一个好友申请，验证消息上写的是：哥哥加我，我是妹妹 我以为是性骚扰，就没加，直接回了一句：我喜欢少妇 过了一会儿，姑姑就给我打了个电话：你妹妹qq加你，你怎么不同意，她想问你几道数学题，你说你喜欢少妇 我：姑姑，你听我狡辩一下...... 祝大家除夕快乐！ 节点准备 基于 ...
RocketMQ消息短暂而又精彩的一生
大家好，我是三友~~ 这篇文章我准备来聊一聊RocketMQ消息的一生。 不知你是否跟我一样，在使用RocketMQ的时候也有很多的疑惑： 消息是如何发送的，队列是如何选择的？消息是如何存储的，是如何保证读写的高性能？RocketMQ是如何实现消息的快速查找的？RocketMQ是如何实现高可用的？消 ...
基于SpringBoot 使用 Flink 收发Kafka消息
前言 这周学习下Flink相关的知识，学习到一个读写Kafka消息的示例， 自己动手实践了一下，别人示例使用的是普通的Java Main方法，没有用到spring boot. 我们在实际工作中会使用spring boot。 因此我做了些加强， 把流程打通了，过程记录下来。 准备工作 首先我们通过do ...
SweetAlert让消息弹出窗口更加具有个性化！
SweetAlert SweetAlert是指可对JavaScript标准功能alert()和confirm()进行个性化定制的库。 SweetAlert的要点 官网上有很多示例，看了这些基本上就OK了。但是，在低代码平台kintone上使用时，【弹出消息后更新页面】这个处理只参照示例来写的话，一开 ...
JAVA微信公众号订阅消息推送
1、前期准备 1.申请微信公众号测试号及微信模板配置 2.申请一个微信公众号测试号。测试号申请：https://mp.weixin.qq.com/debug/cgi-bin/sandbox?t=sandbox/login 3.扫码登陆注册，注册成功后就会生成微信公号的appID和appsecret ...
阅读理解和作文差的解决办法
很多学生的语文成绩不好，都是因为阅读理解和作文差。其实这两者之间是有很大的联系的，要想写出好作文，就需要通过阅读去积累。因此阅读理解差的话，作文也不会太好，针对这种情况的解决办法是...
#Python #微信 #消息防撤回 Python实现微信防撤回
微信（WeChat）是腾讯公司于2011年1月21日推出的一款社交软件，8年时间微信做到日活10亿，日消息量450亿。在此期间微信也推出了不少的功能如：“摇一摇”、“漂流瓶”、“朋友圈”、“附近的人”、“公众平台”、“小程序”等等，涵盖了我们生活的方方面面，微信正在慢慢践行着他们的口号：微信，是一种 ...