back-pressure-Harries Blog™ | 追心中的海，逐世界的梦

聊聊MaxwellKafkaProducer

maxwell-1.25.1/src/main/java/com/zendesk/maxwell/producer/MaxwellKafkaProducer.java public class MaxwellKafkaProducer extends AbstractProducer { private final ArrayBlockingQueue<RowMap> queue;...

2020-05-03 浏览(579) 评论(0)

阅读全文

来，带你鸟瞰 Java 中的并发框架！

作者：唐尤华 https://dzone.com/articles/a-... 1. 为什么要写这篇文章几年前 NoSQL 开始流行的时候，像其他团队一样，我们的团队也热衷于令人兴奋的新东西，并且计划替换一个应用程序的数据库。但是，当深入实现细节时，我们想起了一位智者曾经说过的话：“细节决定成败”。最终我们意识到 NoSQL 不是解决所有问题的银弹，而 NoSQL vs R...

2020-04-27 浏览(568) 评论(0)

阅读全文

Reactive-MongoDB 异步 Java Driver 解读

一、关于异步驱动从3.0 版本开始，MongoDB 开始提供异步方式的驱动(Java Async Driver)，这为应用提供了一种更高性能的选择。但实质上，使用同步驱动(Java Sync Driver)的项目也不在少数，或许是因为先入为主的原因(同步Driver的文档说明更加的完善)，又或者是为了兼容旧的 MongoDB 版本。无论如何，由于 Reactive 的发展，未来...

2019-10-20 浏览(661) 评论(0)

阅读全文

一文彻底搞懂 Flink 网络流控与反压机制

分析一个简单的 Flink 流任务，下图是一个简单的Flink流任务执行图：任务首先从 Kafka 中读取数据、 map 算子对数据进行转换、keyBy 按照指定 key 对数据进行分区（相同 key 的数据经过 keyBy 后分到同一个 subtask 实例中），keyBy 后对数据接着进行 map 转换，然后使用 Sink 将数据输出到外部存储。众所周知，在大数据处理中，无论是...

2019-09-25 浏览(699) 评论(0)

阅读全文

1. 为什么要写这篇文章几年前 NoSQL 开始流行的时候，像其他团队一样，我们的团队也热衷于令人兴奋的新东西，并且计划替换一个应用程序的数据库。但是，当深入实现细节时，我们想起了一位智者曾经说过的话：“细节决定成败”。最终我们意识到 NoSQL 不是解决所有问题的银弹，而 NoSQL vs RDMS 的答案是：“视情况而定”。类似地，去年RxJava 和 Spring Reactor 这样...

2019-07-18 浏览(686) 评论(0)

阅读全文

来，带你鸟瞰 Java 中4款常用的并发框架！

1. 为什么要写这篇文章几年前 NoSQL 开始流行的时候，像其他团队一样，我们的团队也热衷于令人兴奋的新东西，并且计划替换一个应用程序的数据库。但是，当深入实现细节时，我们想起了一位智者曾经说过的话：“细节决定成败”。最终我们意识到 NoSQL 不是解决所有问题的银弹，而 NoSQL vs RDMS 的答案是：“视情况而定”。类似地，去年RxJava 和 Spring Reacto...

2019-03-21 浏览(765) 评论(0)

阅读全文

Spring

Spring Integration 5.0.0.M6发布

Spring Integration 的第六个里程碑版本 5.0 （5.0.0.M6）发布了。Spring Integration 能在基于 Spring 的应用中进行简单的消息通信，并通过简单的适配器与外部系统集成。这些适配器提供了一个更高级别的抽象，超越了 Spring 对远程调用、消息和调度的支持。其主要目标是在保持关注点分离的同时，为构建企业集成解决方案提供一个简单的模型，该模型对产出可维...

2017-07-26 浏览(1,075) 评论(0)

阅读全文

arXiv Paper Daily: Mon, 6 Feb 2017

Neural and Evolutionary Computing Robust Particle Swarm Optimizer based on Chemomimicry Casey Kneale , Karl S. Booksh Comments: To be revised for formatting and submitted as a Let...

2017-02-06 浏览(1,089) 评论(0)

阅读全文

Java 9为何让开发者如此兴奋，来看看它的这一基本功能

【51CTO.com快译】Java 9即将在2017年7月正式发布，并提供一份关于新增和修订的功能以及一些特性的说明清单。对JDK增强提议（简称JEP）进行搜索时，我们发现了JEP 266中包含了：对CompletableFuture进行了不少更新，和更新了并发功能和要支持Reactive Streams机制相关的内容，这引起了我的注意。在本文中，我们就聊聊JEP 266的新增和修...

2017-01-13 浏览(754) 评论(0)

阅读全文

Java 9的这一基本功能，你可能从未听过

2017年7月即将发布的Java 9将会新增和修订不少功能和特性。在搜索JDK增强提议（JEP）时发现，JEP 266对CompletableFuture进行了一些有趣的改进，更新并发功能和支持Reactive Streams。本文的焦点就是JEP 266的改进和一些有趣的特性，它极有可能成为Java 9中最常用的特性之一。 JEP 266改进计划 JEP 266是O...

2017-01-05 浏览(692) 评论(0)

阅读全文