1

我对python有点陌生。我目前正在尝试在程序中制作和使用套接字列表/数组。所以我声明了一个数组，如下所示：

myCSocks = ['CSock1', 'CSock2', 'CSock3', 'CSock4', 'CSock5']

我正在尝试按如下方式使用我的数组元素：

myCSocks[i], addr = serverSocket.accept()
message = myCSocks[i].recv(1024)

我收到以下错误：

Traceback (most recent call last):
  File "./htmlserv_multi.py", line 22, in <module>
    message = myCSocks[i].recv(1024)
AttributeError: 'str' object has no attribute 'recv'

这对我来说很有意义，它是说我的数组元素是 String 类型而不是套接字。所以我明白我的问题是什么，但我不知道如何解决它。我用谷歌搜索了“python 套接字列表”，但没有找到任何东西。任何帮助将不胜感激。谢谢你。

PS：我的最终目标是创建一个非常简单的多线程 TCP Web 服务器（使用 python）

代码：

#! /usr/bin/env python
from socket import *

#does this work?
myCSocks = []

serverSocket = socket(AF_INET, SOCK_STREAM)
serverSocket.bind(('192.168.1.4',12000))
serverSocket.listen(5)
while True:
  for i in range(0, len(myCSocks)+1):
    myCSocks[i], addr = serverSocket.accept()
  try:
    for i in range(0, len(myCSocks)):
      message = myCSocks[i].recv(1024)
      filename = message.split()[1]
      f = open(filename[1:])
      outputdata = f.read()
      myCSocks[i].send('HTTP/1.1 200 OK\r\n\r\n')
      for p in range(0, len(outputdata)):
        myCSocks[i].send(outputdata[p])
      myCSocks[i].close()
  except IOError:
    connectionSocket.send('HTTP/1.1 404 Bad Request\r\n\r\n')
    connectionSocket.send('<HTML><p>ERROR 404: BAD REQUEST!</p></HTML>')
    serverSocket.close()
    exit()
4

3 回答 3

2

看看这里的内置套接字模块（http://docs.python.org/2/library/socket.html）。这允许您创建套接字，以及发送和接收数据，在线文档中有简单的示例。如果您用实际的套接字替换字符串，您的代码可能会起作用。如果要按名称存储多个套接字，可以使用字典：

theDict = {}
theDict['socket1'] = socket.socket()

等等

于 2013-10-26T22:09:37.480 回答
1

如果 CSock1 是一个已经定义的类，您可以只引用类对象。但是，如果您正在尝试执行多线程，有更好的方法可以做到这一点：Python 中的多线程 Web 服务器。如果您只是想使用套接字，我会看看Python 中的多线程 TCP 服务器（第二个答案是最好的）。

于 2013-10-26T22:05:01.170 回答
1

一个非常简单的 echo TCP ( SOCK_STREAM) 服务器，演示了如何实现多处理服务器。用于threadPoolExecutor异步接受连接。

服务器：

import socket
import concurrent.futures


def server_instance(addr):
    HOST = addr[0]
    PORT = addr[1]
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
        s.bind((HOST, PORT))
        s.listen()
        conn, addr = s.accept()
        with conn:
            print(f"Linked with: {addr}")
            while True:
                data = conn.recv(1024)
                if not data:
                    break
                conn.sendall(data)
    return f'DONE'


addresses = [
    ('127.0.0.1', 65432),
    ('127.0.0.1', 65431),
    ('127.0.0.1', 65433),
    ('127.0.0.1', 65435),
    ('127.0.0.1', 65434),
]


with concurrent.futures.ThreadPoolExecutor() as executor:
    for address, status in zip(addresses, executor.map(server_instance, addresses)):
        print(f"{address}: {status}")

向服务器发送数据的客户端。

客户：

import socket
import sys

HOST = '127.0.0.1'


if len(sys.argv) != 3:
    print(f"[*] Usage: python {sys.argv[0]} <PORT> <MESSAGE>")
    sys.exit()

PORT = int(sys.argv[1])
print(f"PORT SET TO: {PORT}")

MSG = bytes(sys.argv[2], encoding='utf8')
print(f"MESSAGE SET TO: {MSG}")

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
    s.connect((HOST, PORT))
    s.sendall(MSG)
    data = s.recv(1024)

print(f'[r] {repr(data)}')

f 字符串需要 python3.6 及更高版本

并发期货需要 python 3.2 及更高版本

于 2019-06-09T03:54:26.333 回答