如何使用 Python 流套接字作为代理？

发布于 2024-12-11 20:38:56 字数 975 浏览 0 评论 0原文

我正在尝试编写一个侦听端口的 python 进程，当客户端连接到它时，它会启动一个执行以下操作的线程：

连接到远程服务 (http://193.108.24.18:8000 /magicFM)
将收到的任何数据传递到连接的客户端（恰好是 Windows Media Player）

故事是，我想在工作时收听广播，但我不能，因为我在另一个国家/地区（仅在全国范围内可用），我无法更改计算机上的代理设置...... 但我有这台服务器，我想将其用作代理。

提前致谢。

这是我到目前为止所做的：

#!/usr/bin/env python
import socket, urllib2

TCP_IP = '0.0.0.0'
TCP_PORT = 5566
BUFFER_SIZE = 16 * 1024  #16 kb/s
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((TCP_IP, TCP_PORT))
s.listen(1)
conn, addr = s.accept()
print 'Connection address:', addr
req = urllib2.urlopen('http://193.108.24.18:8000/magicFM')

while 1:
    chunk = req.read(BUFFER_SIZE)
    if not chunk: break
    conn.send(chunk)


conn.close()

但它失败了......：

Traceback (most recent call last):
  File "./magicfmproxy.py", line 17, in ?
    conn.send(chunk)
socket.error: (32, 'Broken pipe')

原文

I'm trying to write a python process which listens on a port and when a client connects to it, it starts up a thread which does the following:

Connects to a remote service (http://193.108.24.18:8000/magicFM)
Passes any data received to the connected client (which happens to be Windows Media Player)

The story is that I want to listen to my radio at work, but I cannot because I am in another country(available only nationally) and I cannot change the proxy settings on my computer....
But I have this server which I would like to use as a proxy.

Thanks in advance.

Here's what I did so far:

#!/usr/bin/env python
import socket, urllib2

TCP_IP = '0.0.0.0'
TCP_PORT = 5566
BUFFER_SIZE = 16 * 1024  #16 kb/s
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((TCP_IP, TCP_PORT))
s.listen(1)
conn, addr = s.accept()
print 'Connection address:', addr
req = urllib2.urlopen('http://193.108.24.18:8000/magicFM')

while 1:
    chunk = req.read(BUFFER_SIZE)
    if not chunk: break
    conn.send(chunk)


conn.close()

but it fails... with:

Traceback (most recent call last):
  File "./magicfmproxy.py", line 17, in ?
    conn.send(chunk)
socket.error: (32, 'Broken pipe')

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

清旖 2024-12-18 20:38:56

首先，要使用 TCP 连接到远程站点，请使用以下代码

import socket, struct

def connectToHost(host, port=80, timeout=0):
    try:
            sock=socket.socket()
            timeval=struct.pack("2I", timeout, 0)
            sock.setsockopt(socket.SOL_SOCKET, socket.SO_RCVTIMEO, timeval)
            sock.setsockopt(socket.SOL_SOCKET, socket.SO_SNDTIMEO, timeval)
            sock.connect((host, port))
            return sock
    except:
            return None

您现在有一个连接到远程服务器的打开套接字。您必须创建一个侦听套接字并等待该套接字建立连接。连接建立后，立即使用 select 多路复用数据流。

我现在没有时间，这段代码更多的是它的外观草图。您需要适当的错误处理，并且可能需要在此函数中提供不错的错误消息，但如果没有人提出完整的解决方案，我可能会努力完成此代码。

As a start, to connect to a remote site using TCP, use this code

import socket, struct

def connectToHost(host, port=80, timeout=0):
    try:
            sock=socket.socket()
            timeval=struct.pack("2I", timeout, 0)
            sock.setsockopt(socket.SOL_SOCKET, socket.SO_RCVTIMEO, timeval)
            sock.setsockopt(socket.SOL_SOCKET, socket.SO_SNDTIMEO, timeval)
            sock.connect((host, port))
            return sock
    except:
            return None

You now have an open socket connected to a remote server. You would have to create a listen socket and wait on this one for a connection. As soon as the connection is there, multiplex data streams using select.

I don't have the time right now, this code is more of a sketch how it might look like. You would need proper error handling and maybe nice error messages in this function, but if noone comes up with a complete solution I may make the effort to complete this code.

回复收藏 0 原文