golang 긴 연결 솔루션

PHPz원래의: 2023-05-13 09:48:36867검색

Golang은 원래 Google에서 설계하고 개발한 빠르고 정적으로 유형이 지정되고 컴파일된 프로그래밍 언어입니다. Golang은 웹 애플리케이션 및 클라우드 시스템 개발, 특히 동시성이 높은 시나리오에서 널리 사용됩니다.

현대 웹 애플리케이션에서 긴 연결은 매우 중요한 기술입니다. 이는 일반적인 HTTP 요청에서는 클라이언트가 서버로부터 응답을 받으면 연결이 닫히기 때문입니다. 이로 인해 각 요청이 연결을 설정하고 닫게 되며 이는 서버와 클라이언트의 성능에 큰 영향을 미칩니다. 롱 커넥션(Long Connection) 기술은 클라이언트와 서버가 서로 통신하며 지속적으로 연결을 유지할 수 있도록 연결을 유지하는 방식이다. 이 기사에서는 Golang의 긴 연결 솔루션을 소개하고 장점과 단점에 대해 논의합니다.

WebSocket

WebSocket은 단일 TCP 연결을 통한 전이중 통신을 위한 프로토콜입니다. HTTP 프로토콜을 사용하여 연결을 설정한 다음 이를 WebSocket 프로토콜로 변환하여 긴 연결을 달성합니다. WebSocket 프로토콜을 사용하면 클라이언트와 서버가 연결을 끊지 않고도 서로 통신할 수 있어 메시지를 효율적으로 전달할 수 있습니다.

Golang의 표준 라이브러리는 WebSocket 서버 및 클라이언트를 구현하는 데 사용할 수 있는 내장 WebSocket 패키지("net/http")를 제공합니다. 다음은 간단한 WebSocket 서버 예제입니다.

package main

import (
    "fmt"
    "log"
    "net/http"
    "github.com/gorilla/websocket"
)

var upgrader = websocket.Upgrader{
    ReadBufferSize:  1024,
    WriteBufferSize: 1024,
    CheckOrigin: func(r *http.Request) bool {
        return true
    },
}

func wsHandler(w http.ResponseWriter, r *http.Request) {
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println("websocket upgrade error:", err)
        return
    }

    for {
        _, msg, err := conn.ReadMessage()
        if err != nil {
            break
        }

        fmt.Printf("received message: %s
", msg)
    }
}

func main() {
    http.HandleFunc("/ws", wsHandler)
    http.ListenAndServe(":8080", nil)
}

이 예제에서는 WebSocket 요청을 보다 편리하게 처리할 수 있는 Gorilla WebSocket 라이브러리를 사용합니다. HTTP 연결을 WebSocket 연결로 업그레이드하려면 websocket.Upgrader() 함수를 사용하세요. wsHandler() 함수에서는 클라이언트의 메시지를 지속적으로 수신합니다. websocket.Upgrader()函数将HTTP连接升级为WebSocket连接。在wsHandler()函数中，我们不断地监听来自客户端的消息。

使用WebSocket的优点是它能够轻松地实现双向通讯。客户端和服务器都可以发送和接收消息，而无需关闭连接。而且WebSocket协议的开销较小，能够高效地传输数据。缺点是WebSocket需要浏览器或客户端应用程序特别支持。对于一些低版本浏览器或客户端，WebSocket技术可能存在一些问题。此外，由于WebSocket连接是全双工的，如果服务器需要向大量客户端广播消息，那么它需要维护大量的长连接，这会占用大量的内存资源。

Server-Sent Events

Server-Sent Events（SSE）是另一种在Web应用程序中实现长连接的技术。SSE提供了一种服务器向客户端发送数据的方法，并且这个数据是实时的。与WebSocket不同，SSE是单项流，只允许服务器向客户端发送数据，而不支持客户端向服务器发送数据。

使用Golang实现SSE非常简单。以下是一个SSE服务器的示例：

package main

import (
    "fmt"
    "log"
    "net/http"
)

func sseHandler(w http.ResponseWriter, r *http.Request) {
    w.Header().Set("Content-Type", "text/event-stream")
    w.Header().Set("Cache-Control", "no-cache")
    w.Header().Set("Connection", "keep-alive")

    for {
        fmt.Fprintf(w, "data: %s

", "Hello, world!")
        w.(http.Flusher).Flush()

        // Artificially slow down the server so
        // that we're forced to use multiple connections.
        time.Sleep(1 * time.Second)
    }
}

func main() {
    http.HandleFunc("/sse", sseHandler)
    http.ListenAndServe(":8080", nil)
}

在这个例子中，我们设置HTTP响应头，告诉浏览器它正在接收到Server-Sent Events，而不是在等待一次性响应。我们向客户端发送一个简单的消息，并使用http.Flusher将响应立即发送到客户端。然后我们等待一秒钟，然后再次发送新的消息。

使用Server-Sent Events的优点是它使用HTTP协议，因此不需要任何特殊的协议支持。另外，SSE数据易于解析，非常适合支持服务器向客户端实时推送数据的应用程序。缺点是SSE仅支持单向通信，只允许服务器向客户端发送数据。对于需要客户端向服务器发送数据的应用程序，SSE可能不合适。

gRPC

gRPC是一种高度可扩展和性能优化的远程过程调用（RPC）协议，使用Google的Protocol Buffers进行数据交换。它的目标是是让客户端应用程序在线性时间内与服务器应用程序通信，并提供可扩展和高效的方法来代替传统的HTTP REST API。

尽管gRPC不是专门为长连接而设计的，但它也可以用于实现长连接。由于gRPC使用HTTP/2进行传输，它能够快速而可靠地传输大量数据，并支持服务器推送。使用gRPC，客户端可以与服务器建立长连接，并且服务器可以随时将消息推送到客户端。

以下是一个简单的gRPC服务器示例：

package main

import (
    "context"
    "fmt"
    "log"
    "net"
    "google.golang.org/grpc"
    pb "github.com/proto/example"
)

type server struct{}

func (s *server) Push(ctx context.Context, in *pb.Message) (*pb.Response, error) {
    log.Printf("received message: %v", in)

    return &pb.Response{Code: 200}, nil
}

func main() {
    lis, err := net.Listen("tcp", ":9090")
    if err != nil {
        log.Fatalf("failed to listen: %v", err)
    }
    s := grpc.NewServer()
    pb.RegisterPushServer(s, &server{})
    if err := s.Serve(lis); err != nil {
        log.Fatalf("failed to serve: %v", err)
    }
}

这个例子中，我们定义了一个Push()

WebSocket을 사용하면 쉽게 양방향 통신이 가능하다는 장점이 있습니다. 클라이언트와 서버 모두 연결을 끊지 않고도 메시지를 보내고 받을 수 있습니다. 게다가 WebSocket 프로토콜은 오버헤드가 적고 효율적으로 데이터를 전송할 수 있습니다. 단점은 WebSocket이 브라우저나 클라이언트 애플리케이션의 특별한 지원이 필요하다는 것입니다. 일부 낮은 버전의 브라우저나 클라이언트의 경우 WebSocket 기술에 몇 가지 문제가 있을 수 있습니다. 또한 WebSocket 연결은 전이중 방식이므로 서버가 많은 수의 클라이언트에 메시지를 브로드캐스트해야 하는 경우 많은 수의 긴 연결을 유지해야 하므로 많은 메모리 리소스를 차지하게 됩니다.

http.Flusher

Push()

각 긴 연결 기술에는 고유한 장점과 단점이 있습니다. WebSocket은 양방향 통신이 가능한 강력한 장기 연결 기술이지만, 특별한 지원이 필요하고 서버 리소스에 대한 수요가 높습니다. 서버 전송 이벤트는 사용 및 구현이 쉽지만 단방향 통신만 지원하는 또 다른 간단한 장기 연결 기술입니다. gRPC는 확장성이 뛰어나고 성능이 최적화된 RPC(원격 프로시저 호출) 프로토콜로, 대량의 데이터를 빠르고 안정적으로 전송할 수 있고 서버 푸시를 지원하지만 설정 및 시작에 더 많은 시간과 리소스가 필요할 수 있으며 클라이언트와 클라이언트가 모두 필요합니다. 서버는 gRPC 프로토콜을 지원합니다.

대부분의 웹 애플리케이션의 경우 WebSocket 및 서버 전송 이벤트가 아마도 최선의 선택일 것입니다. 사용 및 구현이 쉽고 대부분의 경우 긴 연결 요구 사항을 충족할 수 있습니다. 대량의 데이터를 처리해야 하거나 서버가 실시간으로 클라이언트에 데이터를 푸시해야 하는 경우 gRPC가 더 나은 선택일 수 있습니다. 어떤 기술을 선택하든 애플리케이션의 요구 사항과 시나리오에 따라 선택하고 최적화해야 합니다.

위 내용은 golang 긴 연결 솔루션의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명：

이전 기사：Golang 세로축 이미지 뒤집기다음 기사：Golang 세로축 이미지 뒤집기