@RestController
public class LoggingController {

    private final String socketPath = "/tmp/sidecar.sock";

    @PostMapping("/process")
    public ResponseEntity<String> processRequest(@RequestBody String request) {
        // 处理请求的业务逻辑
        String response = "Processed: " + request;

        // 将请求信息发送给边车程序
        sendToSidecar(request);

        return ResponseEntity.ok(response);
    }

    private void sendToSidecar(String message) {
        try (SocketAddress address = new UnixSocketAddress(socketPath);
             SocketChannel channel = UnixSocketChannel.open(address)) {
            ByteBuffer buffer = ByteBuffer.wrap(message.getBytes(StandardCharsets.UTF_8));
            channel.write(buffer);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

package main

import (
    "bufio"
    "fmt"
    "log"
    "net"
    "os"
)

func main() {
    socketPath := "/tmp/sidecar.sock"

    // 确保之前的socket文件被删除
    if err := os.RemoveAll(socketPath); err != nil {
        log.Fatal(err)
    }

    listener, err := net.Listen("unix", socketPath)
    if err != nil {
        log.Fatal("Listen error:", err)
    }
    defer listener.Close()

    for {
        conn, err := listener.Accept()
        if err != nil {
            log.Fatal("Accept error:", err)
        }
        go handleConnection(conn)
    }
}

func handleConnection(conn net.Conn) {
    defer conn.Close()
    reader := bufio.NewReader(conn)
    for {
        message, err := reader.ReadString('\n')
        if err != nil {
            if err.Error() != "EOF" {
                log.Println("Read error:", err)
            }
            break
        }
        log.Println("Received message:", message)
        // 在此处可以将日志发送到外部系统，例如Kubernetes的日志系统
    }
}

import (
    "context"
    "log"

    "k8s.io/client-go/kubernetes"
    "k8s.io/client-go/rest"
    metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
)

func interactWithK8s() {
    config, err := rest.InClusterConfig()
    if err != nil {
        log.Fatal(err)
    }
    clientset, err := kubernetes.NewForConfig(config)
    if err != nil {
        log.Fatal(err)
    }

    pods, err := clientset.CoreV1().Pods("default").List(context.TODO(), metav1.ListOptions{})
    if err != nil {
        log.Fatal(err)
    }
    for _, pod := range pods.Items {
        log.Println("Pod name:", pod.Name)
    }
}