python tornado websocket 多聊天室（返回消息给部分连接者）

时间：2021-09-18 17:36:52

python tornado 构建多个聊天室， 多个聊天室之间相互独立， 实现服务器端将消息返回给相应的部分客户端！

chatHome.py　　　　// 服务器端， 渲染主页 --》 聊天室建立websocket连接 --》 服务器端记录连接 --》 服务器端接收消息，判断聊天室，返回最新消息到对应聊天室

 #-*-coding:utf-8-*-

 __author__ = 'zhouwang'

 import json

 import tornado.web

 import tornado.websocket

 import tornado.httpserver

 import tornado.ioloop

 import tornado.options

 from uuid import uuid4

 class ChatHome(object):

     '''

         处理websocket 服务器与客户端交互

     '''

     chatRegister = {}

     def register(self, newer):

         '''

             保存新加入的客户端连接、监听实例，并向聊天室其他成员发送消息！

         '''

         home = str(newer.get_argument('n'))     #获取所在聊天室

         if home in self.chatRegister:

             self.chatRegister[home].append(newer)

         else:

             self.chatRegister[home] = [newer]

         message = {

             'from': 'sys',

             'message': '%s 加入聊天室（%s）' % (str(newer.get_argument('u')), home)

         }

         self.callbackTrigger(home, message)

     def unregister(self, lefter):

         '''

             客户端关闭连接，删除聊天室内对应的客户端连接实例

         '''

         home = str(lefter.get_argument('n'))

         self.chatRegister[home].remove(lefter)

         if self.chatRegister[home]:

             message = {

                 'from': 'sys',

                 'message': '%s 离开聊天室（%s）' % (str(lefter.get_argument('u')), home)

             }

             self.callbackTrigger(home, message)

     def callbackNews(self, sender, message):

         '''

             处理客户端提交的消息，发送给对应聊天室内所有的客户端

         '''

         home = str(sender.get_argument('n'))

         user = str(sender.get_argument('u'))

         message = {

             'from': user,

             'message': message

         }

         self.callbackTrigger(home, message)

     def callbackTrigger(self, home, message):

         '''

             消息触发器，将最新消息返回给对应聊天室的所有成员

         '''

         for callbacker in self.chatRegister[home]:

             callbacker.write_message(json.dumps(message))

 class chatBasicHandler(tornado.web.RequestHandler):

     '''

         主页， 选择进入聊天室

     '''

     def get(self, *args, **kwargs):

         session = uuid4()   #生成随机标识码，代替用户登录

         self.render('chat/basic.html', session = session)

 class homeHandler(tornado.web.RequestHandler):

     '''

         聊天室， 获取主页选择聊天室跳转的get信息渲染页面

     '''

     def get(self, *args, **kwargs):

         n = self.get_argument('n')      #聊天室

         u = self.get_argument('u')      #用户

         self.render('chat/home.html', n=n, u=u)

 class newChatStatus(tornado.websocket.WebSocketHandler):

     '''

         websocket， 记录客户端连接，删除客户端连接，接收最新消息

     '''

     def open(self):

         n = str(self.get_argument('n'))

         self.write_message(json.dumps({'from':'sys', 'message':'欢迎来到 聊天室（%s）' % n}))      #向新加入用户发送首次消息

         self.application.chathome.register(self)    #记录客户端连接

     def on_close(self):

         self.application.chathome.unregister(self)  #删除客户端连接

     def on_message(self, message):

         self.application.chathome.callbackNews(self, message)   #处理客户端提交的最新消息

 class Application(tornado.web.Application):

     def __init__(self):

         self.chathome = ChatHome()

         handlers = [

             (r'/', chatBasicHandler),

             (r'/home/', homeHandler),

             (r'/newChatStatus/', newChatStatus),

         ]

         settings = {

             'template_path': 'html',

             'static_path': 'static'

         }

         tornado.web.Application.__init__(self, handlers, **settings)

 if __name__ == '__main__':

     tornado.options.parse_command_line()

     server = tornado.httpserver.HTTPServer(Application())

     server.listen(8000)

     tornado.ioloop.IOLoop.instance().start()

basic.html　　　　//主页， 选择进入聊天室， sessoin 设定为登录用户， GET: n指定聊天室， u指定用户

 <body>

     <h1>你好 ！{{ session }} <br> 欢迎来到聊天室！</h1>

     <a href="/home/?n=1&u={{ session }}"> 聊天室一 </a> &nbsp;        <a href="/home/?n=2&u={{ session }}"> 聊天室二 </a>

 </body>

home.html        　//聊天室，建立websocket连接，发送消息，接受消息，根据最新消息的发送者处理消息格式并写入页面

 <!DOCTYPE html>

 <html lang="en">

 <head>

     <meta charset="UTF-8">

     <title></title>

     <script src="http://libs.baidu.com/jquery/1.10.2/jquery.min.js"></script>

     <script>

         $(function(){

             n = $("#n").val()

             u = $("#u").val()

             $("#btn").click(function(){

                 sendText()

             })

             function requestText(){

                 host = "ws://localhost:8000/newChatStatus/?n=" + n + "&u=" +u

                 websocket = new WebSocket(host)

                 websocket.onopen = function(evt){}      // 建立连接

                 websocket.onmessage = function(evt){    // 获取服务器返回的信息

                     data = $.parseJSON(evt.data)

                     if(data['from']=='sys'){

                         $('#chatinfo').append("<p style='width: 100%; text-align:center; font-size: 16px; color: green'>" + data['message'] + "</p>");

                     }else if(data['from']==u){

                         $('#chatinfo').append("<p style='width: 100%; text-align:right; font-size:15px'>" + u + ": <br>" +"<span style='color: blue'>" + data['message'] + "</span>" + "</p>");

                     }else{

                         $('#chatinfo').append("<p style='width: 100%; text-align:left; font-size:15px'>" + data['from'] + ": <br>" +"<span style='color: red'>" + data['message'] + "</span>" + "</p>");

                     }

                 }

                 websocket.onerror = function(evt){}

             }

             requestText()   // 开始 websocket

             function sendText(){    // 向服务器发送信息

                 websocket.send($("#chat_text").val())

             }

         })

     </script>

 </head>

 <body>

 <div align="center">

     <div style="width: 70%">

         <h1>聊天室（{{ n }}）!</h1>

         <input type="hidden" value="{{ n }}" id="n">

         <input type="hidden" value="{{ u }}" id="u">

         <div id="chatinfo" style="padding:10px;border: 1px solid #888">

             <!-- 聊天内容 -->

         </div>

         <div style="clear: both; text-align:right; margin-top: 20px">

             <input type="text" name="chat_text" id="chat_text">

             <button id="btn">发送</button>

         </div>

     </div>

 </div>

 </body>

 </html>

python tornado websocket 多聊天室（返回消息给部分连接者）的更多相关文章

  1. Ext JS学习第十六天 事件机制event（一） DotNet进阶系列&lpar;持续更新&rpar; 第一节：&period;Net版基于WebSocket的聊天室样例 第十五节：深入理解async和await的作用及各种适用场景和用法 第十五节：深入理解async和await的作用及各种适用场景和用法 前端自动化准备和详细配置&lpar;NVM、NPM&sol;CNPM、NodeJs、NRM、WebPack、Gulp&sol;Grunt、G

    code&monkey   Ext JS学习第十六天 事件机制event(一) 此文用来记录学习笔记: 休息了好几天,从今天开始继续保持更新,鞭策自己学习 今天我们来说一说什么是事件,对于事件 ...

  2. WebSocket 网页聊天室

    先给大家开一个原始的websocket的连接使用范例 <?php /* * recv是从套接口接收数据,也就是拿过来,但是不知道是什么 * read是读取拿过来的数据,就是要知道recv过来的是 ...

  3. 基于WebSocket实现聊天室&lpar;Node&rpar;

    基于WebSocket实现聊天室(Node) WebSocket是基于TCP的长连接通信协议,服务端可以主动向前端传递数据,相比比AJAX轮询服务器,WebSocket采用监听的方式,减轻了服务器压力 ...

  4. websocket&plus;golang聊天室

    原文地址: http://www.niu12.com/article/3 websocket+golang聊天室 main.go和index.html放在同一目录下 main.go package m ...

  5. Tornado WebSocket简单聊天

    Tornado实现了对socket的封装:tornado.web.RequestHandler 工程目录: 1.主程序 manage.py import tornado.web import torn ...

  6. Python开发一个WEB聊天室

    项目实战:开发一个WEB聊天室 功能需求: 用户可以与好友一对一聊天 可以搜索.添加某人为好友 用户可以搜索和添加群 每个群有管理员可以审批用户的加群请求,群管理员可以用多个,群管理员可以删除.添加. ...

  7. 基于webSocket的聊天室

    前言 不知大家在平时的需求中有没有遇到需要实时处理信息的情况,如站内信,订阅,聊天之类的.在这之前我们通常想到的方法一般都是采用轮训的方式每隔一定的时间向服务器发送请求从而获得最新的数据,但这样会浪费 ...

  8. PHP websocket之聊天室实现

    PHP部分 <?php error_reporting(E_ALL); set_time_limit(0);// 设置超时时间为无限,防止超时 date_default_timezone_set ...

  9. Django用websocket实现聊天室之筑基篇

    最近闲来无事,无意发现一个聊天室的前端UI,看着挺好看的但是没有聊天室的通信代码,于是想给它安装电池(通信部分),先看UI: 开始通信部分的工作: 使用的组件: Django1.11.13 chann ...

随机推荐

  1. 在output 子句和 scope&lowbar;identity&lpar;&rpar; 混合使用的时候的注意事项

    无意睹到一篇旧文档 SR0008:考虑使用 SCOPE_IDENTITY 代替 @@IDENTITY :https://msdn.microsoft.com/zh-cn/library/dd17212 ...

  2. C&num; Winform常见的Editor

    常见Editor: 1)ArrayEditor,继承自CollectionEditor 2)BinaryEditor 3)CollectionEditor 4)DateTimeEditor 5)Mul ...

  3. PHP如何让apache支持&period;htaccess 解决Internal Server Error The server …错误

    TP框架  打开 www.newtp.com/index.php/Home/Index/abc出现 如下错误: Internal Server Error The server encountered ...

  4. SendMessage基本认识

    SendMessage基本认识 函数功能:该函数将指定的消息发送到一个或多个窗口.此函数为指定的窗口调用窗口程序,直到窗口程序处理完消息再返回.而函数PostMessage不同,将一个消息寄送到一个线 ...

  5. static timing analysis 基础

    此博文依据 特权同学在电子发烧友上的讲座PPT进行整理而成. static timing analysis   静态时序分析基础 过约束:有不必要的约束,或者是约束不能再某一情况下满足.——约束过头了 ...

  6. python dataframe 针对多列执行map操作

    Suppose I have a df which has columns of 'ID', 'col_1', 'col_2'. And I define a function : f = lambd ...

  7. c语言项目流程开发三部曲

    一.这一部曲是紧接第二部没有介绍完的内容,主要是函数接口实体的实现,代码比较多,如果没有看前两部曲的先去看看,再来看这里,不然不好理解,话不说多上代码, #define _CRT_SECURE_NO_ ...

  8. sed的替换命令

    例1: [root@nhserver2 ~]# cat nagios.txt<TD ALIGN=LEFT valign=center CLASS='statusBGCRITICAL'>&l ...

  9. 自动化测试框架的Step By Step搭建及测试实战（1）

    1.1什么是自动化测试框架 1.什么是自动化框架 自动化框架是应用与自动化测试的程序框架,它提供了可重用的自动化测试模块,提供最基础的自动化测试功能,或提供自动化测试执行和管理功能的架构模块.它是由一 ...

  10. 20155237 《Java程序设计》实验一（Java开发环境的熟悉）实验报告

    20155237 <Java程序设计>实验一(Java开发环境的熟悉)实验报告 一.实验内容及步骤 使用JDK编译.运行简单的java程序 新建文件夹 打开终端 输入cd Code命令进入 ...

相关文章