使用Java实现分布式日志系统

在Java中实现一个简单的分布式日志系统，你可以使用Java中的网络编程和IO操作来收集和记录日志。以下是一个简单的日志服务器示例，它接受来自客户端的日志消息，并将它们输出到控制台。

服务器端代码：

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
 
public class DistributedLogServer {
    public static void main(String[] args) throws IOException {
        int port = 1234; // 日志服务器监听的端口
        ServerSocket serverSocket = new ServerSocket(port);
        System.out.println("Log Server is running on port: " + port);
 
        while (true) {
            Socket clientSocket = serverSocket.accept();
            BufferedReader in = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
 
            String inputLine;
            while ((inputLine = in.readLine()) != null) {
                System.out.println("Received: " + inputLine);
                // 这里可以添加代码将日志记录到文件
            }
 
            in.close();
            clientSocket.close();
        }
    }
}

客户端代码：

import java.io.PrintWriter;
import java.net.Socket;
 
public class DistributedLogClient {
    public static void main(String[] args) throws Exception {
        String logServerHostname = "localhost"; // 日志服务器的主机名
        int port = 1234; // 日志服务器监听的端口
        Socket socket = new Socket(logServerHostname, port);
        PrintWriter out = new PrintWriter(socket.getOutputStream(), true);
 
        // 发送日志消息
        out.println("This is a log message");
 
        socket.close();
    }
}

在这个简单的例子中，服务器端程序创建了一个ServerSocket来监听端口，并接受来自客户端的连接。每个连接都会启动一个线程来处理，服务器端将接收到的日志消息输出到控制台。客户端则连接到服务器并发送一条日志消息。

这个例子仅用于演示如何简单实现一个分布式日志系统的基础框架。在实际应用中，你需要考虑更多的因素，比如错误处理、异常情况、日志持久化、并发处理、安全性等。