Mari kita bincangkan tentang cara melaksanakan SSE dalam Go? Apa yang perlu saya perhatikan?

Artikel ini membawakan anda pengetahuan yang berkaitan tentang Go terutamanya tentang cara Go melaksanakan SSE dan perkara yang perlu diberi perhatian Rakan-rakan yang berminat boleh melihatnya bersama-sama. Semua orang membantu.

1. Kod pelayan

package main

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

type SSE struct {
}

func (sse *SSE) ServeHTTP(rw http.ResponseWriter, req *http.Request) {
   flusher, ok := rw.(http.Flusher)
   if !ok {
      http.Error(rw, "Streaming unsupported!", http.StatusInternalServerError)
      return
   }

   rw.Header().Set("Content-Type", "text/event-stream")
   rw.Header().Set("Cache-Control", "no-cache")
   rw.Header().Set("Connection", "keep-alive")
   rw.Header().Set("Access-Control-Allow-Origin", "*")
   for {
      select {
      case <-req.Context().Done():
         fmt.Println("req done...")
         return
      case <-time.After(500 * time.Millisecond):
         // 返回数据包含id、event(非必须)、data，结尾必须使用\n\n
         fmt.Fprintf(rw, "id: %d\nevent: ping \ndata: %d\n\n", time.Now().Unix(), time.Now().Unix())
         flusher.Flush()
      }
   }

}

func SendData(data chan int64) chan int64 {
   for {
      data <- time.Now().Unix()
      time.Sleep(time.Second * time.Duration(2))
   }
}
func main() {
   http.Handle("/sse", &SSE{})
   http.ListenAndServe(":8080", nil)
}

Kod pelanggan

    const source = new EventSource('http://127.0.0.1:8080/sse');
    source.onopen = () => {
        console.log('链接成功');
    };
    source.addEventListener("ping",function(res){
         console.log('获得数据:' + res.data);
    })
    source.onerror = (err) => {
        console.log(err);
    };

3. Nota (Penting)

Jika pelayan menyediakan parameter event (mesej lengkap termasuk id, data, acara), maka pelanggan perlu Gunakan addEventListener untuk mendengar acara ini secara eksplisit untuk mendapatkan mesej secara normal, jika tidak, acara tidak akan dicetuskan. Jika pelayan tidak menyediakan event parameter, hanya id、data, dsb., anda boleh menggunakan onmessage panggil balik untuk mendengar mesej:

Senario 1: Pelayan mempunyai event parameter dan mentakrifkan parameter yang dipanggil ping Peristiwa khusus

const source = new EventSource('http://127.0.0.1:8080/sse');
source.onopen = () => {
    console.log('链接成功');
};
source.addEventListener("ping",function(res){
     console.log('获得的数据是:' + res.data);
})
source.onerror = (err) => {
    console.log(err);
};

Senario 2: Data yang dikembalikan oleh pelayan tidak mengandungi event

const source = new EventSource('http://127.0.0.1:8080/sse');
  source.onopen = () => {
      console.log('链接成功');
  };
  source.onmessage(function(res){
       console.log('获得的数据是:' + res.data);
  })
  source.onerror = (err) => {
      console.log(err);
  };

[Pembelajaran yang disyorkan: pergi tutorial video]                                                                                                                       

Atas ialah kandungan terperinci Mari kita bincangkan tentang cara melaksanakan SSE dalam Go? Apa yang perlu saya perhatikan?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!