如何使用套接字 Tornado 4.4 启动应用程序

Question

我是手动创建套接字的新手。我的 OS 是 ubuntu。我有一个使用 Tornado 编写的 python 代理服务器，当我使用 "fast version" 启动应用程序时一切正常，我的意思是：

if __name__ == "__main__":
    app = make_app()
    port = options.port # default 8000
    if len(sys.argv) > 1:
        port = int(sys.argv[1])
    app.listen(port)
    print 'tornado working on port %s' % port
    tornado.ioloop.IOLoop.current().start()

但是当我想将其更改为使用 'socket version' 时，似乎我做错了什么。我收到一条错误消息，指出该地址已被使用。

代码：

def make_app():
    return MyApplication()

def connection_ready(sock, fd, events):
    while True:
        try:
            connection, address = sock.accept()
        except socket.error as e:
            if e.args[0] not in (errno.EWOULDBLOCK, errno.EAGAIN):
                raise
            return
        connection.setblocking(0)
        app = make_app()
        app.listen(8000) # I get here an error: [Errno 98] Address already in use

if __name__ == "__main__":
    port = options.port # default port 8000
    if len(sys.argv) > 1:
        port = int(sys.argv[1])
    sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM, 0)
    sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
    sock.setblocking(False)
    sock.bind(("", port))
    sock.listen(128)
    io_loop = tornado.ioloop.IOLoop.current()
    callback = functools.partial(connection_ready, sock)
    io_loop.add_handler(sock.fileno(), callback, io_loop.READ)
    io_loop.start()

我正在尝试按照文档所述的方式实施 (http://www.tornadoweb.org/en/stable/ioloop.html)，但我没有看到它在那里启动应用程序。

谁能告诉我使用套接字启动应用程序的正确方法是什么？我正在尝试完成一个在服务器接受传入套接字时可用的应用程序。（因此，每个连接到我的列表端口的客户端都在主函数行中描述：sock.bind(("", port)) 和 sock.listen(128) 将获得一个新套接字并可以访问应用程序）。

编辑：我正在添加我的代理 class:

class ProxyHandler(tornado.web.RequestHandler):

    SUPPORTED_METHODS = ['GET', 'POST']

    def data_received(self, chunk):
        pass

    def compute_etag(self):
        return None  # disable tornado Etag

    def handle_response(self, response):
        if response.error and not isinstance(response.error, tornado.httpclient.HTTPError):
            self.set_status(500)
            self.write('Internal server error:\n' + str(response.error))
        else:
            self.set_status(response.code, response.reason)
            self._headers = tornado.httputil.HTTPHeaders()  # clear tornado default header

            for header, v in response.headers.get_all():
                 if header not in ('Content-Length', 'Transfer-Encoding', 'Content-Encoding', 'Connection'):
                    self.add_header(header, v)  # some header appear multiple times, eg 'Set-Cookie'

            secured_page = False
            for page in secure_pages:
                if page in self.request.uri:
                    secured_page = True
                    self.set_header('Content-Length', len(response.body))
                    self.write(response.body)
                    break
            if response.body and not secured_page:
                c.execute('SELECT filter_name FROM filters WHERE filter_type=1')
                tags = c.fetchall()
                soup = BeautifulSoup(response.body, 'html.parser')
                for row in tags:
                    catched_tags = soup.find_all(str(row[0]))
                    if catched_tags:
                        print 'catched: %s of <%s> tags' % (len(catched_tags), str(row[0]))
                    for tag in catched_tags:
                        tag.extract()
                new_body = str(soup)
                self.set_header('Content-Length', len(new_body))
                self.write(new_body)
        self.finish()

    @tornado.web.asynchronous
    def get(self):
        logger.debug('Handle %s request to %s', self.request.method, self.request.uri)

        body = self.request.body
        if not body:
            body = None

        try:
            if 'Proxy-Connection' in self.request.headers:
                del self.request.headers['Proxy-Connection']

            c.execute('SELECT filter_name FROM filters WHERE filter_type=2')
            urls = c.fetchall()
            for url in urls:
                if url[0] in self.request.path:
                    self.set_status(403)
                    self.finish()
                    return

            fetch_request(self.request.uri, self.handle_response,
                      method=self.request.method, body=body, headers=self.request.headers, follow_redirects=False,
                      allow_nonstandard_methods=True)
        except tornado.httpclient.HTTPError as e:
            if hasattr(e, 'response') and e.response:
                self.handle_response(e.response)
            else:
                self.set_status(500)
                self.write('Internal server error:\n' + str(e))
                self.finish()

    @tornado.web.asynchronous
    def post(self):
        return self.get()

以及我的申请网址：

urls = [
url(r"/admin/$", mainHandlers.MainHandler),
url(r"/admin/delete_filter/", mainHandlers.DataDeleteHandler),
url(r"/admin/filters/$", mainHandlers.DataGetter),
url(r"/admin/new_filter/$", mainHandlers.FormHandler),
url(r"/admin/stats/$", mainHandlers.StatsTableHandler),
url(r"/admin/stats/query/$", mainHandlers.AjaxStatsGetHandler),
url(r"/static/", StaticFileHandler, dict(path=settings['static_path'])),
url(r'.*', myProxy.ProxyHandler),
]

Answer 1

如果您在 Windows 上启动应用程序，您必须等待防火墙解锁。在 windows 中可以安全地假设，如果一个应用程序占用一个端口，它会被其他进程阻止使用，这些进程可能会侦听不适合它们的数据包。

Answer 2

它说端口已被使用，因为它是。您至少在端口 8000 上监听了两次：一次是在 __main__ 块中调用 sock.listen，一次是在 connection_ready 处理程序中调用 app.listen()（这会创建另一个套接字并尝试将其绑定到端口 8000）。您需要删除 app.listen() 行，但我不明白您正在尝试做的事情足以说明您应该做什么。

Answer 3

我已经将我的代理重写为套接字上的纯 Python 代码，我现在不使用 URL，我只处理来自远程地址的响应。我没有使用任何框架

如何使用套接字 Tornado 4.4 启动应用程序

How to start app using sockets Tornado 4.4

python

sockets

network-programming

tornado