最新 最热

腾讯宣布开源 RoP:Apache Pulsar 支持原生 RocketMQ 协议

导读 RocketMQ 用户可以无缝迁移到 Apache Pulsar 了。自此,Apache Pulsar 补齐了兼容主流消息队列协议的能力。 我们很高兴地宣布腾讯云中间件开源 RoP!RoP 将 RocketMQ 协议处理插件引入 Pulsar broker,这样 Pulsar 就...

2021-05-21
0

3、深潜 kafka producer —— 核心架构

kafka 自定义了一套网络协议,我们可以使用任意语言来实现这套协议,实现向 kafka 集群 push message 以及从 kafka 集群 pull message 的效果。在 kafka 2.8.0 版本的源码中的 clients 模块就是官方默认提供的 Java 版本...

2021-05-19
1

高并发系列:架构优化之从BAT实际案例看消息中间件的妙用

说到Java中的队列应该都不会陌生。其具有通过先进先出,或者双端进出的方式进行数据管理;通过阻塞以达到自动平衡负载的功能。

2021-05-17
0

高并发消息队列补充篇:在所依赖存储不授信的场景下实现柔性事务降级

在大厂和小厂做研发到底有啥不一样?其他好的坏的方方面面没法细说,咱主要还得说技术方面。

2021-05-17
0

python大型项目后台异步这一篇就够了

点击python编程从入门到实践,置顶 公众号重磅 python入门资料,第一时间送达

2021-05-17
0

一文快速了解Kafka

初学Kafka,肯定会被各种概念搞得很头疼,所以整理下Kafka进阶学习必须要了解的概念。

2021-05-17
0

Java面试——多线程

【1】join 让主线程等待子线程运行结束后再继续运行:join方法中如果传入参数,则表示这样的意思:如果线程A 中掉用线程B的 join(10),则表示线程A 会等待线程B 执行10毫秒,10毫秒过后,A、B线程并行执行。需要注意的是,jdk规定,j...

2021-05-14
0

可靠消息最终一致性【本地消息表、RocketMQ 事务消息方案】

可靠消息最终一致性方案是指当事务发起方执行完成本地事务后并发出一条消息,事务参与方(消息消费者)一定能够接收消息并处理事务成功,此方案强调的是只要消息发给事务参与方最终事务要达到一致。 此方案是利用消息中间...

2021-05-14
0

哇咔咔干货来啦!PowerJob 原理剖析之 Akka Toolkit

上面这段文字摘抄自 Akka 官网(akka.io),翻译成中文也就是:“Akka 是一个为 Java 和 Scala 构建高并发、分布式和弹性消息驱动应用程序的工具包”。而 Akka 具有的一切特性,其实都源自于一个用于处理并发计算问题的模型—...

2021-05-14
1

数栈产品分享:Kafka—实时离不开的那个TA

随着技术不断的成熟及市场需求的日益旺盛,实时开发已经成为当前大数据开发不可或缺的一部分。在整个实时开发的链路中,数据采集需要写入到Kafka,数据处理也需要使用到Kafka。今天我们就针对Kafka这个时下主流的消息中间...

2021-05-14
1