Lua/Python 中的持续 socket 连接
2019-5-25 0:40:53
收藏：0
阅读：85
评论：1
我正在尝试创建一个 Lua 客户端和 Python 服务器之间的持续 socket 连接。实际上，我想要创建一个脚本，该脚本将使用 keepalive 消息不断地向服务器发送 ping。
我的当前问题是每次连接后套接字都会关闭，没有重新打开以进行传输的方法。
Lua 客户端：
local HOST, PORT = "localhost", 9999
local socket = require('socket')
-- 创建客户端并进行初始连接
client, err = socket.connect(HOST, PORT)
client:setoption('keepalive', true)
-- 每秒尝试向服务器发送 ping
start = os.time()
while true do
now = os.time()
if os.difftime(now, start) >= 1 then
data = client:send("Hello World")
-- 从服务器接收数据并打印全部内容
s, status, partial = client:receive()
print(data, s, status, partial)
start = now
end
end
Python 服务器：
import socketserver
class MyTCPHandler(socketserver.BaseRequestHandler):
def handle(self):
self.data = self.request.recv(1024).strip()
print("{} wrote".format(self.client_address[0]))
print(self.data)
print(self.client_address)
# 发送一些任意数据给客户端
self.request.sendall(b'1')
if __name__ == '__main__':
HOST, PORT = "localhost", 9999
# 创建一个 socketserver 并且永久服务
with socketserver.TCPServer((HOST, PORT), MyTCPHandler) as server:
server.serve_forever()
预期结果是每秒钟发送一次 keepalive ping，以确保客户端仍然连接到服务器。
点赞
评论区的留言会收到邮件通知哦~
作者:
用户11553028
推荐文章
- Lua 虚拟机加密load(string.dump(function)) 后执行失败问题如何解决
- 我想创建一个 Nginx 规则，禁止访问
- 如何将两个不同的lua文件合成一个 东西有点长 大佬请耐心看完 我是小白研究几天了都没搞定
- 如何在roblox studio中1：1导入真实世界的地形？
- 求解，lua_resume的第二次调用继续执行协程问题。
- 【上海普陀区】内向猫网络招募【Skynet游戏框架Lua后端程序员】
- SF爱好求教：如何用lua实现游戏内调用数据库函数实现账号密码注册？
- Lua实现网站后台开发
- LUA错误显式返回，社区常见的规约是怎么样的
- lua5.3下载库失败
- 请问如何实现文本框内容和某个网页搜索框内容连接，并把网页输出来的结果反馈到另外一个文本框上
- lua lanes多线程使用
- 一个kv数据库
- openresty 有没有比较轻量的 docker 镜像
- 想问一下，有大佬用过luacurl吗
- 在Lua执行过程中使用Load函数出现问题
- 为什么 neovim 里没有显示一些特殊字符?
- Lua比较两个表的值（不考虑键的顺序）
- 有个lua简单的项目，外包，有意者加微信 liuheng600456详谈，最好在成都
- 如何在 Visual Studio 2022 中运行 Lua 代码？
我最终找到了一个解决方案。
问题似乎出现在 Python 中的 socketserver 库上。我把它换成了原始套接字，然后事情开始按照我想要的方式运行了。从那里，我创建了线程来处理后台的来回交流。
Python 服务器：
import socket, threading HOST, PORT = "localhost", 9999 # 确保连接仍然活跃 def keepalive(conn, addr): print("客户端已连接") with conn: conn.settimeout(3) while True: try: data = conn.recv(1024) if not data: break message = data.split(b',') if message[0] == b'ping': conn.sendall(b'pong' + b'\n') except Exception as e: break print("客户端已断开连接") # 监听连接到服务器的连接，并启动新的 keepalive 线程 def listenForConnections(): with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as sock: sock.bind((HOST, PORT)) while True: sock.listen() conn, addr = sock.accept() t = threading.Thread(target=keepalive, args=(conn, addr)) t.start() if __name__ == '__main__': # 启动套接字服务器 SERVER = threading.Thread(target=listenForConnections) SERVER.start() # 在此之后运行任何代码Lua 客户端在此情况下未更改。