python - Django和Socket服务器: Can I add socket server instance to “memory” ?

Question

我正在与:

Django 1.11

Python套接字

我有一个这样的套接字服务器:

class SocketServer(threading.Thread):

    def __init__(self, ip="127.0.0.1", port=5000, _buffer=1024):
        super(RoomSocketServer, self).__init__()
        self.IP = ip
        self.PORT = port
        self.RECV_BUFFER = _buffer  # Advisable to keep it as an exponent of 2
        self.CONNECTION_LIST = []  # list of socket clients
        self.MESSAGE_QUEUES = {}  # List of message queue by socket
        self.OUTPUTS = []
        self.SERVER = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
        # this has no effect, why ?
        self.SERVER.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
        self.SERVER.bind((self.IP, self.PORT))
        self.SERVER.listen(10)

        # Add server socket to the list of readable connections
        self.CONNECTION_LIST.append(self.SERVER)
        self.ROOM = Room.objects.create(port=port, ip=ip, type_room=type_room)

    def read_sockets(self, read_sockets):
        ''' ... '''

    def write_sockets(self, write_sockets):
        ''' ... '''

    def error_sockets(self, error_sockets):
        ''' ... '''

    def run(self):
        while 1:
            # Get the list sockets which are ready to be read through select
            read_sockets, write_sockets, error_sockets = select.select(self.CONNECTION_LIST, self.OUTPUTS, [])

            # Read sockets
            self.read_sockets(read_sockets)
            self.write_sockets(write_sockets)
            self.error_sockets(error_sockets)

        self.SERVER.close()

我可以在Django的任何地方运行这样的SocketServer(custom_command， View ， celery ...):

from socket_server import SocketServer

socket_server = SocketServer()
socket_server.start()
# And the code continues while the socket server is running
# I would like to save socket_server instance anywhere to access
# Later from anywhere or trigger a signal to finish it

就像我在上面说的那样，我想知道(如果可能的话)你们中的任何人将服务器实例保存到Django项目的不同部分来访问它吗？

更新

我尝试在Django上使用memcached，但是当我尝试将SocketServer实例存储在memcached上时，出现此错误:

PicklingError: Can't pickle : attribute lookup thread.lock failed

Answer 1

答案是肯定的，而且很简单

serverlst = dict()
for x in range(0,5):
    tmp = SocketServer("",5000+x) # Note that you should change the port because each port can be listened only by one socket server
    tmp.start()
    serverlst[5000+x]=tmp

或者您可以使用以下命令访问服务器套接字

serverlst[5000].getName()   # returns the server socket with port 5000's thread

循环后打印serverlst时，您可以看到此信息

{5000: <SocketServer(Thread-5, started 139741574940416)>, 5001: <SocketServer(Thread-6, started 139741583333120)>, 5002: <SocketServer(Thread-7, started 139741658834688)>, 5003: <SocketServer(Thread-8, started 139741667227392)>, 5004: <SocketServer(Thread-9, started 139741233895168)>}

或者您可以将其添加到list()更新
对不起，我没看到

I would like to know (if possible) where would any of you save the instance of the server to access it from different parts of the Django project

我可以说这取决于您的发展方式，我认为这不是一个好主意。最好在线程和Django项目(例如redis)之间使用桥接器，该桥接器允许您保留数据并从整个系统访问数据，并且可以使用python redis client。