gost 使用 Relay+tls 协议 的服务端和客户端代码示范

以下是使用Go语言编写的基本服务端和客户端代码示例，使用Relay+TLS协议进行连接。在这个示例中，我们将使用自签名的证书来进行连接，您可以将其更改为您自己的证书。

服务器代码：

package main

import (
    "crypto/tls"
    "fmt"
    "log"
    "net"

    "github.com/mediocregopher/radix/v3"
)

const (
    network = "tcp"
    address = "127.0.0.1:6379"
)

func main() {
    tlsConfig := &tls.Config{
        MinVersion: tls.VersionTLS12,
    }

    listener, err := tls.Listen(network, address, tlsConfig)
    if err != nil {
        log.Fatalf("Failed to start server: %v", err)
    }

    defer listener.Close()
    log.Printf("Server started %s:%s", network, address)

    for {
        conn, err := listener.Accept()
        if err != nil {
            log.Printf("Failed to accept incoming connection: %v", err)
            continue
        }

        go handleConnection(conn)
    }
}

func handleConnection(conn net.Conn) {
    defer conn.Close()
    log.Printf("Received connection from %s", conn.RemoteAddr().String())

    db, err := radix.Dial(network, address)
    if err != nil {
        log.Printf("Failed to connect to Redis: %v", err)
        return
    }

    err = db.Do(radix.Ping())
    if err != nil {
        log.Printf("Failed to ping Redis: %v", err)
        return
    }

    buffer := make([]byte, 1024)
    for {
        n, err := conn.Read(buffer)
        if err != nil {
            log.Printf("Failed to read from connection: %v", err)
            return
        }

        command := string(buffer[:n])
        log.Printf("Received command: %s", command)

        resp := make(chan string)
        go func() {
            response, err := db.Do(radix.Cmd(nil, command))
            if err != nil {
                resp <- fmt.Sprintf("Error: %v", err)
            } else {
                resp <- fmt.Sprintf("%v", response)
            }
        }()

        result := <-resp
        _, err = conn.Write([]byte(result))
        if err != nil {
            log.Printf("Failed to write to connection: %v", err)
            return
        }
    }
}

客户端代码：

package main

import (
    "crypto/tls"
    "fmt"
    "log"
    "net"
    "os"
)

func main() {
    tlsConfig := &tls.Config{
        InsecureSkipVerify: true,
    }

    conn, err := tls.Dial("tcp", "localhost:6379", tlsConfig)
    if err != nil {
        log.Fatalf("Failed to connect to server: %v", err)
    }

    defer conn.Close()

    for {
        fmt.Printf("Enter command: ")

        command := make([]byte, 1024)
        n, err := os.Stdin.Read(command)
        if err != nil {
            log.Fatalf("Failed to read command: %v", err)
        }

        _, err = conn.Write(command[:n])
        if err != nil {
            log.Fatalf("Failed to write command: %v", err)
        }

        response := make([]byte, 1024)
        n, err = conn.Read(response)
        if err != nil {
            log.Fatalf("Failed to read response: %v", err)
        }

        fmt.Printf("Response: %s\n", response[:n])
    }

}