➡️博客首页       https://blog.csdn.net/Java_Yangxiaoyuan        欢迎优秀的你点赞、️收藏、加❤️关注哦。        本文章CSDN首发，欢迎转载，要注明出处哦！        先感谢优秀的你能认真的看完本文，有问题欢迎评论区交流，都会认真回复！

日志系列之什么是分布式日志系统？

一、✅什么是分布式日志系统？1.1 ✅分布式日志系统和消息队列有什么区别和联系1.2 ✅哪些场景下需要使用分布式日志系统和消息队列1.3 ✅实际项目的开发过程中到底如何做选择1.4 ✅分布式日志系统和消息队列如何实现异步通信和解耦呢1.5 ✅分布式日志系统和消息队列的优缺点是什么1.6 ✅分布式日志系统和消息队列如何实现性能和吞吐量呢1.6.1分布式日志系统1.6.2消息队列

1.7 ✅如何保证消息的可靠传输1.7.1 添加依赖1.7.2 创建生产者1.7.3 创建消费者

二、✅扩展知识仓2.1✅ELK

一、✅什么是分布式日志系统？

现在，很多应用都是集群部署的，一次请求会因为负载均衡而被路由到不同的服务器上面，这就导致一个应用的日志会分散在不同的服务器上面。

当我们要向通过日志做数据分析，问题排查的时候，就需要分别到每台机器上去查看日志，这样就太麻烦了。

于是就有了分布式日志系统，他可以做分布式系统中的日志的统一收集、存储及管理。并且提供好的可用性、扩展性。

一个好的分布式日志系统，应该具备数据采集、数据加工、查询分析、监控报警、日志审计等功能。有了分布式日志系统，我们就可以做集中化的日志管理， (准)实时性的做日志查询及分析，快速的做问题排查，更好的做数据分析及挖掘。

比较主流的这类日志管理系统有ELK、Graylog、Apache Flume，还有很多类似的云产品，如阿里云的SLS。

一般来说，如果资金够就上SLS，不够就自建ELK。

实现分布式日志系统需要使用分布式系统的一些基本概念和技术，例如消息传递、数据复制和分布式一致性协议。在Java中实现分布式日志系统可以使用一些现有的框架和库，例如Apache Kafka或Logstash。

看一个Demo：

import java.util.Properties;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import java.util.concurrent.TimeUnit;

import org.apache.kafka.clients.producer.*;

/**

* 一个分布式日志系统的Demo、包括日志的收集、处理、存储和检索功能

*

*/

public class DistributedLogSystem {

public static void main(String[] args) {

// 创建日志收集器线程池

ExecutorService collectorPool = Executors.newFixedThreadPool(10);

// 创建Kafka生产者配置

Properties props = new Properties();

props.put("bootstrap.servers", "localhost:9092");

props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer");

props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer");

// 创建Kafka生产者

Producer producer = new KafkaProducer<>(props);

// 启动日志收集器线程

for (int i = 0; i < 10; i++) {

final int threadId = i;

collectorPool.submit(() -> {

try {

// 模拟日志收集逻辑

for (int j = 0; j < 1000; j++) {

String topic = "logs";

String message = "Log message " + threadId + "_" + j;

ProducerRecord record = new ProducerRecord<>(topic, message);

producer.send(record);

}

} catch (Exception e) {

e.printStackTrace();

}

});

}

// 关闭日志收集器线程池和Kafka生产者

collectorPool.shutdown();

try {

if (!collectorPool.awaitTermination(60, TimeUnit.SECONDS)) {

collectorPool.shutdownNow();

}

producer.close();

} catch (InterruptedException e) {

collectorPool.shutdownNow();

producer.close();

Thread.currentThread().interrupt();

}

}

}

上面这个Demo中，首先创建了一个线程池用于日志收集器线程，然后创建了一个Kafka生产者对象。接着，使用线程池启动了10个日志收集器线程，每个线程模拟日志收集逻辑，并将收集到的日志消息发送到Kafka中。最后，关闭了日志收集器线程池和Kafka生产者对象。

1.1 ✅分布式日志系统和消息队列有什么区别和联系

分布式日志系统和消息队列在实现和应用上有一些区别和联系。

首先，分布式日志系统主要用于记录、存储和分析系统的日志信息，以帮助开发人员监控系统状态、排查问题等。而消息队列则是一种更为通用的技术，主要用于在不同的服务或应用之间传递消息，实现异步通信和数据交换。

其次，分布式日志系统通常将日志数据存储在分布式文件系统中，如HDFS、ELK等，以实现数据的可靠存储和高效查询。而消息队列则可以使用各种消息中间件，如RabbitMQ、Kafka等，以提供更为灵活的消息传递和消费机制。

此外，分布式日志系统和消息队列在应用场景上也有所不同。分布式日志系统主要用于系统监控和诊断，而消息队列则广泛应用于异步通信、任务调度、事件驱动架构等领域。

尽管两者有所区别，但它们之间也存在一定的联系。在实际应用中，可以将分布式日志系统中的日志数据发送到消息队列中，以便于其他服务或应用进行进一步的处理和分析。同时，也可以使用消息队列来实现分布式系统中的异步通信和数据交换，提高系统的灵活性和可扩展性。

总之，分布式日志系统和消息队列都是分布式系统中重要的组成部分，它们各自具有不同的功能和特点，但在实际应用中可以相互配合使用，以实现更为高效和可靠的分布式系统。

看一个简单的Demo来帮助理解：

实现：如何使用分布式日志系统（如Apache Kafka）来收集和存储日志数据。

首先，我们需要引入Apache Kafka的相关依赖。在Maven项目中，可以在pom.xml文件中添加以下依赖：

org.apache.kafka

kafka-clients

2.8.0

接下来，我们可以创建一个Kafka生产者类，用于将日志数据发送到Kafka集群：

import org.apache.kafka.clients.producer.*;

import java.util.Properties;

public class KafkaProducerExample {

public static void main(String[] args) {

// 设置Kafka生产者配置属性

Properties props = new Properties();

props.put("bootstrap.servers", "localhost:9092"); // Kafka集群地址

props.put("key.serializer", "org.apache.kafka.common.serialization.StringSerializer"); // 键序列化器

props.put("value.serializer", "org.apache.kafka.common.serialization.StringSerializer"); // 值序列化器

// 创建Kafka生产者实例

Producer producer = new KafkaProducer<>(props);

// 发送日志数据到Kafka集群

String topic = "my-log-topic"; // 日志主题名称

String logData = "This is a log message"; // 日志数据内容

ProducerRecord record = new ProducerRecord<>(topic, logData);

producer.send(record);

// 关闭Kafka生产者实例

producer.close();

}

}

上面的代码中，我们首先创建了一个Kafka生产者实例，并设置了相关的配置属性，包括Kafka集群地址、键序列化器和值序列化器。然后，我们创建了一个 ProducerRecord 对象，用于表示要发送到Kafka集群的日志数据。最后，我们调用 producer.send() 方法将日志数据发送到指定的Kafka主题中。在完成日志数据的发送后，我们关闭了Kafka生产者实例。

当然了，这只是一个简单的示例，实际应用中还需要考虑更多的问题，如日志数据的格式化、异常处理、数据压缩等。同时，还需要配合其他工具和框架（如ELK Stack）来实现更为完整和高效的分布式日志系统。

1.2 ✅哪些场景下需要使用分布式日志系统和消息队列

分布式日志系统和消息队列在许多场景中都有广泛的应用，以下是一些常见的应用场景：

故障诊断与排查：当分布式系统出现故障时，通过分析日志可以更快地定位问题的原因和位置，从而加快故障排查和修复的速度。性能调优与优化：通过收集系统中的各个节点的日志信息，可以了解系统的整体性能，发现潜在的性能瓶颈，并进行相应的优化。事件追踪与监控：通过分布式日志系统，可以实时追踪系统中的各种事件，如用户行为、系统操作等，并进行实时监控和报警。异步通信与解耦：消息队列可以作为分布式系统中的异步通信机制，解耦各个服务之间的直接依赖关系，提高系统的可扩展性和容错性。数据分片与迁移：在分布式系统中，可以通过分布式日志系统进行数据分片和迁移，提高系统的可扩展性和数据一致性。审计与日志分析：分布式日志系统可以用于审计和日志分析，帮助开发人员了解系统的运行状态和用户行为，以便进行更好的数据分析和挖掘。

分布式日志系统和消息队列在分布式系统中有着广泛的应用场景，它们能够提供可靠的数据存储和传输机制，实现高效的监控、追踪、分析和优化等功能。

1.3 ✅实际项目的开发过程中到底如何做选择

在选择分布式日志系统和消息队列时，需要综合考虑以下几个因素：

需求与功能：根据实际项目的需求和功能要求，选择能够满足需求的分布式日志系统和消息队列。例如，如果需要实时监控和报警，那么选择具有实时处理能力的分布式日志系统可能更为合适；如果需要异步通信和数据交换，那么消息队列可能更适合。性能与效率：分布式日志系统和消息队列的性能和效率对于整个分布式系统的性能有着重要的影响。在选择时，需要权衡各个系统的性能指标和效率，并考虑系统规模和数据量的增长趋势。易用性与可维护性：选择易于使用和易于维护的分布式日志系统和消息队列可以提高开发效率和系统稳定性。此外，还需要考虑系统的文档支持、社区活跃度等因素。成本与开放性：在选择分布式日志系统和消息队列时，需要考虑成本和开放性。一些开源项目可以降低成本，同时具有较好的开放性，方便进行二次开发和定制化。集成与兼容性：在实际项目中，可能需要将分布式日志系统和消息队列与其他系统进行集成和配合使用。因此，需要考虑各个系统的集成能力和兼容性，以便更好地实现系统之间的交互和数据传输。

综上所述，选择合适的分布式日志系统和消息队列需要根据实际项目的需求、功能、性能、易用性、成本、开放性、集成和兼容性等多个因素进行综合考虑。在评估各个因素的基础上，可以选择一种或多种适合系统的工具和技术，以满足项目的实际需求和提高整体性能。

1.4 ✅分布式日志系统和消息队列如何实现异步通信和解耦呢

分布式日志系统和消息队列可以通过以下方式实现异步通信和解耦：

分层和分割：通过分层和分割的方式，将系统中的各个组件或服务分离部署，各自专注于自己的业务，建立起各自的集群。这样可以实现系统的扩展性和维护性，同时解耦各个组件之间的直接依赖关系。使用消息队列：消息队列可以作为系统中的中介，将各个组件或服务之间的通信解耦。消息生产者将消息发送到消息队列中，消息消费者从消息队列中订阅并处理消息。这种方式可以实现异步通信，提高系统的响应性能和吞吐量。定义清晰的消息格式和协议：为了确保不同组件之间的通信能够顺利进行，需要定义清晰的消息格式和通信协议。这样可以使消息生产者和消费者都能理解并正确处理消息。使用合适的消息队列系统：根据需求选择适合的消息队列系统，如RabbitMQ、Kafka、ActiveMQ等。考虑因素包括性能、可靠性、可扩展性和支持的功能。实现消息确认机制：在消息队列中，确保消息的可靠传输至关重要。消息生产者发送消息后，可以等待消息队列返回确认信息，以确保消息已被接收并正确处理。消费者在处理完消息后发送确认消息给消息队列，以通知消息已经成功处理。错误处理和重试机制：当消息处理失败时，可以实现错误处理和重试机制。将失败的消息放回消息队列，让消费者重新处理或延迟处理。这样可以提高系统的可靠性和容错能力。监控和日志记录：对消息队列的状态进行监控，并记录关键指标和日志信息。这样可以帮助识别潜在的问题、优化系统性能，并进行故障排查。

分布式日志系统和消息队列通过分层和分割、使用消息队列、定义清晰的消息格式和协议、使用合适的消息队列系统、实现消息确认机制、错误处理和重试机制以及监控和日志记录等方式实现异步通信和解耦。这样可以提高系统的扩展性、维护性、可靠性和性能，降低系统间的耦合性，并方便进行数据分析和挖掘等操作。

一个简单的Demo：

import org.springframework.jms.core.JmsTemplate;

import org.springframework.jms.core.MessageCreator;

/**

* 如何使用消息队列实现异步通信和解耦：

*/

public class MessageProducer {

private JmsTemplate jmsTemplate;

public void setJmsTemplate(JmsTemplate jmsTemplate) {

this.jmsTemplate = jmsTemplate;

}

public void sendMessage(String destination, String message) {

jmsTemplate.send(destination, new MessageCreator() {

@Override

public Message createMessage(Session session) throws JMSException {

return session.createTextMessage(message);

}

});

}

}

在上面的代码中，我们使用了Spring框架的JmsTemplate类来简化消息队列的操作。通过注入JmsTemplate实例，我们可以方便地发送消息到指定的消息队列。sendMessage()方法接收目标队列的名称和要发送的消息内容作为参数，然后使用JmsTemplate的send()方法将消息发送到指定的队列中。这种方式可以实现异步通信，将发送消息的操作与消息队列解耦，提高系统的灵活性和可扩展性。

需要注意：在实际应用中，还需要根据具体的业务需求和场景来选择合适的消息队列系统，并根据具体的消息格式和协议进行相应的处理和解析。此外，还需要考虑消息的可靠传输、错误处理和重试机制、监控和日志记录等方面的实现。

1.5 ✅分布式日志系统和消息队列的优缺点是什么

分布式日志系统和消息队列是两种不同的技术，它们各自有不同的优缺点。

分布式日志系统的优点：

可靠性：分布式日志系统通常提供数据持久化和备份功能，确保数据不会因为单点故障而丢失。可扩展性：分布式日志系统通常设计为可扩展的，可以轻松地添加更多的日志采集节点来处理更多的日志数据。灵活性：分布式日志系统通常支持多种数据格式和协议，可以根据需要定制和解析日志数据。分析能力：分布式日志系统通常提供强大的查询和数据分析功能，可以帮助开发人员和运维人员快速定位问题。

分布式日志系统的缺点：

复杂性：分布式日志系统通常涉及多个节点和组件，部署和维护相对复杂。性能瓶颈：如果日志数据量非常大，分布式日志系统可能会成为性能瓶颈，需要优化系统配置或增加硬件资源。成本：分布式日志系统的实现和维护需要一定的成本，尤其是在大规模生产环境中。

消息队列的优点：

异步通信：消息队列支持异步通信，生产者和消费者可以在不同时间处理消息，提高了系统的响应速度和吞吐量。解耦：消息队列将生产者和消费者解耦，使它们可以独立扩展和维护，降低了系统的复杂性。可扩展性：消息队列能够处理高并发的消息传递，可以根据需求灵活地扩展机器和队列。灵活性：消息队列支持多种消息格式和协议，可以根据需要定制和发送消息。

消息队列的缺点：

复杂性：消息队列涉及多个组件和交互，部署和维护相对复杂。性能问题：如果消息量非常大，消息队列可能会成为性能瓶颈，需要优化系统配置或增加硬件资源。可靠性问题：如果消息队列的管理和存储机制不完善，可能会出现消息丢失或重复消费的情况。

1.6 ✅分布式日志系统和消息队列如何实现性能和吞吐量呢

分布式日志系统和消息队列在实现高性能和高吞吐量方面，通常采用一系列的设计和优化策略。以下是这些策略的一些关键点：

1.6.1分布式日志系统

并行处理：通过分布式架构，日志可以在多个节点上并行处理。每个节点负责处理一部分日志数据，从而提高整体处理性能。 负载均衡：在日志数据进入系统时，使用负载均衡器将数据分发到不同的处理节点上，确保每个节点的负载相对均衡，避免单点压力过大。 数据压缩：在存储和传输日志数据之前，对数据进行压缩，可以减少网络带宽和存储空间的消耗，从而提高性能。 索引优化：为日志数据建立高效的索引结构，可以加快查询速度，提高分析性能。 异步写入：采用异步写入机制，将日志数据先写入内存缓冲区，再批量写入磁盘或远程存储，减少I/O操作的延迟。 数据分区：将日志数据分区存储，使得每个分区可以独立地进行读写操作，提高并发处理能力。 资源隔离：为日志系统分配独立的计算、网络和存储资源，避免与其他系统争抢资源导致性能下降。

1.6.2消息队列

异步处理：消息队列本身就是异步通信的模式，生产者和消费者可以并行工作，从而提高整体吞吐量。 持久化与非持久化：根据需求选择消息的持久化级别。非持久化消息可以提高性能，但可能会丢失；持久化消息虽然性能略低，但保证了消息的可靠性。 批量处理：生产者和消费者都可以批量发送和接收消息，减少网络交互次数，提高性能。 并发控制：通过控制生产者和消费者的并发数，可以优化系统的吞吐量。 内存优化：合理利用内存缓存机制，减少磁盘I/O操作，提高消息处理速度。 数据分区与分片：将消息数据分区或分片存储，使得每个分区或分片可以独立处理，提高并发性能。 负载均衡与集群：通过集群和负载均衡技术，将消息分发到多个消息代理上，实现水平扩展，提高吞吐量。 流量控制：实施流量控制机制，防止生产者发送过多的消息导致消费者处理不过来，造成资源浪费或系统崩溃。

综上所述，分布式日志系统和消息队列通过并行处理、负载均衡、数据压缩、异步操作、资源隔离等一系列策略和技术，可以有效地实现高性能和高吞吐量。这些策略需要根据具体的业务需求和系统环境进行定制和优化。

来看一个简单的Demo：

import com.rabbitmq.client.Channel;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.ConnectionFactory;

/**

* 如何使用RabbitMQ实现异步通信和解耦，以及如何通过一些优化策略提高性能和吞吐量

* @author xinbaobaba

*/

public class MessageProducer {

private final static String QUEUE_NAME = "hello";

public static void main(String[] argv) throws Exception {

// 创建连接工厂并设置参数

ConnectionFactory factory = new ConnectionFactory();

factory.setHost("localhost");

factory.setUsername("guest");

factory.setPassword("guest");

// 创建连接

Connection connection = factory.newConnection();

Channel channel = connection.createChannel();

// 声明一个队列，如果不存在则创建

channel.queueDeclare(QUEUE_NAME, false, false, false, null);

// 发送消息到队列中

String message = "Hello World!";

channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));

System.out.println("Sent message: " + message);

// 关闭连接和通道

channel.close();

connection.close();

}

}

在上面的代码中，我们使用了RabbitMQ作为消息队列系统。通过创建ConnectionFactory实例并设置相关参数，我们可以连接到RabbitMQ服务器。然后，我们创建Connection和Channel实例，用于发送和接收消息。在发送消息时，我们声明一个队列（如果不存在则创建），并使用basicPublish()方法将消息发送到队列中。最后，我们关闭连接和通道。

为了提高性能和吞吐量，我们可以采取以下优化策略：

批量发送消息：我们可以将多个消息批量发送到队列中，而不是一个一个地发送，从而减少网络交互的次数。在发送消息时，我们可以使用basicPublish()方法的批量发送参数。持久化队列和消息：为了确保消息的可靠传输，我们可以将队列和消息都设置为持久化。这样即使RabbitMQ服务器重启或发生故障，队列和消息也不会丢失。在声明队列和发送消息时，我们可以使用相应的持久化参数。并发处理：我们可以使用多线程或多进程来并发处理消息。这样可以充分利用系统的计算资源，提高处理速度和吞吐量。在接收消息时，我们可以使用多个消费者实例并行地从队列中获取和处理消息。异步处理：我们可以使用异步处理模式来提高性能和吞吐量。在发送和接收消息时，我们可以使用异步方法，避免阻塞主线程。这样可以使应用程序更加高效地处理其他任务。

1.7 ✅如何保证消息的可靠传输

保证消息的可靠传输是在分布式系统和消息队列中非常重要的一个方面。以下是几种常用的策略和技术，可以确保消息的可靠传输：

消息确认机制：

在生产者发送消息后，消息队列系统应该提供一个确认机制来通知生产者消息是否成功发送。对于消费者，一旦消息被成功处理，它应该发送一个确认信号给消息队列系统，表明该消息已经被成功处理。 持久化：

将消息队列中的消息持久化到磁盘或其他持久化存储介质中，以防止因系统崩溃或其他故障导致的消息丢失。配置队列和消息的持久化选项，确保在消息代理重启后，消息不会丢失。 重试机制：

如果消息发送或处理失败，应该有一个重试机制来重新发送或处理消息。重试机制应该有最大重试次数和重试间隔的配置，以避免无限循环和系统资源的浪费。 死信队列：

配置死信队列来捕获那些无法被正常处理或消费的消息。死信队列允许系统管理员后续对这些异常消息进行处理或分析。 事务性消息：

使用事务性消息来确保消息的发送和接收是原子操作。如果事务失败，消息将回滚到之前的状态，确保数据的一致性。 消息顺序性保证：

在某些场景中，消息的顺序性很重要。可以通过在消息中添加序列号或使用专门保证顺序性的消息队列来确保消息的顺序性。 幂等性处理：

设计消息处理逻辑为幂等的，意味着无论消息被处理多少次，结果都是一致的。这可以防止因重复消费消息而导致的系统状态不一致。 网络可靠性：

使用可靠的网络协议（如TCP）来传输消息，以减少消息在网络传输过程中丢失的可能性。 监控和告警：

对消息队列系统进行监控，并设置告警机制来及时通知管理员任何可能的问题或故障。 备份和恢复策略：

定期对消息队列系统进行备份，并制定恢复策略来应对可能的灾难性事件。

在Java中，使用RabbitMQ或Apache Kafka等消息队列时，可以通过配置相关参数和利用这些消息队列提供的API来实现上述的可靠传输策略。例如，在RabbitMQ中，可以设置消息的持久化属性，使用事务或确认机制，以及配置死信队列等。

老样子，使用代码段来进一步解释如何实现消息的可靠传输。以下是一个Demo：

1.7.1 添加依赖

首先，确保你的项目中添加了RabbitMQ的Java客户端依赖。你可以使用Maven或Gradle来添加。

1.7.2 创建生产者

import com.rabbitmq.client.ConnectionFactory;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.Channel;

/**

* 如何使用RabbitMQ的Java客户端来发送和接收消息，并确保消息的可靠传输

* @author xinbaobaba

*/

public class MessageProducer {

private final static String QUEUE_NAME = "hello";

public static void main(String[] argv) throws Exception {

ConnectionFactory factory = new ConnectionFactory();

factory.setHost("localhost"); // 设置RabbitMQ服务器地址

factory.setUsername("guest"); // 设置用户名

factory.setPassword("guest"); // 设置密码

try (Connection connection = factory.newConnection();

Channel channel = connection.createChannel()) {

// 声明一个持久化队列（如果队列不存在则创建）

channel.queueDeclare(QUEUE_NAME, true, false, false, null);

System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

// 发送消息到队列中，持久化队列和消息都会确保消息不会丢失

String message = "Hello World!";

channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));

System.out.println(" [x] Sent '" + message + "'");

}

}

}

1.7.3 创建消费者

import com.rabbitmq.client.ConnectionFactory;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.Channel;

import com.rabbitmq.client.DeliverCallback;

import java.util.concurrent.CountDownLatch;

/**

* @author xinbaobaba

*/

public class MessageConsumer {

private final static String QUEUE_NAME = "hello";

private static final CountDownLatch latch = new CountDownLatch(1); // 用于等待消息处理完成

public static void main(String[] argv) throws Exception {

ConnectionFactory factory = new ConnectionFactory();

factory.setHost("localhost"); // 设置RabbitMQ服务器地址

factory.setUsername("guest"); // 设置用户名

factory.setPassword("guest"); // 设置密码

try (Connection connection = factory.newConnection();

Channel channel = connection.createChannel()) {

// 声明一个持久化队列（如果队列不存在则创建）

channel.queueDeclare(QUEUE_NAME, true, false, false, null);

System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

channel.basicConsume(QUEUE_NAME, true, new DeliverCallback() { // 自动确认模式，确保消息被可靠处理

@Override

public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {

String message = new String(body, "UTF-8"); // 获取消息内容并打印出来

System.out.println(" [x] Received '" + message + "'");

latch.countDown(); // 减少计数，表示消息已处理完成

}

}, consumerTag -> { }); // 使用lambda表达式简化了DeliverCallback的实现过程，并指定消费者标签（可选）

latch.await(); // 等待消息处理完成后再继续执行其他任务（例如关闭连接）

} catch (InterruptedException e) {

e.printStackTrace();

} finally {

// 在这里你可以添加其他逻辑，例如关闭资源或执行清理操作等。

}

}

}

二、✅扩展知识仓

2.1✅ELK

ELK是三个开源软件的缩写，分别表示: Elasticsearch，Logstash,Kibana。 Elasticsearch是个开源分布式搜索引擎，提供分析、存储数据等功能 Logstash主要是用来日志的搜集、分析、过滤日志的工具，支持大量的数据获取方式 Kibana也是一个开源和免费的工具，Kibana可以为 Logstash 和 ElasticSearch 提供的日志分析友好的 Web 界面，可以帮助汇总、分析和搜索重要数据日志。 所以，通常是使用Logstash做日志的采集与过滤，ES做分析和查询，Kibana做图形化界面

相关链接

评论可见，请评论后查看内容，谢谢！！！
 您阅读本篇文章共花了： 


大家都在找：

分布式：分布式能源

日志：日志分析工具

Kaffka：kafka的作用有哪些

Java：java启动器下载

大家都在看：

分布式 hive java 大数据技术之Hadoop(十一)——网站流量日志数据分析系统

java 分布式定时任务系列6：XXL-job触发日志过大引发的CPU告警

目录传送门问题出现 场景说明开发第一个jobHandler新建任务测试任务删除代码中的任务问题重现​​​问题解决手动清理自动清理启动自动清理任务入口初始化自动清理任务​编辑执行自动清理任务 结束语传送...

智慧城市 汽车 java 停车系统系列二(分布式唯一ID)

前言在上一篇文章中我们确定了系统的架构和db,在开发代码前我们还需要准备一些微服务基础组件,本文介绍分布式唯一id的几种方式分布式唯一ID的概念分布式唯一ID（Distributed Unique I...

数据库 系统架构 java 分布式系统稳定性建设指南

文章目录分布式系统稳定性建设总体视图分布式系统稳定性建设目标分布式系统稳定性评价指标分布式系统稳定性建设模式架构设计容量设计架构设计安全设计分布式系统稳定性建设路径需求分析需求实现分析稳定性建设活动分...

系统架构 后端 java 值得一看，阿里又杀疯了开源内部“M9”级别全彩版分布式实战笔记

学习是一种基础性的能力。然而，“吾生也有涯，而知也无涯。”，如果学习不注意方法，则会“以有涯随无涯，殆矣”。学习就像吃饭睡觉一样，是人的一种本能，人人都有学习的能力。我们在刚出生的时候，什么也不知道，...

java-zookeeper dubbo + zookeeper + spring 分布式系统(1)

4.配置 配置文件5.1 启动spring 容器 ；java代码启动System.in.read(); // 按任意键退出5.2 也可以部署到tomcat 中去；那就要配置一下 web.xml 文件了...

java 大数据 什么是分布式任务调度？怎样实现任务调度

通常任务调度的程序是集成在应用中的，比如：优惠卷服务中包括了定时发放优惠卷的的调度程序，结算服务中包括了定期生成报表的任务调度程序，由于采用分布式架构，一个服务往往会部署多个冗余实例来运行我们的业务，...

java 分布式 服务器 nacos配置gateway读取不到其他模块可能原因 – 请求503

nacos配置gateway读取不到其他模块可能原因 – 请求503SpringCloud工程，在配置好gateway和其他模块后，所有的请求都是从gateway进。而各个模块的配置信息则存到naco...

java 算法 系统架构 性能优化 架构 软件工程 Rust从入门到实战系列一百二十九：从 run 函数中返回错误

通过将剩余的逻辑分离进 run 函数而不是留在 main 中，就可以像示例 12-9 中的 Config::new 那样改进 错误处理。不再通过 expect 允许程序 panic，run 函数将会在...

服务器 运维 es node.js java ELK 企业级日志分析系统的概念、ELK Elasticsearch 集群部署

ELK 企业级日志分析系统 一、ELK 的概述1、ELK 简介2、可以添加的其它组件3、filebeat 结合 logstash 带来好处：4、Fluentd的概念 二、ELK的特征与工作原理...

java-zookeeper dubbo + zookeeper + spring 分布式系统（二）

System.in.read(); // 按任意键退出5.2 也可以部署到tomcat 中去；那就要配置一下 web.xml 文件了例如：看 dubbo-service1_1-project 的配置文...

java 分布式项目 16 购物车系统，dubbo框架（重点是拦截器），优化userId，配合拦截器

01.创建jt-cart项目 第一步： 第二步： 第三步： 第四步： 在pom.xml文件中添加jt-common的依赖，如图所示： 第五步： 添加插件第六步：创建pojo实体类对象 说明：在jt...

java dubbo分布式服务实现日志链路追踪traceid

很久没更新博客了。 这几天做traceid的时候，发现网上博客很多，但是大多都有一些点没讲很清楚，特别是SPI这块。这里写了一段亲测可用的代码贴出来让大家使用。兄弟们用完之后点歌收藏，点个赞啥的。也是...

计算机网络 分布式 dubbo spring boot spring cloud java 【Netty系列】Netty/BIO/NIO/AIO

一、Netty介绍Netty是一个开源的、异步的、事件驱动的网络应用框架，用于快速开发高性能的网络服务器和客户端。它主要用于构建可伸缩的网络应用程序，如协议服务器和客户端。Netty的设计目标是提供一...

分布式 java 架构师 面试官：Zookeeper是什么，它有什么特性与使用场景？

哈喽！大家好，我是小奇，一位不靠谱的程序员 小奇打算以轻松幽默的对话方式来分享一些技术，如果你觉得通过小奇的文章学到了东西，那就给小奇一个赞吧 文章持续更新，可以微信搜索【小奇JAVA面试】第一时间阅...