数学建模社区-数学中国

标题: 串口转tcp工具 [打印本页]

---

作者: 2744557306    时间: 2024-3-31 17:19
标题: 串口转tcp工具

1. #coding=utf-8
   0 W" I, S' s+ d/ e5 K
2. 
   6 D* s! |1 [7 Z# Z6 q9 m/ P
3. 
   
4. import sys,threading,time;
   / m8 @) e: c) i6 i9 y
5. import serial;
   
6. import binascii,encodings;
   , p3 _7 V( g4 `/ V9 z/ N8 U# O
7. import re;
   
8. import os;
   , |% J6 J3 O- H$ e" G
9. from socket import *
   
10. from struct import *;
    - o4 k6 T8 _* E7 w: c7 h! @# a/ n
11. #from myutil import *;
    
12. #name: myutil.py
    
13. 
    
14. mylock = threading.RLock()
    
15. 
    * Y3 ~/ C2 ~* j, w$ B' y. U
16. Server_IP = ''
    - `" A  d4 L2 |4 h- u1 `9 ^
17. Srever_Port = ''
    
18. 
    ) V9 w; W+ Y4 d# I( {+ }
19. def print_hex1(s,prev='0x'):
    
20.     for c in s:
    
21.         print '%s%02x' %(prev,ord(c)),
    5 A9 f0 F0 G" R& ?6 O  H7 w
22.     print
    . N" W+ c3 v/ \1 |
23. def print_hex(s):
    . M" v& h# G$ ]5 M
24.     for c in s:
    
25.       print '%02x' %(ord(c)),
    3 F6 Y* p  b+ T
26.     print
    
27. 
    2 t, ?7 k& B  o
28. def hexto_str(s):
    ( N0 K4 u. R! L! h$ j
29.   r =''
    
30.   for c in s:
    ( y7 X$ v  q0 j* e1 A+ c
31.     r += '%02x' %(ord(c))
    
32.   return r
    . y* G% Y. L  u' n5 R
33. def strto_hex(s):
    
34.   r = s.decode('hex')
    / W4 j  z% N3 Y( N2 E% C  ?# k
35.   return r
    
36. #''代表服务器为localhost
    6 x" v/ X/ A+ n. [* D3 A
37. 
    
38. #在一个非保留端口号上进行监听
    
39. 
    
40. 
    
41. class ComThread:
    1 a5 ^+ Y2 ]: J& e
42.     def __init__(self, Port=0):
    
43.         self.l_serial = None;
    $ M' `8 ?3 a2 x: B0 J0 ?
44.         self.alive = False;
    
45.         self.waitEnd = None;
    
46.         self.port = Port;
    8 P1 ~* `) M3 D. O
47. 
    5 i: h4 ]# I% j8 k: U& n) c
48.         #TCP部分
    6 A; ~% |; H0 {
49.         #self.sockobj = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    5 c+ f5 \) i. `+ k) r$ W' z
50.         self.connection = None
    2 m7 a% @: {5 W) l; M# P; E" T
51.         #数据
    - a2 u- z9 r0 q
52.         self.snddata = ''
    
53.         self.rcvdata = ''
    4 k/ P- X6 k: Z
54. 
    6 r$ H: N& A9 ~( ?# D0 Q6 ~% s& g. @9 l
55.     def waiting(self):
    ; w# d0 ^- A. i! j5 }2 U6 I" R
56.         if not self.waitEnd is None:
    
57.             self.waitEnd.wait();
    
58. 
    
59. 
    
60.     def SetStopEvent(self):
    / j$ u! y* i1 U/ p) d2 c
61.         if not self.waitEnd is None:
    
62.             self.waitEnd.set();
    ; Z  y  J  a2 K2 B0 y- ^# H
63.         self.alive = False;
    * U! X  R7 i- c* M6 S3 N, e
64.         self.stop();
    
65. 
    - a4 \" T& T5 N) Z/ P' A5 _- y
66. 
    + t: B& |( [# p& g0 H2 T
67.     def start(self):
    
68.         self.l_serial = serial.Serial();
    0 z- d$ F( W- z* }9 j
69.         self.l_serial.port = self.port;
    
70.         self.l_serial.baudrate = 115200;
    * c4 s7 H! \4 k% d- @
71.         self.l_serial.timeout = 2;  #秒
    ! p  P! e* y( h, w8 t* X; [/ g, y
72.         self.l_serial.open();
    & i2 e" q2 ^& T: O+ W& V
73. 
    0 H; i: h2 K/ G6 c# |* I. i" n
74.         if self.l_serial.isOpen():
    . l5 o4 u/ v5 }. H9 H) v
75.             self.waitEnd = threading.Event();
    6 y0 r* m8 i) \- J% X2 d
76.             self.alive = True;
    * U- g7 \6 \; l. F" |" |# Z. M
77.             print 'open serial port %d ok!\n' %(self.port+1)
    
78.             print 'baudrate:115200 \n'
    1 E* P, e- B8 ]" g! J( s9 ~. c8 f; c
79.             self.thread_read = None;
    ! a$ J0 o/ g6 S- h" @$ F
80.             self.thread_read = threading.Thread(target=self.FirstReader);
    % Q1 D9 e6 L& }  i
81.             self.thread_read.setDaemon(1);
    " Q6 o" P# J1 D9 P0 N/ R0 [
82.             self.thread_read.start();
    
83. 
    
84.             self.thread_write = None;
    
85.             self.thread_write = threading.Thread(target=self.FirstWriter);
    
86.             self.thread_write.setDaemon(1);
    
87.             self.thread_write.start();
    1 y$ _6 k: k. p
88. 
    # E/ l+ m! W; F4 O
89.             #TCP部分
    
90.             self.thread_TcpClient = None;
    + U0 b' C. \7 P' r8 G' b+ u
91.             self.thread_TcpClient = threading.Thread(target=self.TcpClient);
    ' w8 s( H5 Y7 P9 e# i
92.             self.thread_TcpClient.setDaemon(1);
    
93.             self.thread_TcpClient.start();
    7 V+ C8 }. B' e% K+ T
94. 
    
95.             self.thread_TcpSend = None;
    3 R- W; E. R# [+ |  x, O8 N
96.             self.thread_TcpSend = threading.Thread(target=self.TcpSend);
    $ y% Y- M% N9 A9 a4 t/ ?. X' e/ H9 ]
97.             self.thread_TcpSend.setDaemon(1);
    9 E8 x  ^% w1 Y% I: t) \. F* k6 a( H
98.             self.thread_TcpSend.start();
    
99. 
    
100.             return True;
     
101.         else:
     3 A& O- }( ~% @, W1 |
102.             return False;
     
103. 
     ! X' j( }, M  x, p, O7 z( X
104. 
     $ F- x) s" B3 B3 \$ I( E$ b) A
105.     def FirstReader(self):
     , C* E4 o; y3 [1 E& ?7 X# E
106.         while self.alive:
     6 ^1 |- t+ w" a' y! U
107.             # 接收间隔
     - q  p# x0 C7 b; ~. n) B
108.             time.sleep(0.1);
     ' N0 V9 O& X0 R' u7 Y
109.             try:
     5 S; ~9 \' B$ Q8 D7 K; }
110.                 data = '';
     0 z% i* k. |  s! i0 H. f! B
111.                 n = self.l_serial.inWaiting();
     4 F7 p: h  C. A: |2 G9 x
112.                 if n:
     / |- _& ~. O  e; s) Q; Z
113.                     data = data+self.l_serial.read(n);
     
114.                     #for l in xrange(len(data)):
     ( a5 i8 h! |0 T1 e
115.                         #print '%02X' % ord(data[l]),
     
116.                     # 发送数据
     
117.                     print u'->请求:'
     , P! v# d- _1 F
118.                     print data;
     
119.                     mylock.acquire()
     / ?, J" ~7 A: u- ?7 q
120.                     self.snddata = data
     $ T9 D5 {  M& ?: F4 w- j: F2 k
121.                     mylock.release()
     7 f, M% i* Q6 h& I  K& L) O
122.                     #print_hex(data);
     
123.                
     - \& {9 y# t# g0 `
124.                     
     1 e2 v* C2 H# D6 }- n
125.                 # 判断结束
     
126.                
     3 ~- G5 n5 v+ p# P9 [0 n( b& W
127.             except Exception, ex:
     . O) _- |* }: T/ X$ U( E8 ^+ ^
128.                 print str(ex);
     # l/ x  O; K, i# @5 P8 M
129. 
     
130.         self.waitEnd.set();
     * y# X/ f* a% M  a$ u
131.         self.alive = False;
       Z8 z- f, z1 `, @& ^$ F
132. 
     + n6 G6 Y1 m8 X7 ~2 _+ U
133.     def FirstWriter(self):
     $ \2 {/ z& W& V4 c/ _! Y
134.         while self.alive:
     
135.             # 接收间隔
     
136.             time.sleep(0.1);
     7 e; E* ^: h- k  T. z; G# N+ N
137.             try:
     : U6 t! B; f9 v8 R! |$ h
138.                 #snddata = raw_input('\nenter data send:\n')
     
139.                 if self.rcvdata!='':
     ! f0 [% @! e! ]: m4 ]# T
140.                     self.l_serial.write(self.rcvdata);
     $ @8 W2 r$ p  d% s0 {
141.                     print u'-<应答:'
     8 o& m/ [' X/ k% c
142.                     print self.rcvdata;
     
143.                     mylock.acquire()
     , V6 N; f/ _, @
144.                     self.rcvdata = '';
     ; C4 ~: l9 @1 q- m7 N2 f; g( x7 ~
145.                     mylock.release()
     0 I4 c8 z3 {0 p- z! {
146.                 #print_hex(snddata);
     
147.                
     
148.             except Exception, ex:
       w4 }, E6 \9 O7 ]  v
149.                 print str(ex);
     
150.         self.waitEnd.set();
     4 I+ j* M* N& J" \" S3 l
151.         self.alive = False;
     * a" q% ^) L( O: R3 @. ~# ?4 Y
152. 
     6 D$ S# m! N2 T0 N
153.     def TcpClient(self):
     
154.         while True:
     . a; V3 B! v" T& q( i
155.             # 接收间隔
     
156.             time.sleep(0.1);
     2 B6 ?' @1 Z! S1 G1 l; c
157.             self.connection = socket(AF_INET, SOCK_STREAM);
     
158.             self.connection.connect((Server_IP, int(Server_Port)));
     & k# ?% G3 b! B, \( [
159.             print 'Connect to Server OK!';
     
160.             self.snddata = ''
     $ z  n* m6 b0 q
161.             self.rcvdata = ''
     * h( l3 J6 ?3 J+ d
162.             while True:
     
163.             #读取客户端套接字的下一行
     2 P8 x( r. D/ U3 I5 Q7 c
164.             data = self.connection.recv(1024)
     , t7 C9 m$ \5 R, o% S  g/ ]
165.             #如果没有数量的话，那么跳出循环
     
166.             if not data: break
     
167.             #发送一个回复至客户端
     
168.             mylock.acquire()
     4 [' S5 d6 E# H
169.             self.snddata = ''
     
170.             self.rcvdata = data
     6 ~; n1 S/ A$ z; `4 Q* }3 L3 ]; \
171.             mylock.release()
     " q% Y  r# }- a  ~5 u7 y$ m
172.             #connection.send('Echo=>' + data)
     . W  h0 j+ s, L+ _. b# H! \" }
173.             self.connection.close()
     : I& M* H  u' k8 C; A% G
174. 
     
175.         self.waitEnd.set();
     4 R4 K$ U& a0 q( n
176.         self.alive = False;
     9 I! K* ]* {) b9 k  t
177. 
     7 R! A5 l+ @; o
178.     def TcpSend(self):
     2 k* D0 L! W1 c; w6 i
179.         while True:
     9 N" F: ~: [/ k7 z' I- A: d* N
180.             # 接收间隔
     
181.             time.sleep(0.1);
     0 d; O) i5 Y, l; \  ~7 g( U
182.             while True:
     
183.               time.sleep(0.1);
     % c, G3 G% D" F- _  B4 s
184.               try:
     
185.                 if not self.connection is None:
     
186.                   if self.snddata != '':
     
187.                     self.connection.send(self.snddata)
     , |8 @9 v) l2 [( o* l9 u$ `
188.                     mylock.acquire()
     
189.                     self.rcvdata = ''
     
190.                     self.snddata = ''
     0 e5 I! K7 }3 z  T
191.                     mylock.release()
     
192.               except Exception, ex:
     ; ?* f4 A% r: D
193.             pass        
     & O1 \2 m% C) l( x9 K$ Z
194.     def stop(self):
     
195.         self.alive = False;
     ( ], I, m$ q" T* {, C' z
196.         self.thread_read.join();
     
197.         if self.l_serial.isOpen():
     6 T4 B. }$ G1 j- x
198.             self.l_serial.close();
     ( V9 Y& g+ p" B0 R& S
199. 
     0 i* B1 k- Z8 ?1 }
200. 
     
201. 
     / i! X. l. u) S( v, [2 q( T
202. #测试用部分
     & n% q/ _( X' o: B1 I9 g. i
203. if __name__ == '__main__':
     
204.     print 'Serial to Tcp Tool 1.00\n'
     
205.     print 'Author:yangyongzhen\n'
     ( d8 B1 K- Q- E4 _8 w! w# `4 W# G4 u
206.     print 'QQ:534117529\n'
       _6 k  Z) }- B3 J' J# f
207.     print 'Copyright (c) **cap 2015-2016.\n'
     
208. 
     
209.     Server_IP = raw_input('please enter ServerIP:')
     
210.     print 'Server_IP: %s' %(Server_IP)
     * _/ v! C- u  V- R: Y2 M; b& T2 A
211.     Server_Port = raw_input('please enter ServerPort:')
     
212.     print 'Server_Port: %s' %(Server_Port)
     
213.     com =raw_input('please enter com port(1-9):')
     $ i# a0 u3 m  Z1 ~( Q# k+ j% b2 q
214.     rt = ComThread(int(com)-1);
     
215.     try:
     5 ~1 \2 Z% J6 W3 h5 O2 t
216.         if rt.start():
     - n" ^7 n+ W' Z$ L
217.             rt.waiting();
     
218.             rt.stop();
     # ?. t" E+ b& @7 s! H4 u
219.         else:
     * K  h, ^3 y+ f' Z
220.             pass;            
     
221.     except Exception,se:
     
222.         print str(se);
     
223. 
     ) e9 f& D2 l- S( h
224.     if rt.alive:
     
225.         rt.stop();
     3 ?( C. d9 L2 N- l$ |
226.     os.system("pause")
     
227. 
     2 F7 A1 \/ v+ h4 }5 ~0 j' e8 D
228.     print '';
     
229.     print 'End OK .';
     
230.     del rt;

复制代码

---

欢迎光临 数学建模社区-数学中国 (http://www.madio.net/)

Powered by Discuz! X2.5