From c2fd45c2ecfb05176becd847c34a1563e4e35222 Mon Sep 17 00:00:00 2001 From: Smile Rex Date: Tue, 10 Mar 2026 00:13:15 +0300 Subject: [PATCH] new quic release [chat tests] 3 --- go.mod | 12 +++++++++++ go.sum | 26 ++++++++++++++++++++++++ main.go | 62 ++++++++++++++++++++++++++++----------------------------- 3 files changed, 68 insertions(+), 32 deletions(-) diff --git a/go.mod b/go.mod index f3808e4..c830b3a 100644 --- a/go.mod +++ b/go.mod @@ -1,3 +1,15 @@ module qgo go 1.25.0 + +require github.com/quic-go/webtransport-go v0.10.0 + +require ( + github.com/dunglas/httpsfv v1.1.0 // indirect + github.com/quic-go/qpack v0.6.0 // indirect + github.com/quic-go/quic-go v0.59.0 // indirect + golang.org/x/crypto v0.41.0 // indirect + golang.org/x/net v0.43.0 // indirect + golang.org/x/sys v0.35.0 // indirect + golang.org/x/text v0.28.0 // indirect +) diff --git a/go.sum b/go.sum index e69de29..c288757 100644 --- a/go.sum +++ b/go.sum @@ -0,0 +1,26 @@ +github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c= +github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38= +github.com/dunglas/httpsfv v1.1.0 h1:Jw76nAyKWKZKFrpMMcL76y35tOpYHqQPzHQiwDvpe54= +github.com/dunglas/httpsfv v1.1.0/go.mod h1:zID2mqw9mFsnt7YC3vYQ9/cjq30q41W+1AnDwH8TiMg= +github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM= +github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4= +github.com/quic-go/qpack v0.6.0 h1:g7W+BMYynC1LbYLSqRt8PBg5Tgwxn214ZZR34VIOjz8= +github.com/quic-go/qpack v0.6.0/go.mod h1:lUpLKChi8njB4ty2bFLX2x4gzDqXwUpaO1DP9qMDZII= +github.com/quic-go/quic-go v0.59.0 h1:OLJkp1Mlm/aS7dpKgTc6cnpynnD2Xg7C1pwL6vy/SAw= +github.com/quic-go/quic-go v0.59.0/go.mod h1:upnsH4Ju1YkqpLXC305eW3yDZ4NfnNbmQRCMWS58IKU= +github.com/quic-go/webtransport-go v0.10.0 h1:LqXXPOXuETY5Xe8ITdGisBzTYmUOy5eSj+9n4hLTjHI= +github.com/quic-go/webtransport-go v0.10.0/go.mod h1:LeGIXr5BQKE3UsynwVBeQrU1TPrbh73MGoC6jd+V7ow= +github.com/stretchr/testify v1.11.1 h1:7s2iGBzp5EwR7/aIZr8ao5+dra3wiQyKjjFuvgVKu7U= +github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD981Nm4B6U= +go.uber.org/mock v0.5.2 h1:LbtPTcP8A5k9WPXj54PPPbjcI4Y6lhyOZXn+VS7wNko= +go.uber.org/mock v0.5.2/go.mod h1:wLlUxC2vVTPTaE3UD51E0BGOAElKrILxhVSDYQLld5o= +golang.org/x/crypto v0.41.0 h1:WKYxWedPGCTVVl5+WHSSrOBT0O8lx32+zxmHxijgXp4= +golang.org/x/crypto v0.41.0/go.mod h1:pO5AFd7FA68rFak7rOAGVuygIISepHftHnr8dr6+sUc= +golang.org/x/net v0.43.0 h1:lat02VYK2j4aLzMzecihNvTlJNQUq316m2Mr9rnM6YE= +golang.org/x/net v0.43.0/go.mod h1:vhO1fvI4dGsIjh73sWfUVjj3N7CA9WkKJNQm2svM6Jg= +golang.org/x/sys v0.35.0 h1:vz1N37gP5bs89s7He8XuIYXpyY0+QlsKmzipCbUtyxI= +golang.org/x/sys v0.35.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k= +golang.org/x/text v0.28.0 h1:rhazDwis8INMIwQ4tpjLDzUhx6RlXqZNPEM0huQojng= +golang.org/x/text v0.28.0/go.mod h1:U8nCwOR8jO/marOQ0QbDiOngZVEBB7MAiitBuMjXiNU= +gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA= +gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM= diff --git a/main.go b/main.go index 5831d4a..2f7c4fe 100644 --- a/main.go +++ b/main.go @@ -1,48 +1,46 @@ package main import ( + "context" "fmt" "net/http" + + "github.com/quic-go/webtransport-go" ) func main() { + wm := &webtransport.Server{ + CheckOrigin: func(r *http.Request) bool { return true }, + } + mux := http.NewServeMux() - - mux.HandleFunc("/api/hello", func(w http.ResponseWriter, r *http.Request) { - // 1. Настройка CORS для работы со Svelte и другими фронтендами - w.Header().Set("Access-Control-Allow-Origin", "*") - w.Header().Set("Access-Control-Allow-Methods", "GET, POST, OPTIONS") - w.Header().Set("Access-Control-Allow-Headers", "Content-Type, Authorization") - - // Если это Preflight-запрос (OPTIONS), просто отвечаем 200 OK - if r.Method == "OPTIONS" { - w.WriteHeader(http.StatusOK) + mux.HandleFunc("/chat", func(w http.ResponseWriter, r *http.Request) { + session, err := wm.Upgrade(w, r) + if err != nil { + fmt.Printf("Ошибка апгрейда: %v\n", err) return } - - // 2. Логирование для отладки - // Traefik v3 пробрасывает протокол. Проверим также заголовок X-Forwarded-Proto - proto := r.Header.Get("X-Forwarded-Proto") - if proto == "" { - proto = r.Proto - } - - fmt.Printf("Получен запрос. Метод: %s, Протокол: %s, Путь: %s\n", r.Method, proto, r.URL.Path) - - // 3. Ответ клиенту - w.Header().Set("Content-Type", "text/plain; charset=utf-8") - w.WriteHeader(http.StatusOK) - - response := fmt.Sprintf("Привет! Твой запрос обработан через Traefik v3.\nПротокол (внутренний): %s\n", r.Proto) - w.Write([]byte(response)) + go handleChatSession(session) }) - // Порт 8080 внутри контейнера - port := ":8080" - fmt.Printf("Сервер запущен на порту %s...\n", port) + fmt.Println("Сервер чата запущен на :8080") + // Traefik пробросит сюда HTTP/3 запрос + http.ListenAndServe(":8080", mux) +} - err := http.ListenAndServe(port, mux) - if err != nil { - fmt.Printf("Ошибка при запуске сервера: %s\n", err) +func handleChatSession(session *webtransport.Session) { + for { + // Принимаем двунаправленный поток (для сообщений) + stream, err := session.AcceptStream(context.Background()) + if err != nil { + return + } + go func(s webtransport.Stream) { + defer s.Close() + buf := make([]byte, 1024) + n, _ := s.Read(buf) + fmt.Printf("Сообщение: %s\n", string(buf[:n])) + s.Write([]byte("Сервер: Принято!")) + }(*stream) } }