Python uses WebSocket and SSE to implement HTTP server message push method

#python 3+
import threading
import websocket


class Client:
    def __init__(self,url):
    	 = url
         = None
         = True


    def on_message(self,response):
		 = False
        print(response)


    def on_error(self,error):
        # print(ws)
        print(error)


    def on_close(self):
    	 = True
        print(ws)
       

    def on_open(self):
		print('open')
    
    def start_func(self):

        while :
            (True)
             = (,
                                        on_message=self.on_message,
                                        # on_data=on_data,
                                        on_error=self.on_error,
                                        on_open=self.on_open,
                                        on_close=self.on_close, )


            .run_forever(ping_interval=60, ping_timeout=5)

if __name__ == "__main__":
	cli = Client(url = 'wss:///websocket' )
    t1 = (target=cli.start_func_zb)
    ()

var ws = new WebSocket("wss://");

 = function(evt) { 
  ("Connection open ..."); 
  ("Hello WebSockets!");
};

 = function(evt) {
  ( "Received Message: " + );
  ();
};

 = function(evt) {
  ("Connection closed.");
};      

from websocket_server import WebsocketServer

class WSSocketObj:
    def __init__(self,host=None,port = 8131):
        = host if host else '127.0.0.1'
        = port

    # When a new client connects, it will prompt    def new_client(self,client, server,):
        print("When a new client connects, it will prompt: %s" % client['id'])
        dd = 122
        server.send_message_to_all("Hey all, a new client has joined us")

    # When the old client leaves    def client_left(self,client, server):
        print("Client %s disconnected" % client['id'])

    # Receive client information.    def message_received(self,client, server, message):
        print("Client(%d) said: %s" % (client['id'], message))
        # server.send_message_to_all(message) #Send messages to all clients        server.send_message(client, 'hello,client')  # Send a message to the specified client
    def run_server(self):
        server = WebsocketServer(, )
        server.set_fn_new_client(self.new_client)
        server.set_fn_client_left(self.client_left)
        server.set_fn_message_received(self.message_received)
        server.run_forever()

if __name__ == '__main__':

    WSSocketObj().run_server()

#The first methoddef sse_client():
    """
    pip install sseclient-py
    For return criteria onlySSEFormat requests available Format：event: {EVENT}\nretry: 10000\ndata: {DATA}\n\n
    :return:
    """
    import requests
    # res = ('get', url, json=data, stream=True, headers={'Accept': 'text/event-stream'})
    client = (url, json=data, stream=True, headers={'Accept': 'text/event-stream'})
    client = (client)
    for i in ():
        print()

# The second waydef sse_with_requests():
    headers = {"Accept": "text/event-stream"}
    r = (url, headers=headers, json=data, stream=True)
     = 'utf-8'
    for chunk in r.iter_content(chunk_size=None, decode_unicode=True):
        # Process the received data blocks        print("Received:", chunk)

//Judge whether SSE is supportedif('EventSource' in window){

//Initialize SSEvar url="http:localhost:8000/stream";
var source=new EventSource(url);

// Open event will be triggered after the connection is successful=(event)=>{

("Open SSE");

}

// If there is no event field when the server sends information to the client, the message event will be triggered by default.=(event)=>{

var data=;

$("body").append($("<p>").text(data));

}

// Listen to like events('like',function(event){

var data=;

$("body").append($("<p>").text(data));
},false);

// An error event will be triggered when the connection is abnormal and it will automatically reconnect.=(event)=>{

(event);

}

if () {
  // Create EventSource object to connect to the server  const source = new EventSource('http://localhost:2000');

  // Open event will be triggered after the connection is successful  ('open', () => {
    ('Connected');
  }, false);

  // If there is no event field when the server sends information to the client, the message event will be triggered by default.  ('message', e => {
    (`data: ${}`);
  }, false);

  // Custom EventHandler, triggered when receiving a message with the event field slide  ('slide', e => {
    (`data: ${}`); // => data: 7
  }, false);

  // An error event will be triggered when the connection is abnormal and it will automatically reconnect.  ('error', e => {
    if ( === ) {
      ('Disconnected');
    } else if ( === ) {
      ('Connecting...');
    }
  }, false);
} else {
  ('Your browser doesn\'t support SSE');
}

import json
import time

from flask import Flask, request
from flask import Response
from flask import render_template

app = Flask(__name__)


def get_message():
    """this could be any function that blocks until data is ready"""
    (1)
    s = (())
    return (['Current time:' + s , 'a'], ensure_ascii=False)


@('/')
def hello_world():
    return render_template('')


@('/stream')
def stream():
    user_id = ('user_id')
    print(user_id)
    def eventStream():
        id = 0
        while True:
            id +=1
            # wait for source data to be available, then push it

            yield 'id: {}\nevent: add\ndata: {}\n\n'.format(id,get_message())


    return Response(eventStream(), mimetype="text/event-stream")


if __name__ == '__main__':
    ()

[field]:value\n

function connectSSE() {
  if () {
    const source = new EventSource('http://localhost:2000');
    let reconnectTimeout;

    ('open', () => {
      ('Connected');
      clearTimeout(reconnectTimeout);
    }, false);

    ('pause', e => {
      ();
      const reconnectTime = +;
      const currentTime = +new Date();
      reconnectTimeout = setTimeout(() => {
        connectSSE();
      }, reconnectTime - currentTime);
    }, false);
  } else {
    ('Your browser doesn\'t support SSE');
  }
}

connectSSE();