搜索结果
查询Tags标签: 消息,共有 735条记录-
Kafka多线程开发消费者实例
Kafka consumer是单线程的设计,这个其实不准确,从 Kafka 0.10.1.0 版本开始,KafkaConsumer 就变为了双线程的设计,即用户主线程和心跳线程。 所谓用户主线程,就是你启动 Consumer 应用程序 main 方法的那个线程,而新引入的心跳线程(Heartbeat Thread)只负责定期给…
2022/4/16 23:17:31 人评论 次浏览 -
如何让Kafak尽可能不丢失消息
Kafka 只对“已提交”的消息(committed message)做有限度的持久化保证 已提交,commit,若干个(可用配置设置) Broker 成功地接收到一条消息并写入到日志文件后,它们会告诉生产者程序这条消息已成功提交。 有限度,假如你的消息保存在 N 个 Kafka Broker 上,那么这个…
2022/4/10 6:15:31 人评论 次浏览 -
Kafka 生产消息降低网络io
一、Kafka消息 Kafka消息分为两层:消息集合(message set)以及消息(message) 一个消息集合中包含若干条日志项(record item),而日志项才是真正封装消息的地方。Kafka 底层的消息日志由一系列消息集合日志项组成。Kafka 通常不会直接操作具体的一条条消息,它总是在…
2022/4/10 6:15:28 人评论 次浏览 -
消息推送
HT Android推送用户A,向用户B发送消息,“你好”,后台首先判断用户B的在线状态; 如果在线,就走app内协议,比如HT聊天服务用的是websocket协议。 如果不在线,就走推送通道。后台取出用户B登录的时候向后台发送的token值,判断推送需要走哪个渠道,比如vivo,oppo等,…
2022/4/9 6:22:15 人评论 次浏览 -
如何基于 ZEGO SDK 实现 Web 基本消息收发
即时通讯(Instant Messaging)是一种基于互联网的即时交流消息的业务。 实时聊天交互功能是市面上主流APP的重要功能之一,人们所熟悉的就是微信,QQ的聊天消息系统,IM看似简单,技术开发绝非易事,海量并发,超低延时,消息必达等高实时性需求需要众多技术的应用合体;…
2022/4/9 6:19:28 人评论 次浏览 -
Xshell7远程连接Linux服务器
开始连接之前记得去开启22端口 一、进行新建二、配置连接信息主机地址一般会在购买云服务器时发一条消息给你,或者去服务器提供商的控制台查看你购买的主机IP用户名同样去消息里查看,一般会给一个默认的用户名,密码有的会在消息里给出初始密码,有的要去控制台设置
2022/4/7 7:24:02 人评论 次浏览 -
深入理解Kafka核心设计及原理(二):生产者
转载请注明出处: 2.1Kafka生产者客户端架构2.2 Kafka 进行消息生产发送代码示例及ProducerRecord对象kafka进行消息生产发送代码示例:public class KafkaProducerAnalysis {public static final String brokerList = "localhost:9092";public static final St…
2022/4/7 6:25:29 人评论 次浏览 -
你好RabbitMQ消息队列
消息队列 RabbitMQ是一个消息队列,它能够接收和转发消息。这个过程就像寄快递一样,把物件打包给快递小哥,快递小哥会负责把物件派送到正确的地址。 生产者和消费者 生产者就是用来生产消息(发送消息)的:消费者就是用来消费消息(接收消息)的:在生产者和消费者之间…
2022/3/30 23:20:01 人评论 次浏览 -
SpringCloud Stream消息驱动组件
一、Stream解决的痛点问题Spring Cloud Stream 消息驱动组件帮助我们更快速,更方便,更友好的去构建消息 驱动微服务的 MQ消息中间件广泛应用在应用解耦合、异步消息处理、流量削峰等场景中 不同的MQ消息中间件内部机制包括使用方式都会有所不同,比如RabbitMQ中有 Excha…
2022/3/25 6:22:48 人评论 次浏览 -
微服务架构系列主题:springboot 项目使用 Disruptor 做内部消息队列
本文转自:芋道源码目录 01、背景 02、Disruptor介绍 03、Disruptor 的核心概念 04、Ring Buffer 05、Sequence Disruptor 06、Sequencer 07、Sequence Barrier 08、Wait Strategy 09、Event 10、EventProcessor 11、EventHandler 12、Producer 13、案例-demo 14、总结工作…
2022/3/21 23:28:28 人评论 次浏览 -
RocketMQ 延迟消息(定时消息)4.9.3 版本优化 异步投递支持
1. 概述 在 RocketMQ 4.9.3 版本中,@Git-Yang 对延迟消息做了很大的优化,大幅度提升了延迟消息的性能。 其中,PR#3287 将原先用来启动周期性任务的 Timer 改为使用 ScheduledExecutorService,将多延迟等级下同时发送延迟消息的性能提升了 3+ 倍。 本文主要讲解的是另一…
2022/3/21 6:29:37 人评论 次浏览 -
Kafka v2.3 快速入门与实践
消息队列应用场景:应用解耦、异步消息、流量削峰等问题,实现高性能、高可用、可伸缩和最终一致性架构。 Kafka是由LinkedIn开发的一个分布式的消息系统,可独立部署在单台服务器上,也可部署在多台服务器上构成集群。它提供了发布与订阅功能。用户可以发送数据到Kafka集…
2022/3/18 23:29:35 人评论 次浏览 -
Windows消息钩取
1.消息钩子 简单理解:在消息从OS移动到应用程序的时候,我们利用消息钩子在此期间偷看这些信息 钩链:多个相同的消息钩子,按照设置顺序依次调用这些钩子,组成的链条就被称为钩链消息钩子实现的API:SetwindowsHookEx() HHOOK SetWindowsHookEx(int idHook, …
2022/3/12 7:17:45 人评论 次浏览 -
消息队列的常见问题及解决
消息队列优势 消息队列(Message Queue,简称MQ),其主要用于在复杂的微服务系统中进行消息通信,它的优点可以大致整理成以下几点:服务间解耦 提高服务并发、性能 突发流量削峰 ...服务间解耦 微服务系统业务之间相互依赖,各种调用错综复杂,如果不能良好对服务进行解…
2022/3/7 23:18:47 人评论 次浏览 -
RabbitMQ
RabbitMQ 入门RabbitMQ 是由erlang语言开发,基于AMQP(Advanced Message Queue 高级消息队列协议)协议实现的消息队列,它是一种应用程序之间的通信方法,消息队列在分布式系统开发中应用非常广泛。RabbitMQ官方地址:http://www.rabbitmq.com概述 在介绍RabbitMQ之前,…
2022/3/5 23:20:52 人评论 次浏览