Go 웹소켓 구현(코드 포함)-Golang-php.cn

집

백엔드 개발

Golang

Go 웹소켓 구현(코드 포함)

尚

Nov 25, 2019 pm 03:02 PM

Go 웹소켓 구현(코드 포함)

websocket은 핸드셰이크와 데이터 전송 단계, 즉 HTTP 핸드셰이크 + 이중 TCP 연결로 구분됩니다.

#🎜 🎜 #핸드셰이크 단계

핸드셰이크 단계는 일반 HTTP입니다.

클라이언트가 다음 메시지를 보냅니다.

GET /chat HTTP/1.1
    Host: server.example.com
    Upgrade: websocket
    Connection: Upgrade
    Sec-WebSocket-Key: dGhlIHNhbXBsZSBub25jZQ==
    Origin: http://example.com
    Sec-WebSocket-Version: 13

서버 반환 메시지:

HTTP/1.1 101 Switching Protocols
Upgrade: websocket
Connection: Upgrade
Sec-WebSocket-Accept: s3pPLMBiTxaQ9kYGzzhZRbK+xOo=

Sec-WebSocket-Accept의 계산 방법은 다음과 같습니다.

base64(hsa1(sec-websocket-key + 258EAFA5-E914-47DA-95CA-C5AB0DC85B11))

Sec-WebSocket-Accept가 잘못 계산되면 브라우저에 다음 메시지가 표시됩니다. #🎜 🎜 #

Sec-WebSocket-Accept 불일치

반환이 성공하면 Websocket은 onopen 이벤트를 다시 호출합니다

Data 전송#🎜🎜 #웹소켓의 데이터 전송에 사용되는 프로토콜은 다음과 같습니다. #매개변수에 대한 자세한 설명:

FIN: 1비트, 메시지의 마지막 메시지 조각임을 나타내는 데 사용됩니다. 물론 첫 번째 메시지 조각이 마지막 메시지일 수도 있습니다. 조각;

RSV1, RSV2, RSV3: 두 당사자 간에 맞춤 계약이 없는 경우 이 비트의 값은 0이어야 하며, 그렇지 않으면 WebSocket 연결이 끊어져야 합니다. 🎜🎜##🎜 🎜#Opcode: 4자리 opcode, 페이로드 데이터를 정의합니다. 알 수 없는 opcode가 수신되면 연결을 끊어야 합니다. 정의된 opcode는 다음과 같습니다. Go 웹소켓 구현(코드 포함)

* %x0 연속 메시지 조각

* %x1은 텍스트 메시지 조각을 나타냅니다.

* %x2는 바이너리 메시지 조각을 나타냅니다.

* %x3-7은 다음과 같습니다. 메시지 조각용으로 예약된 향후 비제어 작업 코드

* %x8은 연결이 닫혔음을 의미합니다.

* %x9는 하트비트 확인 핑을 의미합니다

* % xA는 하트비트 확인을 의미합니다. pong

* %xB-F 향후 제어 메시지 조각을 위한 예약된 opcode

Mask:

1 비트, 전송된 데이터를 정의 마스크가 있습니까? 1로 설정되면 클라이언트가 서버로 보내는 모든 메시지에 대해 마스크 키가 1이 됩니다. #🎜🎜 #페이로드 길이:

전송된 데이터의 길이는 바이트로 표시됩니다: 7비트, 7+16비트 또는 7+64비트.

Masking-key:

0 또는 4바이트, 클라이언트가 서버로 보낸 데이터는 내장된 32비트 값으로 마스크됩니다. 마스크 키는 다음 경우에만 존재합니다. 마스크 비트는 1로 설정됩니다.

페이로드 데이터:

(x+y)비트, 페이로드 데이터는 확장 데이터와 애플리케이션 데이터의 길이를 합한 것입니다.

확장 데이터:

x비트, 클라이언트와 서버 사이에 특별한 합의가 없는 경우 확장 데이터의 길이는 항상 0이며 모든 확장은 다음을 지정해야 합니다. 확장자 데이터의 길이 또는 길이를 계산하는 방법, 핸드셰이크 시 올바른 핸드셰이크를 결정하는 방법. 확장 데이터가 있는 경우 페이로드 데이터의 길이에 확장 데이터가 포함됩니다.

응용 프로그램 데이터:

y 비트, 확장 데이터 뒤에 배치되는 모든 응용 프로그램 데이터, 응용 프로그램 데이터의 길이 = 로드 데이터의 길이 - 로드 데이터의 길이 확장된 데이터.

Instance

go를 사용한 구체적인 구현 예: Client ：# 🎜🎜#

html：

<html>
    <head>
        <script type="text/javascript" src="./jquery.min.js"></script>
    </head>
    <body>
        <input type="button" id="connect" value="websocket connect" />
        <input type="button" id="send" value="websocket send" />
        <input type="button" id="close" value="websocket close" />
    </body>
    <script type="text/javascript" src="./websocket.js"></script>
</html>

js：

var socket;
 
$("#connect").click(function(event){
    socket = new WebSocket("ws://127.0.0.1:8000");
 
    socket.onopen = function(){
        alert("Socket has been opened");
    }
 
    socket.onmessage = function(msg){
        alert(msg.data);
    }
 
    socket.onclose = function() {
        alert("Socket has been closed");
    }
});
 
$("#send").click(function(event){
    socket.send("send from client");
});
 
$("#close").click(function(event){
    socket.close();
})

Server:

package main
 
import(
    "net"
    "log"
    "strings"
    "crypto/sha1"
    "io"
    "encoding/base64"
    "errors"
)
 
func main() {
    ln, err := net.Listen("tcp", ":8000")
    if err != nil {
        log.Panic(err)
    }
 
    for {
        conn, err := ln.Accept()
        if err != nil {
            log.Println("Accept err:", err)
        }
        for {
            handleConnection(conn)
        }
    }
}
 
func handleConnection(conn net.Conn) {
    content := make([]byte, 1024)
    _, err := conn.Read(content)
    log.Println(string(content))
    if err != nil {
        log.Println(err)
    }
 
    isHttp := false
    // 先暂时这么判断
    if string(content[0:3]) == "GET" {
        isHttp = true;
    }
    log.Println("isHttp:", isHttp)
    if isHttp {
        headers := parseHandshake(string(content))
        log.Println("headers", headers)
        secWebsocketKey := headers["Sec-WebSocket-Key"]
 
        // NOTE：这里省略其他的验证
        guid := "258EAFA5-E914-47DA-95CA-C5AB0DC85B11"
 
        // 计算Sec-WebSocket-Accept
        h := sha1.New()
        log.Println("accept raw:", secWebsocketKey + guid)
 
        io.WriteString(h, secWebsocketKey + guid)
        accept := make([]byte, 28)
        base64.StdEncoding.Encode(accept, h.Sum(nil))
        log.Println(string(accept))
 
        response := "HTTP/1.1 101 Switching Protocols\r\n"
        response = response + "Sec-WebSocket-Accept: " + string(accept) + "\r\n"
        response = response + "Connection: Upgrade\r\n"
        response = response + "Upgrade: websocket\r\n\r\n"
         
             
        log.Println("response:", response)
        if lenth, err := conn.Write([]byte(response)); err != nil {
            log.Println(err)
        } else {
            log.Println("send len:", lenth)
        }
 
        wssocket := NewWsSocket(conn)
        for {
            data, err := wssocket.ReadIframe()
            if err != nil {
                log.Println("readIframe err:" , err)
            }
            log.Println("read data:", string(data))
            err = wssocket.SendIframe([]byte("good"))
            if err != nil {
                log.Println("sendIframe err:" , err)
            }
            log.Println("send data")
        }
         
    } else {
        log.Println(string(content))
        // 直接读取
    }
}
 
type WsSocket struct {
    MaskingKey []byte
    Conn net.Conn
}
 
func NewWsSocket(conn net.Conn) *WsSocket {
    return &WsSocket{Conn: conn}
}
 
func (this *WsSocket)SendIframe(data []byte) error {
    // 这里只处理data长度<125的
    if len(data) >= 125 {
        return errors.New("send iframe data error")
    }
 
    lenth := len(data)
    maskedData := make([]byte, lenth)
    for i := 0; i < lenth; i++ {
        if this.MaskingKey != nil {
            maskedData[i] = data[i] ^ this.MaskingKey[i % 4]
        } else {
            maskedData[i] = data[i]
        }
    }
 
    this.Conn.Write([]byte{0x81})
 
    var payLenByte byte
    if this.MaskingKey != nil && len(this.MaskingKey) != 4 {
        payLenByte = byte(0x80) | byte(lenth)
        this.Conn.Write([]byte{payLenByte})
        this.Conn.Write(this.MaskingKey)
    } else {
        payLenByte = byte(0x00) | byte(lenth)
        this.Conn.Write([]byte{payLenByte})
    }
    this.Conn.Write(data)
    return nil
}
 
func (this *WsSocket)ReadIframe() (data []byte, err error){
    err = nil
 
    //第一个字节：FIN + RSV1-3 + OPCODE
    opcodeByte := make([]byte, 1)
    this.Conn.Read(opcodeByte)
 
    FIN := opcodeByte[0] >> 7
    RSV1 := opcodeByte[0] >> 6 & 1
    RSV2 := opcodeByte[0] >> 5 & 1
    RSV3 := opcodeByte[0] >> 4 & 1
    OPCODE := opcodeByte[0] & 15
    log.Println(RSV1,RSV2,RSV3,OPCODE)
 
    payloadLenByte := make([]byte, 1)
    this.Conn.Read(payloadLenByte)
    payloadLen := int(payloadLenByte[0] & 0x7F)
    mask := payloadLenByte[0] >> 7
 
    if payloadLen == 127 {
        extendedByte := make([]byte, 8)
        this.Conn.Read(extendedByte)
    }
     
    maskingByte := make([]byte, 4)
    if mask == 1 {
        this.Conn.Read(maskingByte)
        this.MaskingKey = maskingByte
    }
 
    payloadDataByte := make([]byte, payloadLen)
    this.Conn.Read(payloadDataByte)
    log.Println("data:", payloadDataByte)
 
    dataByte := make([]byte, payloadLen)
    for i := 0; i < payloadLen; i++ {
        if mask == 1 {
            dataByte[i] = payloadDataByte[i] ^ maskingByte[i % 4]
        } else {
            dataByte[i] = payloadDataByte[i]
        }
    }
 
    if FIN == 1 {
        data = dataByte
        return
    }
 
    nextData, err := this.ReadIframe()
    if err != nil {
        return
    }
    data = append(data, nextData…)
    return
}
 
func parseHandshake(content string) map[string]string {
    headers := make(map[string]string, 10)
    lines := strings.Split(content, "\r\n")
 
    for _,line := range lines {
        if len(line) >= 0 {
            words := strings.Split(line, ":")
            if len(words) == 2 {
                headers[strings.Trim(words[0]," ")] = strings.Trim(words[1], " ")
            }
        }
    }
    return headers
}

더 많은 바둑 언어 지식을 보려면 팔로우하세요 #🎜 🎜#go 언어 튜토리얼 컬럼.

위 내용은 Go 웹소켓 구현(코드 포함)의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명

이 기사는 博客园에서 복제됩니다. 침해가 있는 경우 admin@php.cn으로 문의하시기 바랍니다. 삭제

관련 기사

마스터 링 GO 줄 : '문자열'패키지에 대한 깊은 다이빙May 12, 2025 am 12:05 AM

텍스트 데이터를 처리하는 도구를 제공하고 기본 문자열에서 고급 정규 표현식에 이르기까지 텍스트 데이터를 처리 할 수있는 도구를 제공하기 때문에 이동 중 "문자열"패키지에주의해야합니다. 1) "Strings"패키지는 성능 문제를 피하기 위해 문자열을 스플 라이스하는 데 사용되는 결합 기능과 같은 효율적인 스트링 작업을 제공합니다. 2) 포함 함수와 같은 고급 함수가 포함되어있어 문자열에 특정 문자 세트가 포함되어 있는지 확인합니다. 3) 교체 함수는 문자열의 하위 문자열을 대체하는 데 사용되며 교체 순서 및 사례 감도에주의를 기울여야합니다. 4) 분할 함수는 분리기에 따라 문자열을 분할 할 수 있으며 종종 정규 발현 처리에 사용됩니다. 5) 사용 할 때 성능을 고려해야합니다.

Go의 '인코딩/이진'패키지 : 이진 작업을위한 이동May 12, 2025 am 12:03 AM

"인코딩/바이너리"패키지 인테이블 링 베이너리 데이터, 1) ItsupportsBothlittle-endianandbig-endianByteorders, CruialCross-SystemCompatibility .2) ThePackagealLowworkingwithcus

바이트 슬라이스 조작 자습서 : '바이트'패키지 마스터 링May 12, 2025 am 12:02 AM

바이트 패키지를 GO에서 마스터하면 코드의 효율성과 우아함을 향상시키는 데 도움이 될 수 있습니다. 1) 바이트 패키지는 이진 데이터를 구문 분석, 네트워크 프로토콜 및 메모리 관리에 중요합니다. 2) BYTES.BUFFER를 사용하여 점차적으로 바이트 슬라이스를 작성하십시오. 3) 바이트 패키지는 바이트 슬라이스 검색, 교체 및 세분화 기능을 제공합니다. 4) BYTES.READER 유형은 특히 I/O 작업에서 바이트 슬라이스의 데이터를 읽는 데 적합합니다. 5) Bytes 패키지는 GO의 가비지 수집기와 협력하여 빅 데이터 처리의 효율성을 향상시킵니다.

'문자열'패키지를 사용하여 GO에서 문자열을 조작하는 방법은 무엇입니까?May 12, 2025 am 12:01 AM

문자열을 조작 할 때 "문자열"패키지를 사용할 수 있습니다. 1) Strings.trimSpace를 사용하여 문자열의 양쪽 끝에서 공백 문자를 제거하십시오. 2) strings.split을 사용하여 지정된 구분 기호에 따라 문자열을 슬라이스로 분할하십시오. 3) 문자열 슬라이스를 문자열을 통해 하나의 문자열로 병합합니다. 4) 문자열에 포함하여 문자열에 특정 하위 문자열이 포함되어 있는지 확인하십시오. 5) STRINGS.REPLACEALL을 사용하여 글로벌 교체를 수행하십시오. 사용할 때 성능과 잠재적 인 함정에주의하십시오.

'바이트'패키지를 사용하여 바이트 슬라이스를 이동하는 방법 (단계별)May 12, 2025 am 12:01 AM

thebytespackageingoishlytectivefificbyteslicemanipulation, ontomingfortionsforctionsforctions, splitting, andbuffering

Go Bytes 패키지 : 대안은 무엇입니까?May 11, 2025 am 12:11 AM

thealternativeStogo'sbytespackageinincludestringspackage, bufiopackage, and customstructs.1) thestringspackagecanbeusedforbytemanipulationbytestostringsandback.2) thebufiopackageisidealforhandlinglargestreamsofficationsificationsificationsly

바이트 슬라이스 조작 GO : '바이트'패키지의 전력May 11, 2025 am 12:09 AM

"바이트"패키지 인테이션 전신 formanipulatingByteslices, CruialForbinaryData, NetworkProtocols 및 Filei/O.itoffersFunctions likeIndexForsearching, BufferforHandlingLargedAtasets, ReaderForsimulatingstreamReading 및 조종 전망

Go Strings 패키지 : 문자열 조작에 대한 포괄적 인 안내서May 11, 2025 am 12:08 AM

GO'SSTRINGSPACKAGEISCRUCIALFORFOFFICIENTSTRINGMENIPULATION, OffingerToolSlikestrings.split (), strings.join (), strings.Replaceall () 및 strings.contains () .split () DivideStringIntoSubstrings; 2) strings.join () stringsintring;

See all articles

핫 AI 도구

Undresser.AI Undress

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

AI Clothes Remover

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

Undress AI Tool

무료로 이미지를 벗다

Clothoff.io

AI 옷 제거제

Video Face Swap

완전히 무료인 AI 얼굴 교환 도구를 사용하여 모든 비디오의 얼굴을 쉽게 바꾸세요!

뜨거운 도구

SecList

SecLists는 최고의 보안 테스터의 동반자입니다. 보안 평가 시 자주 사용되는 다양한 유형의 목록을 한 곳에 모아 놓은 것입니다. SecLists는 보안 테스터에게 필요할 수 있는 모든 목록을 편리하게 제공하여 보안 테스트를 더욱 효율적이고 생산적으로 만드는 데 도움이 됩니다. 목록 유형에는 사용자 이름, 비밀번호, URL, 퍼징 페이로드, 민감한 데이터 패턴, 웹 셸 등이 포함됩니다. 테스터는 이 저장소를 새로운 테스트 시스템으로 간단히 가져올 수 있으며 필요한 모든 유형의 목록에 액세스할 수 있습니다.

Dreamweaver Mac版

시각적 웹 개발 도구

MinGW - Windows용 미니멀리스트 GNU

이 프로젝트는 osdn.net/projects/mingw로 마이그레이션되는 중입니다. 계속해서 그곳에서 우리를 팔로우할 수 있습니다. MinGW: GCC(GNU Compiler Collection)의 기본 Windows 포트로, 기본 Windows 애플리케이션을 구축하기 위한 무료 배포 가능 가져오기 라이브러리 및 헤더 파일로 C99 기능을 지원하는 MSVC 런타임에 대한 확장이 포함되어 있습니다. 모든 MinGW 소프트웨어는 64비트 Windows 플랫폼에서 실행될 수 있습니다.