1
This commit is contained in:
parent
fb88daaa61
commit
1172fc16fd
@ -1,4 +1,15 @@
|
|||||||
# -*- coding: utf-8 -*-
|
# -*- coding: utf-8 -*-
|
||||||
|
import os
|
||||||
|
import json
|
||||||
|
import random
|
||||||
|
import time
|
||||||
|
import threading
|
||||||
|
import tornado.ioloop
|
||||||
|
import tornado.web
|
||||||
|
import tornado.gen
|
||||||
|
import tornado.websocket
|
||||||
|
import tornado.tcpserver
|
||||||
|
from tornado.tcpclient import TCPClient
|
||||||
|
|
||||||
class ClientSide:
|
class ClientSide:
|
||||||
|
|
||||||
@ -6,5 +17,10 @@ class ClientSide:
|
|||||||
self._local_ip = local_ip
|
self._local_ip = local_ip
|
||||||
self._remote_ip = remote_ip
|
self._remote_ip = remote_ip
|
||||||
|
|
||||||
|
@gen.coroutine
|
||||||
|
def co_connect():
|
||||||
|
[host, port] = self._local_ip.split(':')
|
||||||
|
stream = yield TCPClient().connect(host, port)
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
pass
|
ioloop.IOLoop.current().run_sync(self,connec)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user