Golang은 웹소켓을 구축합니다.-Golang-php.cn

집

백엔드 개발

Golang

Golang은 웹소켓을 구축합니다.

WBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWBOYWB

May 22, 2023 pm 07:21 PM

Golang은 웹 개발에도 널리 사용되는 빠르게 컴파일되고 효율적이며 안전한 프로그래밍 언어입니다. 그중 Golang을 사용하여 Websocket을 구축하는 것은 매우 인기 있는 애플리케이션 시나리오입니다. 이 기사에서는 Golang을 사용하여 Websocket 애플리케이션을 구축하는 방법을 소개합니다.

1. Websocket이란

Websocket은 브라우저와 서버 간의 양방향 통신 연결을 허용하는 프로토콜입니다. 전통적인 HTTP 프로토콜은 브라우저를 통해 서버에 요청을 보내고 서버로부터 응답을 받을 수만 있습니다. 그러나 Websocket을 사용하면 서버가 브라우저에 적극적으로 메시지를 보내 서버와 브라우저 간의 전이중 통신을 실현할 수 있습니다.

2. Golang이 Websocket을 구현하는 방법

Golang은 표준 라이브러리 net/http와 함께 제공됩니다. 이 패키지는 웹 구축에 사용할 수 있는 http.Server 구조를 제공합니다. 섬기는 사람. 또한 net/http는 WebSocket 서버를 구축하는 데 필요한 모든 기능을 제공하는 websocket 하위 패키지도 제공합니다. net/http，这个包提供了一个http.Server结构体，它可以用来构建Web服务器。除此之外，net/http也提供了一个websocket子包，它为我们提供了构建WebSocket服务器所需的全部功能。

建立WebSocket连接

要建立WebSocket连接，客户端需要向服务器发送一个HTTP请求，并携带Upgrade头部，指示请求升级为WebSocket协议。服务器端在收到此请求后，需要检查Upgrade头部，并根据是否为WebSocket请求来进行相应的处理。

服务器端可以使用websocket.IsWebSocketUpgrade函数来检查请求是否为WebSocket请求，并使用websocket.Upgrade函数升级请求。升级成功后，服务器就可以通过*websocket.Conn类型的连接对象与客户端进行通信了。

func handler(w http.ResponseWriter, r *http.Request) {
    conn, err := upgrader.Upgrade(w, r, nil)
    if err != nil {
        log.Println(err)
        return
    }
    defer conn.Close()
    // 使用conn进行通信
}

로그인 후 복사

其中，upgrader是一个websocket.Upgrader类型的变量，通过设置它的属性可以控制WebSocket连接的处理方式。Upgrade函数在升级请求时会阻塞，因此要将其放在goroutine中运行。

发送和接收WebSocket消息

一旦WebSocket连接建立成功，客户端和服务器都可以通过*websocket.Conn对象进行通信。使用这个对象可以发送和接收WebSocket消息。

发送消息很简单，只需要调用WriteMessage方法即可：

err := conn.WriteMessage(websocket.TextMessage, []byte("hello"))

로그인 후 복사

接收消息的方法有三种：

ReadMessage：阻塞读取，直到有消息到来
NextReader：阻塞等待下一个消息到来
NextWriter：返回一个io.WriteCloser对象，可以使用这个对象发送消息

一般使用ReadMessage方法接收WebSocket消息：

_, message, err := conn.ReadMessage()
if err != nil {
    log.Println(err)
    return
}
log.Printf("recv: %s", message)

로그인 후 복사

三、一个简单的WebSocket应用

在这个例子中，我们将创建一个简单的聊天室应用，客户端发送消息之后，服务器将消息广播给所有连接的客户端。

客户端代码：（使用JavaScript）

<!DOCTYPE html>
<html>
<head>
    <title>Chatroom</title>
</head>
<body>
    <input type="text" id="input-message"/>
    <button onclick="sendMessage()">发送</button>
    <ul id="message-list"></ul>

    <script>
        var ws = new WebSocket("ws://localhost:8080/ws");
        ws.onmessage = function(event) {
            var message = event.data;
            var li = document.createElement("li");
            li.appendChild(document.createTextNode(message));
            document.getElementById("message-list").appendChild(li);
        };

        function sendMessage() {
            var message = document.getElementById("input-message").value;
            ws.send(message);
        }
    </script>
</body>
</html>

로그인 후 복사

服务器端代码：

package main

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

    "github.com/gorilla/websocket"
)

var upgrader = websocket.Upgrader{}

func main() {
    http.HandleFunc("/ws", wsHandler)
    err := http.ListenAndServe(":8080", nil)
    if err != nil {
        log.Fatal("ListenAndServe: ", err)
    }
}

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

    for {
        _, message, err := conn.ReadMessage()
        if err != nil {
            log.Println(err)
            break
        }
        fmt.Printf("recv: %s
", message)

        // 广播给所有客户端
        for _, conn := range conns {
            err := conn.WriteMessage(websocket.TextMessage, message)
            if err != nil {
                log.Println(err)
                break
            }
        }
    }
}

로그인 후 복사

在上面的代码中，我们将所有连接的websocket.Conn对象存储在conns变量中。每当有一个新消息到来时，服务器会将消息广播给所有客户端。

总结

使用Golang搭建WebSocket应用程序非常简单，只需要导入net/http和websocket

WebSocket 연결 설정

WebSocket 연결을 설정하려면 클라이언트는 서버에 HTTP 요청을 보내고 요청이 업그레이드되었음을 나타내는 업그레이드 헤더를 전달해야 합니다. 웹소켓 프로토콜. 이 요청을 받은 후 서버는 업그레이드 헤더를 확인하고 WebSocket 요청인지 여부에 따라 적절하게 처리해야 합니다. 🎜🎜서버는 websocket.IsWebSocketUpgrade 함수를 사용하여 해당 요청이 WebSocket 요청인지 확인하고, websocket.Upgrade 함수를 사용하여 요청을 업그레이드할 수 있습니다. 업그레이드가 성공한 후 서버는 *websocket.Conn 유형의 연결 개체를 통해 클라이언트와 통신할 수 있습니다. 🎜rrreee🎜 그 중 upgrader는 websocket.Upgrader 유형의 변수로 해당 속성을 설정하여 WebSocket 연결 처리 방법을 제어할 수 있습니다. 업그레이드 기능은 요청을 업그레이드할 때 차단되므로 고루틴에서 실행해야 합니다. 🎜

WebSocket 메시지 보내기 및 받기

🎜WebSocket 연결이 성공적으로 설정되면 클라이언트와 서버 모두

*websocket.Conn 개체가 통신합니다. 이 개체를 사용하여 WebSocket 메시지를 보내고 받습니다. 🎜🎜메시지 보내기는 매우 간단합니다. <code>WriteMessage

메서드를 호출하면 됩니다. 🎜rrreee🎜메시지를 받는 방법에는 세 가지가 있습니다. 🎜

ReadMessage: 차단 메시지가 도착할 때까지 Get 읽기
NextReader: 다음 메시지가 도착할 때까지 기다리는 블록
NextWriter: io .WriteCloser 객체, 이 객체를 사용하여 메시지를 보낼 수 있습니다.

🎜일반적으로 WebSocket 메시지를 수신하려면 ReadMessage 메서드를 사용하세요: 🎜rrreee🎜 3. A 간단한 WebSocket 애플리케이션🎜🎜 이 예에서는 클라이언트가 메시지를 보낸 후 서버가 연결된 모든 클라이언트에게 메시지를 브로드캐스트합니다. 🎜🎜클라이언트 측 코드: (JavaScript 사용) 🎜rrreee🎜서버 측 코드: 🎜rrreee🎜위 코드에서는 연결된 모든 websocket.Conn 개체를

conns 코드에 저장합니다. > 변수. 새 메시지가 도착할 때마다 서버는 모든 클라이언트에게 메시지를 브로드캐스트합니다. 🎜🎜요약🎜🎜Golang을 사용하여 WebSocket 애플리케이션을 구축하는 것은 매우 간단합니다. <code>net/http

및 websocket 패키지를 가져오고 제공된 API를 직접 사용하면 됩니다. WebSocket 애플리케이션 개발을 완료하기 위해 표준 라이브러리를 사용합니다. 이 글이 Golang Websocket 개발에 도움이 되기를 바랍니다. 🎜

위 내용은 Golang은 웹소켓을 구축합니다.의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

본 웹사이트의 성명

본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.

핫 AI 도구

Undresser.AI Undress

사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover

사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool

무료로 이미지를 벗다

Clothoff.io

AI 옷 제거제

AI Hentai Generator

AI Hentai를 무료로 생성하십시오.

뜨거운 도구

메모장++7.3.1

사용하기 쉬운 무료 코드 편집기

SublimeText3 중국어 버전

중국어 버전, 사용하기 매우 쉽습니다.

스튜디오 13.0.1 보내기

강력한 PHP 통합 개발 환경

드림위버 CS6

시각적 웹 개발 도구

SublimeText3 Mac 버전

신 수준의 코드 편집 소프트웨어(SublimeText3)

뜨거운 주제

Gmail 이메일의 로그인 입구는 어디에 있나요?

7463

Cakephp 튜토리얼

1376

Steam의 계정 이름 형식은 무엇입니까?

Win11 활성화 키 영구

NYT 연결 힌트와 답변

Related knowledge

Debian Openssl의 취약점은 무엇입니까? Apr 02, 2025 am 07:30 AM

보안 통신에 널리 사용되는 오픈 소스 라이브러리로서 OpenSSL은 암호화 알고리즘, 키 및 인증서 관리 기능을 제공합니다. 그러나 역사적 버전에는 알려진 보안 취약점이 있으며 그 중 일부는 매우 유해합니다. 이 기사는 데비안 시스템의 OpenSSL에 대한 일반적인 취약점 및 응답 측정에 중점을 둘 것입니다. DebianopensSL 알려진 취약점 : OpenSSL은 다음과 같은 몇 가지 심각한 취약점을 경험했습니다. 심장 출혈 취약성 (CVE-2014-0160) :이 취약점은 OpenSSL 1.0.1 ~ 1.0.1F 및 1.0.2 ~ 1.0.2 베타 버전에 영향을 미칩니다. 공격자는이 취약점을 사용하여 암호화 키 등을 포함하여 서버에서 무단 읽기 민감한 정보를 사용할 수 있습니다.