百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术文章 > 正文

还不会主动向前端通过SSE推送消息? 看这篇就会了![Delphi版]

zhezhongyun 2025-01-13 19:13 55 浏览

SSE(Server-Send Events)

SSE 是一种在基于浏览器的 Web 应用程序中仅从服务器向客户端发送文本消息的技术。SSE基于 HTTP 协议中的持久连接, 具有由 W3C 标准化的网络协议和 EventSource 客户端接口,作为 HTML5 标准套件的一部分。

使用其他方法实现的很多,采用Delphi实现的却基本没有,请教了一位高手,在他的帮助下实现了,特写下来,希望能帮助到更多的delphier.

废话不多说,直接上代码!

pas如下

unit Unit1;

interface

uses
  Winapi.Windows, Winapi.Messages, System.SysUtils, System.Variants, System.Classes, Vcl.Graphics,
  Vcl.Controls, Vcl.Forms, Vcl.Dialogs, IdContext, IdCustomHTTPServer, IdHTTPServer,IdTCPConnection,
  IdBaseComponent, IdComponent, IdCustomTCPServer, Vcl.StdCtrls;

type
  TForm1 = class(TForm)
    IdHTTPServer1: TIdHTTPServer;
    Memo1: TMemo;
    Button1: TButton;
    Edit1: TEdit;
    procedure FormCreate(Sender: TObject);
    procedure IdHTTPServer1CommandGet(AContext: TIdContext; ARequestInfo: TIdHTTPRequestInfo;
      AResponseInfo: TIdHTTPResponseInfo);
    procedure Button1Click(Sender: TObject);
  private
    procedure SendSSEMessage(const AMessage: string);
  public
  end;

var
    Form1: TForm1;
   gConnection : TIdTCPConnection;

implementation

{$R *.dfm}

procedure TForm1.Button1Click(Sender: TObject);
begin
    SendSSEMessage(Edit1.Text);
end;

procedure TForm1.FormCreate(Sender: TObject);
begin
    IdHTTPServer1.DefaultPort := 80; // 设置服务器端口
    IdHTTPServer1.ServerSoftware := 'Delphi SSE Server'; // 设置服务器名称  IdHTTPServer1.Active := True;
    idHttpServer1.Active    := True;
    Memo1.Lines.Add('Server started...');
end;

procedure TForm1.IdHTTPServer1CommandGet(AContext: TIdContext; ARequestInfo: TIdHTTPRequestInfo;
    AResponseInfo: TIdHTTPResponseInfo);
var
    LFilename: string;
    LPathname: string;
begin
    LFilename := ARequestInfo.Document;
    LPathname := 'E:\Study\SSE' + LFilename;
    if FileExists(LPathname) then begin
        AResponseInfo.ContentStream := TFileStream.Create(LPathname, fmOpenRead + fmShareDenyWrite);
    end else begin
        if ARequestInfo.URI = '/subscribe' then begin
            with AContext.Connection.IOHandler do begin
                WriteBufferOpen;
                WriteLn('HTTP/1.1 200 OK');
                WriteLn('Content-Type: text/event-stream; charset=UTF-8');
                WriteLn('Cache-Control: no-cache');
                WriteLn('Connection: keep-alive');
                WriteLn();
                WriteBufferClose;

            end;

            //
            gConnection   := AContext.Connection;
        end;
    end;
end;

procedure TForm1.SendSSEMessage(const AMessage: string);
begin
    with gConnection.IOHandler do begin
        WriteBufferOpen;
        WriteLn('id:'+IntToStr(random(1000))+#13#10);
        WriteLn('event:test'+#13#10);
        WriteLn('data:'+AMessage+#13#10#13#10);
        WriteBufferClose;
    end;
end;

end.

dfm如下:

object Form1: TForm1
  Left = 0
  Top = 0
  Caption = 'Form1'
  ClientHeight = 242
  ClientWidth = 601
  Color = clBtnFace
  Font.Charset = DEFAULT_CHARSET
  Font.Color = clWindowText
  Font.Height = -11
  Font.Name = 'Tahoma'
  Font.Style = []
  OldCreateOrder = False
  OnCreate = FormCreate
  PixelsPerInch = 96
  TextHeight = 13
  object Memo1: TMemo
    Left = 250
    Top = 0
    Width = 351
    Height = 242
    Align = alRight
    Lines.Strings = (
      'Memo1')
    TabOrder = 0
    ExplicitLeft = 512
  end
  object Button1: TButton
    Left = 48
    Top = 168
    Width = 75
    Height = 25
    Caption = 'Button1'
    TabOrder = 1
    OnClick = Button1Click
  end
  object Edit1: TEdit
    Left = 48
    Top = 32
    Width = 121
    Height = 21
    TabOrder = 2
    Text = 'Edit1'
  end
  object IdHTTPServer1: TIdHTTPServer
    Bindings = <>
    TerminateWaitTime = 50000
    KeepAlive = True
    SessionTimeOut = 50000
    OnCommandGet = IdHTTPServer1CommandGet
    Left = 120
    Top = 80
  end
end

对应的HTML如下:

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="UTF-8">
    <title>Title</title>
    <script>
        window.onload = ()=> {

			console.log("onload!");
            if (window.EventSource) {
                let source = new EventSource("/subscribe");
                let s = '';
                // 
                source.addEventListener('message', function(e) {
                    console.log("connect message");
                    document.querySelector("p").innerText = e.data;
                })
                source.addEventListener('open',function(e){
                    console.log("connect is open");
                },false);
                source.addEventListener('error',function(e){
                    if(e.readyState == EventSource.CLOSE){
                        console.log("connect is close");
						console.log('connection state: ' + source.readyState + ', error: ' + event); 
						console.log(event); 
                    }else{
                        console.log(e.readyState);
                    }
                },false);
            } else {
                alert("浏览器不支持EventSource");
            }
        }
    </script>
</head>
<body>
    <p></p>
</body>
</html>

编译版是Delphi 10.4.2

点击Button1,即可向前端推送Edit1中的字符串。

相关推荐

用豆包生成的BMI计算器(豆包的热量是多少?)

<!DOCTYPEhtml><htmllang="en"><head><metacharset="UTF-8&#...

Android 开发中文引导-应用小部件

应用小部件是可以嵌入其它应用(例如主屏幕)并收到定期更新的微型应用视图。这些视图在用户界面中被叫做小部件,并可以用应用小部件提供者发布。可以容纳其他应用部件的应用组件叫做应用部件的宿主(1)。下面的截...

Qt推流(视频文件/视频流/摄像头/桌面转流媒体rtmp+hls+webrtc)

一、前言说明推流直播就是把采集阶段封包好的内容传输到服务器的过程。其实就是将现场的视频信号从手机端,电脑端,摄影机端打包传到服务器的过程。“推流”对网络要求比较高,如果网络不稳定,直播效果就会很差,观...

一看就会!谷歌广告转化跟踪详细设置指南来了

在出海推广业务中,投放广告最常见的目的是获取订单,但我们怎么知道有没有达成投放目的呢?谷歌转化跟踪技术就可以做到!熟悉谷歌的卖家朋友都知道,转化跟踪在最近几年变得越来越复杂了,虽然有很多选项可以自定义...

Android原生编解码接口MediaCodec详解

作者:躬行之MediaCodec是Android中的编解码器组件,用来访问底层提供的编解码器,通常与MediaExtractor、MediaSync、MediaMuxer、MediaCrypt...

手把手搭建RTSP流媒体服务器(rtsp 流媒体)

0.引言本文主要讲解如何搭建RTSP流媒体服务器的过程,使用开源项目ZLMediaKit。通过这个开源项目,推RTSP流到服务器,然后拉流端可以拉取RTSP、RTMP等流。ZLMediaKit码云链接...

MediaInfo 24.04.0 是一个关于多媒体文件的信息提供工具

MediaInfo24.04.0是一个关于多媒体文件的信息提供工具(仅当文件中包含信息时才提供):包括常规信息(标题、作者、导演、专辑、曲目编号、日期、时长等);视频信息(编解码器、画面比例、帧率...

rmvb格式视频怎么打开,rmvb转MP4认准这个方法

 一、rmvb是什么格式?  RMVB是一种视频文件格式,其中的VB指的是可变比特率。比起上一代的RM格式,RMVB  格式的画面比较清晰,因为它是降低了静态画面下的比特率。  二、制作rmvb  ①...

教你用Plex Media Server,把铁威马变成你的“私人好莱坞”!

TNAS(铁威马NAS)中可以安装多媒体服务器、影视、PlexMediaServer、EmbyServer作为个人媒体服务器使用。PlexMediaServer可以组织整理TNAS上的媒体...

你肯定用过!经典Windows软件被抛弃

Windows系统这些年持续更新的过程中,不断融入新的软件和功能的同时,一些经典的应用也渐渐成为了历史……Windows媒体播放器被抛弃Windows系统不断地推陈出新,一些老旧的组件也难免被抛弃,在...

博思得Q8标签打印全能手(博思得标签打印机安装教程)

2014-12-0905:35:00作者:宋达希【中关村在线办公打印频道原创】服装吊牌、洗涤标签、产品说明标签等都要用到标签打印机,这些标签涵盖多种尺寸的长度和宽度以及材质。另外作为一件商品或者产...

flv文件用什么播放器打开,这样做不踩雷!

FLV是FLASHVIDEO的简称,是随着FlashMX的推出发展而来的视频格式。它的出现有效地解决了视频文件导入Flash后,使导出的SWF文件体积庞大,不能在网络上很好的使用等问题。一、...

media player怎么转换格式?音频转换神器推荐!

Windowsmediaplayer怎么转换格式?WindowsMediaPlayer是微软公司出品的一款多媒体播放器,通常简称“WMP”。提供了编辑音频和视频文件的功能。用户可以使用该软件导...

视频参数检查工具更新:MediaInfo 23.10

MediaInfo提供有关视频或音频文件的技术和标签信息。信息示例包括编解码器、比特率、每秒帧数、宽度、高度、频道数、持续时间、标题、作者、字幕语言和章节名称。多种方式可以查看信息(文本、工作表、树和...

多媒体管理软件:JRiver Media Center 31.0.68 (64位)

JRiverMediaCenter64位是适用于大量库的完整媒体解决方案。它组织、播放和标记所有类型的媒体文件,并对Xbox、PS3、UPnP、DLNA和TiVo进行翻录、刻录。JRiverM...