WebSocket群聊与单聊

时间：2023-01-30 12:01:26

一 . WebSocket实现群聊

　　py文件代码

# py文件

from flask import Flask, render_template, request

from geventwebsocket.handler import WebSocketHandler

from geventwebsocket.websocket import WebSocket

from geventwebsocket.exceptions import WebSocketError

from gevent.pywsgi import WSGIServer  

app = Flask(__name__)

user_socket_list = []

@app.route('/index')

def index():

    return render_template('index.html')

@app.route('/my/ws')

def my_ws():

    # 当前端声明WebSocket的时候才有wsgi.websocket

    user_socket = request.environ.get('wsgi.websocket')  # type:WebSocket   # 为了让下面user_socket点的时候有提示

    user_socket_list.append(user_socket)

    print(len(user_socket_list), user_socket_list)

    while 1:

        try:   # 下面用图解释为什么要try

            msg = user_socket.receive()  # 阻塞等待发送信息

        except WebSocketError:

            user_socket_list.remove(user_socket)

            return 'GoodBye'

        for user in user_socket_list:

            if user == user_socket:

                continue

            try:

                user.send(msg)

            except:

                continue

if __name__ == '__main__':

    # 用下面这种方法启动是为了识别并支持websocket

    http_server = WSGIServer(('0.0.0.0', 9527), app, handler_class=WebSocketHandler)

    http_server.serve_forever()

　　html代码

<!DOCTYPE html>

<html lang="en">

<head>

    <meta charset="UTF-8">

    <title>index</title>

</head>

<body>

<p><input type="text" id="message">

    <button onclick="send_message()">发送</button>

</p>

<div id="chat_list">

</div>

</body>

<script type="application/javascript">

    var ws = new WebSocket('ws://127.0.0.1:9527/my/ws');

    ws.onmessage = function (MessageEvent) {   //当接收到消息的时候执行MessageEvent函数

        var p = document.createElement('p');   // 创建一个p标签

        p.innerText = MessageEvent.data;    // 给p标签里面添加数据

        document.getElementById('chat_list').appendChild(p);  // 把p标签添加到div标签里面

    };

    function send_message() {

        var message = document.getElementById('message').value;

        ws.send(message)

    }

</script>

</html>

　　不try的时候

WebSocket群聊与单聊

　　WebSocket群聊与单聊

　　try之后　　

　　WebSocket群聊与单聊

二 . 单聊

　　py文件

import json

from flask import Flask, render_template, request

from geventwebsocket.handler import WebSocketHandler

from geventwebsocket.websocket import WebSocket

from geventwebsocket.exceptions import WebSocketError

from gevent.pywsgi import WSGIServer

app = Flask(__name__)

user_socket_dict = {}

@app.route('/home')

def index():

    return render_template('home.html')

@app.route('/my/ws/<username>')

def my_ws(username):

    user_socket = request.environ.get('wsgi.websocket')  # type:WebSocket

    user_socket_dict[username] = user_socket

    print(len(user_socket_dict), user_socket_dict)

    while 1:

        try:

            msg = user_socket.receive()  # 阻塞等待消息

            # print(msg, type(msg))

            msg_dict = json.loads(msg)

            to_user = msg_dict.get('to_user')

            to_user_socket = user_socket_dict.get(to_user)

            to_user_socket.send(msg)

        except WebSocketError:

            user_socket_dict.pop(username)

            return 'GoodBye'

if __name__ == '__main__':

    http_server = WSGIServer(('0.0.0.0', 9527), app, handler_class=WebSocketHandler)

    http_server.serve_forever()

　　html文件

<!DOCTYPE html>

<html lang="en">

<head>

    <meta charset="UTF-8">

    <title>Title</title>

</head>

<body>

<p>发送者<input type="text" id="username">

    <button onclick="open_chat()">开始聊天</button>  <!--onclick就是点击执行里面函数-->

</p>

<p>接受者 <input type="text" id="to_user"></p>

<p>

    消息 <input type="text" id="message">

    <button onclick="SendMessage()">发送</button>

</p>

<div id="chat_list">

</div>

</body>

<script type="application/javascript">

    var ws = null;   //声明一个全局变量

    function open_chat() {

        var username = document.getElementById('username').value;

        ws = new WebSocket('ws://127.0.0.1:9527/my/ws/' + username);

        ws.onopen = function () {   // onopen函数就是当你连接开始时执行

            alert('欢迎' + username + '来到午夜激情聊天室!')

        };

        ws.onmessage = function (MessageEvent) {

            var chat = JSON.parse(MessageEvent.data);

            var p = document.createElement('p');

            p.style.cssText = 'width:270px;text-align: left';

            p.innerText = chat.from_user + '->' + chat.message;

            document.getElementById('chat_list').appendChild(p);

        };

        ws.onclose = function () {  // onclose函数就是如果断开连接了执行函数

            // 断开连接

            console.log('已经断开连接');

        };

    }

    function SendMessage() {

        var message = document.getElementById('message').value;

        var from_user = document.getElementById('username').value;

        var to_user = document.getElementById('to_user').value;

        var send_str = {

            from_user: from_user,

            to_user: to_user,

            message: message

        };

        ws.send(JSON.stringify(send_str));

        var p = document.createElement('p');

        p.style.cssText = 'width:270px;text-align:right';

        p.innerText = send_str.message + '<-大帅比';

        document.getElementById('chat_list').appendChild(p);

    }

</script>

</html>

　　展示结果:

　　WebSocket群聊与单聊         WebSocket群聊与单聊

WebSocket群聊与单聊的更多相关文章

  1. spring websocket 和socketjs实现单聊群聊&comma;广播的消息推送详解

    spring websocket 和socketjs实现单聊群聊,广播的消息推送详解 WebSocket简单介绍 随着互联网的发展,传统的HTTP协议已经很难满足Web应用日益复杂的需求了.近年来,随 ...

  2. 一套高可用、易伸缩、高并发的IM群聊、单聊架构方案设计实践

    一套高可用.易伸缩.高并发的IM群聊.单聊架构方案设计实践 一套高可用.易伸缩.高并发的IM群聊.单聊架构方案设计实践-IM开发/专项技术区 - 即时通讯开发者社区! http://www.52im. ...

  3. Websocket实现群聊、单聊

    Websocket 使用的第三方模块:gevent-websocket 群聊 ws群聊.py中的内容 from flask import Flask, request, render_template ...

  4. websocket实现群聊和单聊&lpar;转&rpar;

    昨日内容回顾 1.Flask路由 1.endpoint="user" # 反向url地址 2.url_address = url_for("user") 3.m ...

  5. flask &plus; websocket实现简单的单聊和群聊

    单聊 from flask import Flask,request,render_template from geventwebsocket.handler import WebSocketHand ...

  6. Flask实现简单的群聊和单聊

    Flask是使用python写的一个简单轻量级的框架,今天我们使用Flask实现一个简单的单聊和群聊功能 . 主要思路 : 前端登录聊天室,聊天室信息包含用户的登录信息,相当于一个登录功能,会把这个信 ...

  7. Flask&plus;WebSocket实现群聊与单聊功能

    在开始我们的程序代码之前,先来了解一下相关的基础知识: 1.什么是websocket? (1)WebSocket是HTML5开始提供的一种在单个 TCP 连接上进行全双工通讯的协议.WebSocket ...

  8. 如何用WebSocket实现一个简单的聊天室以及单聊功能

    百度百科中这样定义WebSocket:WebSocket协议是基于TCP的一种新的网络协议.它实现了浏览器与服务器全双工(full-duplex)通信——允许服务器主动发送信息给客户端.简单的说,We ...

  9. websocket 实现单聊群聊 以及 握手原理&plus;加密方式

    WebSocket 开始代码 服务端 群聊 # type:WebSocket 给变量标注类型 # websocket web + socket from geventwebsocket.server ...

随机推荐

  1. 架构实例之Demo&lowbar;JSP&lowbar;JavaBean

    架构实例之Demo_JSP_JavaBean 1.开发工具和开发环境      开发工具: MyEclipse10,JDK1.6.0_13(32位),Tomcat7.0(32位),mysql5.7.1 ...

  2. andriod网址

    http://www.runoob.com/w3cnote/android-tutorial-end.html  入门教程 长青说安卓

  3. Android滑动选择的日期选择框

    效果图如下. 实现也很简单,使用的是Android的DatePicker控件.AlertDialog实现. 首先是布局文件:date_picker_dialog.xml <?xml versio ...

  4. 最简单的内核模块hello world

    [root@rt2m09617.sqa.tbc /home/ahao.mah/main] #cat hello.c // Defining __KERNEL__ and MODULE allows u ...

  5. 《Java程序书面采访猿收藏》之 instanceof的作用是什么

    instanceof它是Java二元运算语言,它的作用是推断对象变量引用被指向的类型是一类(或接口.抽象类.父亲)示例.即,对象是否是它的一个实例离开它的类的权.返回boolean数据类型. 常见的使 ...

  6. 201521123115《Java程序设计》第14周学习总结

    1. 本周学习总结 1.1 以你喜欢的方式(思维导图或其他)归纳总结多数据库相关内容. 2. 书面作业 1. MySQL数据库基本操作 建立数据库,将自己的姓名.学号作为一条记录插入.(截图,需出现自 ...

  7. Spring 为Bean对象执行初始化和销毁方法

    1)初始化: ①可以利用<bean>元素的init-method="方法名"属性指定初始化方法. ②指定的初始化方法是在构造方法调用后自动执行.若非单例模式,则每创建一 ...

  8. linux中的权限

    第1章 显示或设置网络相关信息 1.1 ip address 与ifconfig 类似 [root@znix ~]# ip address 1: lo: <LOOPBACK,UP,LOWER_U ...

  9. &lbrack;Kubernetes&rsqb;CentOS7下Etcd集群搭建

    Etcd简要介绍 Etcd是Kubernetes集群中的一个十分重要的组件,用于保存集群所有的网络配置和对象的状态信息 Etcd构建自身高可用集群主要有三种形式: ①静态发现: 预先已知 Etcd 集 ...

  10. Spring（十五）：通过注解配置 Bean

    在ClassPath中扫描组件 1)组件扫描(component scanning):Spring能够从classpath下自动扫描,侦测和实例化具有特定注解的组件: 2)特定组件包含: --- @C ...

相关文章