buffer-slayer 是一个把请求在内存中 buffer 并批量发送的工具，适用于批量能显著提升性能的组件（redis-client、jdbc), 支持一对一的回调。
快速启动
io.bufferslayer
buffer-spring-jdbc
1.1.0
ReporterProperties reporterProperties = new ReporterProperties()
.setBufferedMaxMessages(500)
.setPendingMaxMessages(10000)
.setMetrics("inmemory")
.setMetricsExporter("http")
.setParallelismPerBatch(5)
.setSenderExecutor(new ThreadPoolExecutor(200,
200, 0, TimeUnit.MILLISECONDS, new SynchronousQueue<>()));
BatchedJdbcTemplate template = new BatchedJdbcTemplate(reporterProperties);
template.setDataSource(dataSource);
Promise promise = template.update(...);
promise.done(success -> ...)
.fail(reject -> ...);吞吐量对比
Benchmark Mode Cnt Score Units
BatchedJdbcTemplateBenchmark.high_contention_batched thrpt 15 8709.042 ops/s
BatchedJdbcTemplateBenchmark.high_contention_unbatched thrpt 15 271.529 ops/s
BatchedJdbcTemplateBenchmark.mild_contention_batched thrpt 15 2146.595 ops/s
BatchedJdbcTemplateBenchmark.mild_contention_unbatched thrpt 15 262.621 ops/s
BatchedJdbcTemplateBenchmark.no_contention_batched thrpt 15 1194.852 ops/s
BatchedJdbcTemplateBenchmark.no_contention_unbatched thrpt 15 201.806 ops/s
-
定义测试用的Message：test.proto message SubMsg { required uint32 n1 = 1; required uint32 n2 = 2; } message Msg { required uint32 n = 1; repeated SubMsg sub_msg = 2; } [root@slayer xx]# protoc tes
-
来自AWS Lambda常见问题解答： Q： 我一次可以执行的AWS Lambda函数的数量是否有限制？ 不需要。AWS Lambda旨在并行运行多个函数实例。然而，AWS Lambda的默认安全限制为每个区域每个帐户100次并发执行。如果您希望提交请求以增加100次并发执行的限制，您可以访问我们的支持中心，单击“打开新案例”，然后提交服务限制增加请求。 Q： 如果我的帐户超过并发执行的默认限制，
-
在大数据存储中，IOPS和吞吐量之间的关键区别是什么
-
名称 方法 实现 Hibernate 优势 劣势 Mybaties Jpa get 1. Hibernate 1.1 单独使用 1.1.1 For Idea 新建项目:【File】——>【New】——>【Project】——>【Java】——>【Hibernate、JavaEE Persistence】 添加数据连接驱动 配置数据源 根据数据库表生成实体类:【Persistence】——>【名称】
-
我正在对ElasticSearch进行基准测试，以实现非常高的索引吞吐量。 我目前的目标是能够在几个小时内索引30亿（3,000,000,000)文档。为此，我目前有3台windows服务器机器，每台16GB内存和8个处理器。插入的文档有一个非常简单的映射，只包含少数数字非分析字段（被禁用）。 使用这个相对适中的钻机，我能够达到每秒大约120,000个索引请求（使用大桌子监控），我相信吞吐量可以进
-
我有一个类女巫负责向客户端发送数据，所有其他类在需要发送数据时都使用这个。让我们称之为“数据ender.class”。 现在客户端要求我们将吞吐量控制在每秒最多50次调用。 我需要在这个类上创建一个algoritm（如果可能的话），以保持当前秒的调用次数，如果它达到50的最大值，保持进程要么睡眠或某事，并继续而不丢失数据。也许我必须实现一个队列或比简单的睡眠更好的东西。我需要建议或遵循的方向。 为
-
无论从什么角度来看，它都不是。 假设我有两个消费者，它们以每秒“10”条消息的速度从给定主题中消耗数据。现在，不管它们是从单个分区还是从两个不同的分区进行消耗；我的吞吐量将保持不变，每秒20条消息。 我觉得我一定漏了一些内部工作的细节，你能帮我解释一下kafka分区（多个）是如何帮助提高固定用户数量的吞吐量的，而不是单个kafka分区。