@kfpenn 拉的不够硬啊，我也是整个部门被干掉了，留了我 /doge

赶紧分吧，兄弟

之前用是经常崩溃，后面买 jb 全家桶用 datagrid 了

人妻仲正

@wuxie01
电商直播公司，公司内部还需要用这个项目，只是不做额外开发了。
我是后端，最熟悉这个项目的人也是我了，所以就留了我帮忙解决一下业务部门的问题。
我猜想暂时只是过度吧，等业务部门都不用这系统了，我也该被裁了

谢谢大家分享~
@zhangxh1023 😂上班爬山确实有点过分了

感觉不至于，我 24 年 8 月充的 10 块钱 现在还在

刚在 v2 看到 cursor 无限 bug 的帖子，蹬了一下，以为自己的号被封了 吓死😂 现在官网的 api 都 503 了

没错，是你电脑问题，我还能正常操作

参与一下

我家的也是，感觉最好是拿跟绳子拴住它

用的 m1 air 16g, 升级了 pycharm2025.3.1, 项目巨卡而且电脑发热严重. analyze 特别慢，后面直接用回了 2024 版本，流畅很多而且不发热

要联系方式是吧？好的

@barnett2010 简单写了个下载 pdf 的 demo, 单纯的 requests 请求. 可以自己优化一下

import requests

headers = {
"Referer": "https://www.dpm.org.cn/Public/static/pdfwrap/js/pdf.worker.js",
"User-Agent": "Mozilla/5.0 (Macintosh; Intel Mac OS X 10_15_7) AppleWebKit/537.36 (KHTML, like Gecko) Chrome/105.0.0.0 Safari/537.36 Edg/105.0.1343.33"
}

url = "https://www.dpm.org.cn/Uploads/File/2022/08/29/u630c38230f984.pdf"

resp = requests.get(url, headers=headers)

total_len = int(resp.headers["Content-Length"])

range_int = 65535

loop = total_len // range_int + 1

for i in range(loop):
if i == loop - 1:
exist = True
start = range_int * i + 1
end = total_len
elif i == 0:
exist = False
start = 0
end = range_int
else:
exist = True
start = range_int * i + 1
end = range_int * (i + 1)

headers["Range"] = f"bytes={start}-{end}"

content = requests.get(url, headers=headers).content

if not exist:
with open("a.pdf", "wb") as f:
f.write(content)
else:
with open("a.pdf", "ab") as f:
f.write(content)

加 referer headers 就解决了

@zhishixiang 感觉可以在注册的时候记录好 request.sid 和 request namespace sid 两个 id, 在服务端监听 disconnect 方法，获取到 request.sid 后拿到对应保存的 namespace sid, 然后再做 close room 或者 leave room 操作

@zhishixiang 不一样的，你可以打印看看。我那个代码可以直接允许的了

@zhishixiang 你的 namespace 跟 sid 要和客户端相同的，所以在连接的时候获取到的 sid 传送给服务端，记录好，test 接口才能发信息给客户端。不能在服务端获取啊

给你贴个可以运行的代码
``` 服务端
from flask import Flask
from flask_socketio import SocketIO, emit, join_room
from loguru import logger

app = Flask(__name__)
app.config['SECRET_KEY'] = 'secret!'
socketio = SocketIO(app)
tokenList = {}


@app.route("/test")
def testConnect():
sid = tokenList["114514"]
data = {'from': 'server'}
# socketio.emit('newMission', data, namespace='/mission')
socketio.emit('newMission', data, to=sid, namespace='/mission')
return 'success'


@socketio.on('register')
def register(data):
sid = data['sid']
print("服务器%s 尝试注册" % data["secret"])
emit('register', {"token": sid})
logger.debug("注册成功，token 为%s" % sid)
join_room(sid)
tokenList["114514"] = sid


@socketio.on('message', namespace='/mission')
def message(data):
print(data) # {'from': 'client'}
# emit('response', {'from': 'server'})
# sleep(5)
# emit('response', "exit")


if __name__ == '__main__':
socketio.run(app, debug=True, host='127.0.0.1', port=8090)
```

``` 客户端
import socketio

sio = socketio.Client()


@sio.on('connect')
def on_connect():
print('正在注册，请稍后')
# 获取 namespace sid, 发送给 server
sid = sio.get_sid('/mission')
sio.emit('register', {'secret': '114514', 'sid': sid})


@sio.on('register')
def isReg(data):
print("receiver message from register ，当前 token 为", data['token'])
pass


@sio.on("newMission", namespace='/mission')
def newMission(data):
print("get mission message data: ", data)


sio.connect('ws://localhost:8090')
sio.wait()
```

主要是获取到 namespace 后，把 namespace sid join room, 记录好 sid. 要 emit 的时候, 加上 namespace 和 roomId(sid)进行发送