开启辅助访问 切换到宽版

精易论坛

 找回密码
 注册

QQ登录

只需一步,快速开始

用微信号发送消息登录论坛

新人指南 邀请好友注册 - 我关注人的新帖 教你赚取精币 - 每日签到


求职/招聘- 论坛接单- 开发者大厅

论坛版规 总版规 - 建议/投诉 - 应聘版主 - 精华帖总集 积分说明 - 禁言标准 - 有奖举报

查看: 804|回复: 4
收起左侧

[已解决] 如何在不使用asyncio协程的情况下将代码改成同步的websocketd...

 关闭 [复制链接]
结帖率:65% (20/31)
发表于 2023-7-27 23:39:22 | 显示全部楼层 |阅读模式   广东省揭阳市
500精币
# 菜鸟一枚 不懂asyncio 找了很多方法 都是需要异步 有没有通过therading模块或者其他方法可以实现websockets服务端import websockets
import asyncio

async def echo(websocket):
    message = '我是发送给客户Duan的信息'
    await  websocket.send(message )
    return  True

# 接收  客户Duan返回的数据
async def recv_msg(websocket):
    while 1:
        # 接收
        resv_text = await websocket.recv()
        print(resv_text)
        with open('sss.txt','w',encoding='utf-8') as f:
            f.write(resv_text)

# 入口
async def main_run(websocket):
    await echo(websocket)
    await recv_msg(websocket)


stat_sever = websockets.serve(main_run,'127.0.0.1',9999)
print('成功建立连接')
loop = asyncio.get_event_loop()
loop.run_until_complete(stat_sever)

# 保持长连接 需要不断的监听返回的数据
loop.run_forever()

最佳答案

查看完整内容

如果你想通过threading模块或其他方法实现websockets服务端,可以使用websockets库提供的serve函数结合threading模块来实现。以下是一个示例代码: [mw_shl_code=python,true]import websockets import asyncio import threading async def echo(websocket, path): message = '我是发送给客户Duan的信息' await websocket.send(message) return True # 接收 客户Duan返回的数据 async def recv_msg(websocket, path) ...

回答提醒:如果本帖被关闭无法回复,您有更好的答案帮助楼主解决,请发表至 源码区 可获得加分喔。
友情提醒:本版被采纳的主题可在 申请荣誉值 页面申请荣誉值,获得 1点 荣誉值,荣誉值可兑换荣誉会员、终身vip用户组。
快捷通道:申请荣誉值无答案申请取消悬赏投诉有答案未采纳为最佳
结帖率:86% (51/59)

签到天数: 2 天

发表于 2023-7-27 23:39:23 | 显示全部楼层   广东省中山市
如果你想通过threading模块或其他方法实现websockets服务端,可以使用websockets库提供的serve函数结合threading模块来实现。以下是一个示例代码:
[Python] 纯文本查看 复制代码
import websockets
import asyncio
import threading

async def echo(websocket, path):
    message = '我是发送给客户Duan的信息'
    await websocket.send(message)
    return True

# 接收 客户Duan返回的数据
async def recv_msg(websocket, path):
    while True:
        # 接收
        resv_text = await websocket.recv()
        print(resv_text)
        with open('sss.txt', 'w', encoding='utf-8') as f:
            f.write(resv_text)

# 入口
async def main_run(websocket, path):
    await echo(websocket, path)
    await recv_msg(websocket, path)

def start_server():
    asyncio.set_event_loop(asyncio.new_event_loop())
    stat_sever = websockets.serve(main_run, '127.0.0.1', 9999)
    print('成功建立连接')
    loop = asyncio.get_event_loop()
    loop.run_until_complete(stat_sever)
    loop.run_forever()

# 创建一个线程来启动服务器
server_thread = threading.Thread(target=start_server)
server_thread.start()

在这个示例代码中,我们使用threading模块创建了一个新的线程来启动websockets服务器。在start_server函数中,我们创建了一个新的事件循环,并在该事件循环中运行websockets的serve函数。然后,我们使用run_until_complete方法来运行服务器,最后使用run_forever方法来保持服务器的长连接。
请注意,这只是一个示例代码,具体实现可能因你的需求和环境而有所不同。确保你已经安装了websockets库,并根据需要进行适当的调整。
回复

使用道具 举报

结帖率:65% (20/31)
 楼主| 发表于 2023-7-28 00:08:47 | 显示全部楼层   广东省揭阳市
import websockets

def handle_websocket(websocket, path):
    while True:
        message = websocket.recv()  # 接收客户Duan发送的消息
        print(f"Received message: {message}")

        response = f"Server received message: {message}"
        websocket.send(response)  # 向客户Duan发送响应消息

# 创建WebSocket服务器
start_server = websockets.serve(handle_websocket, "localhost", 8765)
# 启动WebSocket服务器
server = start_server.ws_server

这个代码可以创建服务端 但是不能持久化 有没有大佬能教导一下怎么不通过asyncio的情况下 实现websocket持久化
回复

使用道具 举报

结帖率:63% (5/8)
发表于 2023-7-28 03:57:22 | 显示全部楼层   重庆市重庆市
websocket持久化需要和客户Duan一直说话。。。一但客户Duan和服务端建立连接之后,客户Duan就需要一直往服务端发送消息,比如10s自动关闭连接,那就5s发送一次。直到客户Duan或服务端主动要求关闭。
回复

使用道具 举报

签到天数: 1 天

发表于 2024-4-8 23:01:19 | 显示全部楼层   重庆市重庆市
支持开源~!感谢分享
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 注册

本版积分规则 致发广告者

发布主题 收藏帖子 返回列表

sitemap| 易语言源码| 易语言教程| 易语言论坛| 易语言模块| 手机版| 广告投放| 精易论坛
拒绝任何人以任何形式在本论坛发表与中华人民共和国法律相抵触的言论,本站内容均为会员发表,并不代表精易立场!
论坛帖子内容仅用于技术交流学习和研究的目的,严禁用于非法目的,否则造成一切后果自负!如帖子内容侵害到你的权益,请联系我们!
防范网络诈骗,远离网络犯罪 违法和不良信息举报电话0663-3422125,QQ: 793400750,邮箱:wp@125.la
Powered by Discuz! X3.4 揭阳市揭东区精易科技有限公司 ( 粤ICP备12094385号-1) 粤公网安备 44522102000125 增值电信业务经营许可证 粤B2-20192173

快速回复 返回顶部 返回列表