国产av日韩一区二区三区精品,成人性爱视频在线观看,国产,欧美,日韩,一区,www.成色av久久成人,2222eeee成人天堂

首頁(yè) 後端開(kāi)發(fā) Golang SSE最簡(jiǎn)單的demo(伺服器傳送事件)

SSE最簡(jiǎn)單的demo(伺服器傳送事件)

Nov 24, 2024 am 06:27 AM

介紹

伺服器傳送事件 (SSE) 是一種 Web 技術(shù),可讓伺服器透過(guò) HTTP 將即時(shí)更新推送到客戶(hù)端。與 WebSocket 不同,SSE 實(shí)作起來(lái)更簡(jiǎn)單,因?yàn)樗褂脧乃欧鞯綖g覽器的單向通訊通道,並透過(guò)常規(guī) HTTP 連線(xiàn)工作。它對(duì)於需要定期更新的應(yīng)用程式特別有用,例如即時(shí)比分、通知或即時(shí)監(jiān)控儀表板。

我創(chuàng)建了這個(gè)演示,因?yàn)槲夷壳罢陂_(kāi)發(fā)一個(gè)應(yīng)用程序,人工智慧可以在其中討論各種主題。我想實(shí)現(xiàn)一些類(lèi)似流的功能,並發(fā)現(xiàn)了名為“SSE”的技術(shù)。

演示概述

此示範(fàn)展示如何使用伺服器傳送事件 (SSE) 將即時(shí)更新從 API 傳送到瀏覽器。在此範(fàn)例中,瀏覽器顯示伺服器發(fā)送的一系列範(fàn)例訊息。該演示的簡(jiǎn)單性使其成為了解 SSE 如何運(yùn)作並將其整合到您的專(zhuān)案中的絕佳起點(diǎn)。

示範(fàn)影片

下面的影片示範(fàn)了伺服器發(fā)送事件 (SSE) 示範(fàn)如何即時(shí)運(yùn)作。觀看此影片將使您更了解客戶(hù)端和伺服器如何互動(dòng)以提供即時(shí)更新。

The simplest demo on SSE(Server-Send Events)

執(zhí)行

伺服器發(fā)送事件(SSE)演示的核心實(shí)作分為兩部分:前端和後端。完整的原始程式碼可在 GitHub 上找到:sse-demo 儲(chǔ)存庫(kù)。

前端 (ui/src/app/page.tsx)

前端使用 React 構(gòu)建,提供啟動(dòng)和停止 SSE 連接的按鈕,顯示來(lái)自伺服器的即時(shí)訊息。主要亮點(diǎn)如下:

  1. 連接到 SSE:handleStartConnection 函數(shù)建立一個(gè)連接到 /events 端點(diǎn)的 EventSource 物件。它監(jiān)聽(tīng)訊息、開(kāi)啟事件和錯(cuò)誤事件:

    • onmessage:處理傳入訊息並更新訊息狀態(tài)。
    • onopen:建立連線(xiàn)時(shí)記錄。
    • onerror:處理錯(cuò)誤、記錄詳細(xì)資訊並在需要時(shí)關(guān)閉連線(xiàn)。
  2. 停止連線(xiàn):handleStopConnection函數(shù)關(guān)閉SSE連線(xiàn)並進(jìn)行清理。

  3. UI:此頁(yè)麵包括一個(gè)簡(jiǎn)單的介面,帶有開(kāi)始/停止按鈕和一個(gè)顯示訊息的清單。

"use client";

import type React from "react";
import { useState } from "react";

const App: React.FC = () => {
  const [messages, setMessages] = useState<string[]>([]);
  const [eventSource, setEventSource] = useState<EventSource | null>(null);

  const handleStartConnection = () => {
    const newEventSource = new EventSource("http://localhost:8080/events");

    const handleOnMessage = (event: MessageEvent) => {
      console.log("onmessage", event.data);
      setMessages((prev) => [...prev, event.data]);
    };

    const handleOnOpen = () => {
      console.log("Connection established");
    };

    const handleOnError = (error: Event) => {
      console.error("onerror", error);
      console.log("readyState:", newEventSource.readyState);
      console.log("Connection error occurred.");
      newEventSource.close();
      setEventSource(null);
    };

    const handleOnClose = () => {
      console.log("Connection is being closed by the server.");
      newEventSource.close();
      setEventSource(null);
    };

    newEventSource.onmessage = handleOnMessage;
    newEventSource.onopen = handleOnOpen;
    newEventSource.onerror = handleOnError;
    newEventSource.addEventListener("close", handleOnClose);

    setEventSource(newEventSource);
  };

  const handleStopConnection = () => {
    if (eventSource) {
      eventSource.close();
      setEventSource(null);
      console.log("Connection closed");
    }
  };

  return (
    <div>
      <h1>Server-Sent Events Demo</h1>
      <button
        type="button"
        onClick={handleStartConnection}
        disabled={!!eventSource}
        className="bg-blue-500 hover:bg-blue-700 text-white font-bold py-2 px-4 rounded disabled:opacity-50"
      >
        Start Connection
      </button>
      <button
        type="button"
        onClick={handleStopConnection}
        disabled={!eventSource}
        className="bg-red-500 hover:bg-red-700 text-white font-bold py-2 px-4 rounded disabled:opacity-50 ml-2"
      >
        Stop Connection
      </button>
      <ul>
        {messages.map((message, index) => (
          <li key={`${index}-${message}`}>{message}</li>
        ))}
      </ul>
    </div>
  );
};

export default App;

後端(api/main.go)

後端是使用 Go 的 Gin 框架建構(gòu)的,包括以下主要功能:

  1. CORS 配置:後端使用 Gin CORS 中間件來(lái)允許調(diào)試期間的連接。

  2. SSE 端點(diǎn):/events 端點(diǎn)將一系列預(yù)先定義訊息串流傳輸?shù)娇蛻?hù)端,每個(gè)訊息之間存在延遲。關(guān)鍵組件:

    • 標(biāo)頭設(shè)定為指定文字/事件流內(nèi)容類(lèi)型。
    • 訊息循環(huán)發(fā)送,每個(gè)訊息之間有 2 秒的延遲。
    • 最終關(guān)閉事件標(biāo)誌著連線(xiàn)的結(jié)束。
"use client";

import type React from "react";
import { useState } from "react";

const App: React.FC = () => {
  const [messages, setMessages] = useState<string[]>([]);
  const [eventSource, setEventSource] = useState<EventSource | null>(null);

  const handleStartConnection = () => {
    const newEventSource = new EventSource("http://localhost:8080/events");

    const handleOnMessage = (event: MessageEvent) => {
      console.log("onmessage", event.data);
      setMessages((prev) => [...prev, event.data]);
    };

    const handleOnOpen = () => {
      console.log("Connection established");
    };

    const handleOnError = (error: Event) => {
      console.error("onerror", error);
      console.log("readyState:", newEventSource.readyState);
      console.log("Connection error occurred.");
      newEventSource.close();
      setEventSource(null);
    };

    const handleOnClose = () => {
      console.log("Connection is being closed by the server.");
      newEventSource.close();
      setEventSource(null);
    };

    newEventSource.onmessage = handleOnMessage;
    newEventSource.onopen = handleOnOpen;
    newEventSource.onerror = handleOnError;
    newEventSource.addEventListener("close", handleOnClose);

    setEventSource(newEventSource);
  };

  const handleStopConnection = () => {
    if (eventSource) {
      eventSource.close();
      setEventSource(null);
      console.log("Connection closed");
    }
  };

  return (
    <div>
      <h1>Server-Sent Events Demo</h1>
      <button
        type="button"
        onClick={handleStartConnection}
        disabled={!!eventSource}
        className="bg-blue-500 hover:bg-blue-700 text-white font-bold py-2 px-4 rounded disabled:opacity-50"
      >
        Start Connection
      </button>
      <button
        type="button"
        onClick={handleStopConnection}
        disabled={!eventSource}
        className="bg-red-500 hover:bg-red-700 text-white font-bold py-2 px-4 rounded disabled:opacity-50 ml-2"
      >
        Stop Connection
      </button>
      <ul>
        {messages.map((message, index) => (
          <li key={`${index}-${message}`}>{message}</li>
        ))}
      </ul>
    </div>
  );
};

export default App;

如何運(yùn)行它

要執(zhí)行此演示,請(qǐng)參閱 GitHub 儲(chǔ)存庫(kù)中的 README.md 檔案。它包含設(shè)定和運(yùn)行專(zhuān)案前端和後端的逐步說(shuō)明。

結(jié)論

此示範(fàn)提供了對(duì)伺服器發(fā)送事件 (SSE) 的簡(jiǎn)單而有效的介紹,示範(fàn)如何將即時(shí)訊息從伺服器串流傳輸?shù)綖g覽器。透過(guò)專(zhuān)注於基礎(chǔ)知識(shí),它旨在幫助您快速理解核心概念並開(kāi)始在自己的專(zhuān)案中嘗試 SSE。

如果您有興趣嘗試或基於此範(fàn)例進(jìn)行構(gòu)建,請(qǐng)查看 GitHub 上的完整原始程式碼:sse-demo 儲(chǔ)存庫(kù)。

以上是SSE最簡(jiǎn)單的demo(伺服器傳送事件)的詳細(xì)內(nèi)容。更多資訊請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章!

本網(wǎng)站聲明
本文內(nèi)容由網(wǎng)友自願(yuàn)投稿,版權(quán)歸原作者所有。本站不承擔(dān)相應(yīng)的法律責(zé)任。如發(fā)現(xiàn)涉嫌抄襲或侵權(quán)的內(nèi)容,請(qǐng)聯(lián)絡(luò)admin@php.cn

熱AI工具

Undress AI Tool

Undress AI Tool

免費(fèi)脫衣圖片

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅(qū)動(dòng)的應(yīng)用程序,用於創(chuàng)建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線(xiàn)上人工智慧工具。

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費(fèi)的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費(fèi)的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強(qiáng)大的PHP整合開(kāi)發(fā)環(huán)境

Dreamweaver CS6

Dreamweaver CS6

視覺(jué)化網(wǎng)頁(yè)開(kāi)發(fā)工具

SublimeText3 Mac版

SublimeText3 Mac版

神級(jí)程式碼編輯軟體(SublimeText3)

熱門(mén)話(huà)題

默認(rèn)情況下,GO靜態(tài)鏈接的含義是什麼? 默認(rèn)情況下,GO靜態(tài)鏈接的含義是什麼? Jun 19, 2025 am 01:08 AM

Go默認(rèn)將程序編譯為獨(dú)立二進(jìn)製文件,主要原因是靜態(tài)鏈接。 1.部署更簡(jiǎn)單:無(wú)需額外安裝依賴(lài)庫(kù),可直接跨Linux發(fā)行版運(yùn)行;2.二進(jìn)制體積更大:包含所有依賴(lài)導(dǎo)致文件尺寸增加,但可通過(guò)構(gòu)建標(biāo)誌或壓縮工具優(yōu)化;3.更高的可預(yù)測(cè)性與安全性:避免外部庫(kù)版本變化帶來(lái)的風(fēng)險(xiǎn),增強(qiáng)穩(wěn)定性;4.運(yùn)行靈活性受限:無(wú)法熱更新共享庫(kù),需重新編譯部署以修復(fù)依賴(lài)漏洞。這些特性使Go適用於CLI工具、微服務(wù)等場(chǎng)景,但在存儲(chǔ)受限或依賴(lài)集中管理的環(huán)境中需權(quán)衡取捨。

在沒(méi)有C中的手動(dòng)內(nèi)存管理的情況下,如何確保內(nèi)存安全性? 在沒(méi)有C中的手動(dòng)內(nèi)存管理的情況下,如何確保內(nèi)存安全性? Jun 19, 2025 am 01:11 AM

Goensuresmemorysafetywithoutmanualmanagementthroughautomaticgarbagecollection,nopointerarithmetic,safeconcurrency,andruntimechecks.First,Go’sgarbagecollectorautomaticallyreclaimsunusedmemory,preventingleaksanddanglingpointers.Second,itdisallowspointe

如何在GO中創(chuàng)建緩衝頻道? (例如,make(chan int,10)) 如何在GO中創(chuàng)建緩衝頻道? (例如,make(chan int,10)) Jun 20, 2025 am 01:07 AM

在Go中創(chuàng)建緩衝通道只需在make函數(shù)中指定容量參數(shù)即可。緩衝通道允許發(fā)送操作在沒(méi)有接收者時(shí)暫存數(shù)據(jù),只要未超過(guò)指定容量,例如ch:=make(chanint,10)創(chuàng)建了一個(gè)可存儲(chǔ)最多10個(gè)整型值的緩衝通道;與無(wú)緩衝通道不同,發(fā)送數(shù)據(jù)時(shí)不會(huì)立即阻塞,而是將數(shù)據(jù)暫存於緩衝區(qū)中,直到被接收者取走;使用時(shí)需注意:1.容量設(shè)置應(yīng)合理以避免內(nèi)存浪費(fèi)或頻繁阻塞;2.需防止緩衝區(qū)無(wú)限堆積數(shù)據(jù)導(dǎo)致內(nèi)存問(wèn)題;3.可用chanstruct{}類(lèi)型傳遞信號(hào)以節(jié)省資源;常見(jiàn)場(chǎng)景包括控制並發(fā)數(shù)量、生產(chǎn)者-消費(fèi)者模型及異

如何使用GO進(jìn)行系統(tǒng)編程任務(wù)? 如何使用GO進(jìn)行系統(tǒng)編程任務(wù)? Jun 19, 2025 am 01:10 AM

Go是系統(tǒng)編程的理想選擇,因?yàn)樗Y(jié)合了C等編譯型語(yǔ)言的性能與現(xiàn)代語(yǔ)言的易用性和安全性。 1.文件與目錄操作方面,Go的os包支持創(chuàng)建、刪除、重命名及檢查文件和目錄是否存在,使用os.ReadFile可一行代碼讀取整個(gè)文件,適用於編寫(xiě)備份腳本或日誌處理工具;2.進(jìn)程管理方面,通過(guò)os/exec包的exec.Command函數(shù)可執(zhí)行外部命令、捕獲輸出、設(shè)置環(huán)境變量、重定向輸入輸出流以及控制進(jìn)程生命週期,適合用於自動(dòng)化工具和部署腳本;3.網(wǎng)絡(luò)與並發(fā)方面,net包支持TCP/UDP編程、DNS查詢(xún)及原始套

如何在GO中的結(jié)構(gòu)實(shí)例上調(diào)用方法? 如何在GO中的結(jié)構(gòu)實(shí)例上調(diào)用方法? Jun 24, 2025 pm 03:17 PM

在Go語(yǔ)言中,調(diào)用結(jié)構(gòu)體方法需先定義結(jié)構(gòu)體和綁定接收者的方法,使用點(diǎn)號(hào)訪(fǎng)問(wèn)。定義結(jié)構(gòu)體Rectangle後,可通過(guò)值接收者或指針接收者聲明方法;1.使用值接收者如func(rRectangle)Area()int,通過(guò)rect.Area()直接調(diào)用;2.若需修改結(jié)構(gòu)體,應(yīng)使用指針接收者如func(r*Rectangle)SetWidth(...),Go會(huì)自動(dòng)處理指針與值的轉(zhuǎn)換;3.嵌入結(jié)構(gòu)體時(shí),內(nèi)嵌結(jié)構(gòu)體的方法會(huì)被提升,可直接通過(guò)外層結(jié)構(gòu)體調(diào)用;4.Go無(wú)需強(qiáng)制使用getter/setter,字

GO中的接口是什麼?如何定義它們? GO中的接口是什麼?如何定義它們? Jun 22, 2025 pm 03:41 PM

在Go語(yǔ)言中,接口是一種定義行為而不指定實(shí)現(xiàn)方式的類(lèi)型。接口由方法簽名組成,任何實(shí)現(xiàn)這些方法的類(lèi)型都自動(dòng)滿(mǎn)足該接口。例如,定義一個(gè)Speaker接口包含Speak()方法,則所有實(shí)現(xiàn)該方法的類(lèi)型均可視為Speaker。接口適用於編寫(xiě)通用函數(shù)、抽象實(shí)現(xiàn)細(xì)節(jié)和測(cè)試中使用mock對(duì)象。定義接口使用interface關(guān)鍵字並列出方法簽名,無(wú)需顯式聲明類(lèi)型實(shí)現(xiàn)了接口。常見(jiàn)用例包括日誌、格式化、不同數(shù)據(jù)庫(kù)或服務(wù)的抽象,以及通知系統(tǒng)等。例如,Dog和Robot類(lèi)型均可實(shí)現(xiàn)Speak方法,並傳遞給同一個(gè)Anno

如何在GO中使用字符串軟件包中的字符串函數(shù)? (例如len(),strings.contains(),strings.index(),strings.replaceall()) 如何在GO中使用字符串軟件包中的字符串函數(shù)? (例如len(),strings.contains(),strings.index(),strings.replaceall()) Jun 20, 2025 am 01:06 AM

在Go語(yǔ)言中,字符串操作主要通過(guò)strings包和內(nèi)置函數(shù)實(shí)現(xiàn)。 1.strings.Contains()用於判斷字符串是否包含子串,返回布爾值;2.strings.Index()可查找子串首次出現(xiàn)的位置,若不存在則返回-1;3.strings.ReplaceAll()能替換所有匹配的子串,還可通過(guò)strings.Replace()控制替換次數(shù);4.len()函數(shù)用於獲取字符串字節(jié)數(shù)長(zhǎng)度,但處理Unicode時(shí)需注意字符與字節(jié)的區(qū)別。這些功能常用於數(shù)據(jù)過(guò)濾、文本解析及字符串處理等場(chǎng)景。

如何使用IO軟件包在GO中使用輸入和輸出流? 如何使用IO軟件包在GO中使用輸入和輸出流? Jun 20, 2025 am 11:25 AM

TheGoiopackageprovidesinterfaceslikeReaderandWritertohandleI/Ooperationsuniformlyacrosssources.1.io.Reader'sReadmethodenablesreadingfromvarioussourcessuchasfilesorHTTPresponses.2.io.Writer'sWritemethodfacilitateswritingtodestinationslikestandardoutpu

See all articles