dvr項(xiàng)目中flex駐留在瀏覽器，而影響播放程序是獨(dú)立的進(jìn)程，sandbox的安全問(wèn)題導(dǎo)致flex的代碼無(wú)法直接與播放進(jìn)程IPC通信，那只有通過(guò)公網(wǎng)IP的主機(jī)進(jìn)行橋接。 很多年以前用過(guò)foundstone系列的工具，也有socket轉(zhuǎn)向的功能，包括在5173時(shí)做過(guò)lsp的底層轉(zhuǎn)向軟件（仿sockcap）,原理當(dāng)然是相當(dāng)簡(jiǎn)單，python是首選工具。 代碼接收兩端建立socket進(jìn)來(lái)，并根據(jù)相同的id號(hào)來(lái)進(jìn)行socket配對(duì)，之后兩個(gè)socket之間就實(shí)現(xiàn)互相轉(zhuǎn)發(fā)(技術(shù)同之前寫的http代理服務(wù)器 ) 1 # -- coding:utf-8 --
2
3 import socket,traceback,os,os.path,sys,time,struct,base64,gzip,array,threading
4 import select,json
5
6
7 '''
8 {'id','type'}
9
10 type - 'mapshow','imageplay'
11 id - 一次會(huì)話的編號(hào)
12
13 imageplay 與xbridge建立socket連接，并注冊(cè)一個(gè)會(huì)話編號(hào)(隨機(jī)產(chǎn)生)
14 imageplay啟動(dòng)mapshow,并將會(huì)話編號(hào)傳遞給mapshow,mapshow建立xbridge的連接，并提交會(huì)話編號(hào)
15 xbridge將雙向傳遞相同會(huì)話編號(hào)的數(shù)據(jù)到對(duì)方
16
17 sock1的客戶必須等sock2連接進(jìn)入之后發(fā)送數(shù)據(jù)，否則將sock1數(shù)據(jù)轉(zhuǎn)發(fā)給sock2時(shí)將產(chǎn)生異常
18 '''
19
20 class ConnectionPair:
21 def __init__(self,app):
22 self.app = app
23 self.id = ''
24 self.sock1=None #imageplay上來(lái)的連接
25 self.sock2=None #第二個(gè)連接上來(lái)的對(duì)象mapdemo
26
27 def start(self):
28 t = threading.Thread(target=self.threadRecv)
29 t.start()
30
31 def onLostConnection(self):
32 try:
33 print 'connection pair lost..'
34 self.sock1.close()
35 self.sock2.close()
36 self.app.onConnectionPairBroken(self)
37 except:
38 traceback.print_exc()
39
40 def threadRecv(self):
41 print 'service threading entering '
42 import select
43 while True:
44 fds = []
45 if self.sock1:
46 fds.append(self.sock1)
47 if self.sock2:
48 fds.append(self.sock2)
49 #fds = [self.sock1,self.sock2]
50 try:
51 #sock2未連接進(jìn)來(lái)前，將不接收sock1上產(chǎn)生數(shù)據(jù)
52 #print 'fds:',len(fds),fds
53 rds,wds,eds = select.select(fds,[],[],1)
54 if not rds:#timeout
55 continue
56
57 for s in rds:
58 d = s.recv(1024)
59 #print d
60 if not d:
61 raise 'any jump'
62
63 to = self.sock2
64 if s == self.sock2:
65 to = self.sock1
66 #print 'redirect data:',d
67 to.sendall(d)
68 except:
69 traceback.print_exc()
70 self.onLostConnection()
71 break
72
73 print 'ConnThread Exiting'
74
75
76
77
78 class XBridge:
79 def __init__(self,addr=('',12788)):
80 self.sock = None
81 self.addr = addr
82 self.conns={} #{id}
83 self.mtxconns = threading.Lock()
84
85 def onConnectionPairBroken(self,cp):
86 self.mtxconns.acquire()
87 del self.conns[cp.id]
88 print 'onConnectionPairBroken(),removed:',cp.id
89 self.mtxconns.release()
90
91 def start(self):
92 try:
93
94 self.sock = socket.socket()
95 #print 'lll',self.addr
96 self.sock.bind( tuple(self.addr) )
97 self.sock.listen(5)
98
99 self.thread = threading.Thread(target=self.service_loop)
100 self.thread.start()
101 print 'xbridge started!'
102 self.thread.join()
103 except:
104 traceback.print_exc()
105 return False
106
107 def shutdown(self):
108 self.sock.close()
109
110
111 def service_loop(self):
112
113 while True:
114 fdr = []
115 fdr.append(self.sock)
116 infds,wr,e = select.select(fdr,[],[])
117 if e:
118 print 'service thread exit'
119 break
120 for s in infds:
121 if s == self.sock: #新連接到達(dá)
122 sock = None
123 try:
124 sock,peer = self.sock.accept() #異常產(chǎn)生表示self.sock被強(qiáng)行關(guān)閉
125 print 'new client incoming',peer
126 except:
127 return
128 thread = threading.Thread(target=self.threadNewClient,args=(sock,))
129 thread.start()
130
131 def threadNewClient(self,sock):
132 #等待注冊(cè)信息進(jìn)入 ，5 秒超時(shí)
133 try:
134 fdr = [sock,]
135 print 'enter select '
136 infds,wr,e = select.select(fdr,[],[],5)
137
138 if not infds:
139 sock.close()
140 print 'client register timeout'
141 return #接收超時(shí)
142 d = sock.recv(1024)
143 d = json.loads(d)
144 id,type = d['id'],d['type']
145 connpair = None
146 print id,type
147 self.mtxconns.acquire()
148 if type == 'imageplay':
149
150 cp = ConnectionPair(self)
151 cp.id = id
152 cp.sock1 = sock
153 self.conns[id] = cp
154 cp.start()
155
156 elif type =='mapshow':
157 connpair = self.conns.get(id,None)
158 if connpair == None: #沒(méi)找到imageplay
159 sock.close()
160 print 'mapshow cannt found imageplay..'
161 else:
162 print 'mapclient matched!'
163 connpair.sock2 = sock
164 else:
165 print 'unknown command id:',id,type
166
167 self.mtxconns.release()
168 except:
169 sock.close()
170 traceback.print_exc()
171
172 if __name__=='__main__':
173 XBridge().start() #default '',12788
174
|