Запускать отдельный код во время работы сервера сокетов? - PullRequest
Новая
       5

Запускать отдельный код во время работы сервера сокетов?

2 голосов
/ 14 сентября 2011

Как я могу запустить работающий сокет-сервер, который принимает входящие соединения и обрабатывает эту часть кода, не имея кода, ожидающего новых соединений, застрявшего в том же цикле?учить.Будет ли полезен обработчик TCP?

Мне просто нужно несколько простых примеров на эту тему.Я хочу что-то вроде части команд на сервере.Так что я могу делать определенные вещи во время работы сервера.

РЕДАКТИРОВАТЬ: Что я пытаюсь сделать: 

1 - TCP server for multiple clients
2 - Respond to more than one at a time when needed
3 - Text input availability at all time, to be used for getting/setting info
4 - A simple way to get/save client address info. Currently using a list to save them.

Ответы [ 3 ]

2 голосов
/ 14 сентября 2011

Вы можете запустить свой сокет-сервер в потоке . 

import threading
import SocketServer

server = SocketServer.TCPServer(('localhost', 0), SocketServer.BaseRequestHandler)
th = threading.Thread(target=server.serve_forever)
th.daemon = True
th.start()
0 голосов
/ 15 сентября 2011

Python имеет встроенную поддержку асинхронной обработки сокетов в модуле asyncore (http://docs.python.org/library/asyncore.html).

Асинхронная обработка сокетов означает, что Вы должны выполнить хотя бы одну итерацию цикла обработки сокетов внутри своего кода (основной цикл): 

asyncore.loop(count=1)

Пример взят из документации: 

import asyncore
import socket

class EchoHandler(asyncore.dispatcher_with_send):

    def handle_read(self):
        data = self.recv(8192)
        if data:
            self.send(data)

class EchoServer(asyncore.dispatcher):

    def __init__(self, host, port):
        asyncore.dispatcher.__init__(self)
        self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
        self.set_reuse_addr()
        self.bind((host, port))
        self.listen(5)

    def handle_accept(self):
        pair = self.accept()
        if pair is None:
            pass
        else:
            sock, addr = pair
            print 'Incoming connection from %s' % repr(addr)
            handler = EchoHandler(sock)

server = EchoServer('localhost', 8080)
# Note that here loop is infinite (count is not given)
asyncore.loop()

Каждый раз, когда сокет принимает соединение, handle_accept вызывается циклом. Каждый раз, когда данные доступны для чтения из сокета, вызывается handle_read и т. Д.

Таким образом вы можете использовать как сокеты TCP, так и UDP.

0 голосов
/ 14 сентября 2011

Я не совсем уверен, что вы спрашиваете, но обычно на стороне сервера вы делаете вызовы socket (), bind () и listen () для настройки сокета, а затем зацикливаетесь на вызове accept ().Этот вызов accept () блокируется до тех пор, пока не будет установлено клиентское соединение.

Для простых серверов вы обрабатываете любой запрос, который клиент делает в цикле.Для реальных серверов вам нужно создать какой-то другой механизм (например, новый поток или процесс, в зависимости от языка / платформы), чтобы обрабатывать запрос асинхронно, чтобы исходный цикл мог повторяться снова при вызове accept () и идтивернуться к прослушиванию соединений.

См. Документацию по сокету Python для получения дополнительной информации и примеров на Python:

http://docs.python.org/howto/sockets.html

...