如何将JavaScript(AJAX)回调函数返回值传递至Python WebSocket服务器

我来帮你解决这个卡了几小时的问题！你已经写好了获取地理位置的AJAX函数，接下来只需要在回调里加上WebSocket的发送逻辑，再配合一个Python的WebSocket服务器就能搞定，分两部分给你讲清楚：

首先先修正你原函数里的小问题——long和lat没有用let/const声明，会变成全局变量，容易引发意外问题。然后在success回调里加入WebSocket的连接和数据发送逻辑：

function get_locations(callback){
 $.ajax({
 data: 'data to send',
 url: "https://geoip-db.com/jsonp",
 jsonpCallback: "callback",
 dataType: "jsonp",
 success: function (location) {
   // 用const声明变量，避免全局污染
   const longitude = location.longitude;
   const latitude = location.latitude;
   // 整理成结构化的数据，方便后端解析
   const locationData = {
     latitude: latitude,
     longitude: longitude,
     city: location.city, // 可选，如果你需要其他字段可以加进来
     country: location.country_name
   };

   // 连接你的Python WebSocket服务器，替换成实际的服务器地址和端口
   const ws = new WebSocket('ws://localhost:8000');

   // 连接成功时发送数据
   ws.onopen = function() {
     // WebSocket只能发送字符串，所以要转成JSON格式
     ws.send(JSON.stringify(locationData));
     console.log('位置数据已成功发送到服务器');
     // 如果不需要保持连接，发送完可以关闭
     ws.close();
   };

   // 处理WebSocket连接错误
   ws.onerror = function(error) {
     console.error('WebSocket连接出错了:', error);
   };

   // 继续执行你原本的回调逻辑
   callback(location);
 },
 error: function () {
   console.error('获取地理位置失败，请检查网络或接口状态');
 }
 });
}

我们用Python常用的websockets库来搭建一个简单的服务器，用来接收前端发来的位置数据：

第一步：安装依赖 #

先在终端里安装websockets库：

pip install websockets

第二步：编写服务器脚本 #

创建一个ws_server.py文件，写入以下代码：

import asyncio
import websockets
import json

async def handle_client(websocket):
    try:
        # 接收前端发来的JSON字符串
        raw_data = await websocket.recv()
        # 解析成Python字典
        location_data = json.loads(raw_data)
        
        # 这里可以添加你的业务逻辑，比如存储到数据库、做地理计算等
        print("收到客户端的位置数据：")
        print(f"纬度：{location_data['latitude']}")
        print(f"经度：{location_data['longitude']}")
        print(f"城市：{location_data.get('city', '未知')}")
    except json.JSONDecodeError:
        print("收到的数据格式不正确，无法解析")
    except Exception as e:
        print(f"处理请求时出错：{str(e)}")

async def run_server():
    # 启动服务器，监听本地8000端口，允许所有客户端连接
    async with websockets.serve(handle_client, "0.0.0.0", 8000):
        await asyncio.Future()  # 保持服务器持续运行

if __name__ == "__main__":
    asyncio.run(run_server())

• 跨域问题：如果你的前端页面和WebSocket服务器不在同一个域名/端口，需要在服务器端配置跨域允许。可以在websockets的process_request方法中添加CORS响应头，或者用aiohttp结合websockets来处理跨域。
• 服务器地址：前端代码里的ws://localhost:8000要替换成你实际部署服务器的公网IP和端口（比如ws://your-server-ip:8000）。
• 连接稳定性：如果需要持续通信，可以不要在发送完数据后立即关闭WebSocket，而是保持连接；如果只是单次发送数据，关闭连接更节省资源。

内容的提问来源于stack exchange，提问作者ewalel