Author Archive

《译文:RabbitMQ 消费者确认和发布者确认》

原文链接 译者:flystarfly

介绍

使用消息代理(如RabbitMQ)的系统按定义分发。 由于发送的协议方法(消息)不能保证到达对方或被成功处理,所以发布者和消费者都需要一个交付和处理确认的机制。 RabbitMQ支持的一些消息协议提供了这样的功能。 本指南涵盖AMQP 0-9-1中的特性,但其他协议(STOMP,MQTT等)中的思路大致相同。

从消费者(consumers)投递rabbitmq代理(broker)的处理确认被认为是AMQP 0-9-1协议中的确认; rabbitmq代理(broker)对发布者(publishers)的确认被称作发布者确认(publisher confirms)
Read more

《译文:RabbitMQ关于吞吐量,延迟和带宽的一些理论》

原文链接 译者:flystarfly

该文阅读自RabbitMQ官方网站,分享好文给大家

你在Rabbit有一个队列,然后一些消费者从这个队列中消费。如果你根本没有设置QoS(basic.qos),那么Rabbit会把所有的队列消息都按照网络和客户端允许的速度推送给客户端。消费者将会飞速增加它们的内存占用,因为它们将所有消息都缓存在自己的RAM中。如果您询问Rabbit,队列可能会显示为空,但会有大量在客户端中,正准备由客户端应用程序处理的消息未被确认。如果您添加新的消费者,则队列中不会有消息发送给新的消费者。即使有其他消费者可用于更快地处理这样的消息,它们也只是在现有的客户端缓存,并且可能在那里很长一段时间。这是相当次优的。

因此,默认的QoS预取设置为客户提供了无限的缓冲区,这可能导致不良的行为和性能。但是,怎样的QoS预取缓冲区大小才是您应该设置的?设置的目的是让消费者保持工作饱和状态,同时尽量减少客户端的缓冲区大小,以便更多的消息留在Rabbit的队列中,来可供新消费者使用,或在消费者空闲时发送给消费者。
Read more

《Spring 5 官方文档》39. 创建可扩展的XML

原文链接 译者: flystarfly

39. 创作可扩展的XML

39.1 介绍

从2.0版开始,Spring提供了一种基于模式的扩展机制用于定义和配置beans的Spring XML基本格式。本节将尽力详细地说明如何编写自己的自定义XML bean解析器,以及如何将这样的解析器集成到Spring IoC容器中。

Read more

《KAFKA官方文档》5.2 APIs

原文链接 译者:flystarfly

2. APIs

Kafka包含四种核心的API:

  1. Producer API支持应用将数据流发送到Kafka集群的主题。
  2. Consumer API支持应用从Kafka集群的主题中读取数据流。
  3. Streams API支持数据流从输入主题转化到输出主题。
  4. Connect API支持实现持续地从一些源系统或应用划入Kafka或者从Kafka推入一些源系统或应用的接口。

Read more

spring boot集成mongodb最简单版

作者:flystarfly

通过spring tools suite新建一个spring project。带maven的即可

pom.xml文件配置

Read more

《Log4j 2 官方文档》Configuring Filters

原文链接 译者:flystarfly

配置过滤器

Log4j允许在下面4个地方中任意一个指定过滤器:

Read more

《Http Client 官方文档》7. 高级主题

原文链接 译者:flystarfly

第七章 高级主题

7.1. 自定义客户端连接

在某些情况下,有必要自定义HTTP消息传输的方式来扩展HTTP参数的可使用性,以便能够处理非标准的作业。 例如,对于网络爬虫,可能需要强制HttpClient接受格式不正确的响应头,来捕捉消息的内容。

Read more

《Spring Data 官方文档》7. 映射

原文链接 译者:flystarfly

7. 映射

“CassandraMappingConverter”提供了丰富的映射支持。 “CassandraMappingConverter”具有丰富的元数据模型,提供了将域对象映射到CQL表的一套完整的特性功能集合。 使用域对象上的注解来填充映射元数据模型。 然而,基础架构不会强求使用注解作为元数据信息的唯一来源。“CassandraMappingConverter”还允许您通过遵循一组公约来将对象映射到文档,而不用提供任何其他元数据。

Read more

《HttpClient官方文档》2.1 连接持久性-2.2 HTTP连接路由

 

2.1. 连接持久性

一个主机与另一个主机建立连接的过程是相当复杂的,并且涉及两个端点之间的多个分组交换,这可能相当耗时。尤其是对于较小的HTTP消息来说,连接握手的开销是很大的。如果打开的连接能够重用于执行多次请求,就可以实现更高的数据吞吐量。

HTTP/1.1协议规定每个缺省的HTTP连接都可以重用于多次请求。 符合HTTP/1.0协议的端点同样可以通过一种机制明示它们的优先权来维持连接的可用性并将其用于多次请求。
HTTP代理还可以维持空闲连接存活一段时间,以防后续请求需要用到同一目标主机的连接。 通常称维持连接存活的能力为连接持久性,HttpClient完全支持这种能力。

Read more

《Spring Data 官方文档》6. Cassandra 存储库

原文链接 译者:flystarfly

6. Cassandra 存储库

《Spring Data 官方文档》5.8. 使用自定义转换器重载默认映射至5.10. 异常解释

原文链接 译者:flystarfly

5.8. 使用自定义转换器重载默认映射

为了对映射过程有更细粒度的控制,你可以使用’CassandraConverter’实现来注册Spring转换器,例如’MappingCassandraConverter’。

“MappingCassandraConverter”检查是否有任何Spring转换器可以在这些特殊类试图映射自身对象之前处理。 为了’hijack’ MappingCassandraConverter’的正常映射策略,或许为了提高性能或其他自定义映射需求,您首先需要创建一个Spring’Converter’接口的实现,然后将它注册到MappingConverter。

Read more

《Spring Data 官方文档》5.7 查询CQL表

原文链接 译者:flystarfly

5.7. 查询CQL表

有几种选择和查询的风格,您可以从中选择。 请参阅CassandraTemplate API文档,了解所有可用的重载。

查询表的多行数据,并将结果映射到POJO。

Read more

《Spring Data 官方文档》5.6 保存, 更新, 以及删除数据行

原文链接 译者:flystarfly

5.6. 保存, 更新, 以及删除数据行

‘CassandraTemplate’提供了一种简单的方法来保存,更新和删除域对象,并将这些对象映射到存储在Cassandra中的文档。

Read more

《Spring Data官方文档》5.3. Connecting to Cassandra with Spring至5.5. Introduction to CassandraTemplate

原文链接 译者:flystarfly

5.3. 连接到Spring Cassandra

5.3.1. 外部化连接属性

你需要连接到Cassandra来创建配置文件信息。接触点是键空间的所必需的最小字段,但是为了清楚起见,最好能添加端口。

Read more

《Spring Data 官方文档》Reference Documentation至5.2. Examples Repository

原文链接 译者:flystarfly

参考文档

文档结构

参考文档的这一部分讲解Spring Data Cassandra所提供的核心功能.

Read more

return top