socketserver study

Author: CoderHuo

studyLib/socket/my_tcp_client.py

@@ -8,15 +8,15 @@
 
 
 def main():
-    server_addr = ('146.11.22.128', 9999)
+    server_addr = ('146.11.22.166', 20000)
     client = socket.socket()
     client.connect(server_addr)
-    send_data1 = [b'aheuo', b'ashxao', b'bhaua']
-    print(client.recv(1024))
+    send_data1 = [b'1aheuo\r\n', b'2ashxao\r\n', b'3bhaua\r\n']
+    print(client.getpeername())
     for data in send_data1:
         client.send(data)
-        print(client.recv(1024).decode())
-    client.send(b'exit')
+        print(client.recv(1024))
+    client.send(b'exit\r\n')
     client.close()
     pass
 

studyLib/socket/sockClient.py

@@ -0,0 +1,61 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+import socket, threading, multiprocessing
+from network_setting import *
+from time import ctime
+
+__author__ = 'Mr.Huo'
+
+TcpSerAddr = (LOCALIP, TCP_PORT_S)
+TcpCliAddr = (LOCALIP, TCP_PORT_C)
+
+
+class MyTcpClient():
+    def __init__(self, client_address, server_address, buff=1024, bind=True):
+        self.client_address = client_address
+        self.server_address = server_address
+        self.socket = socket.socket()
+        self.recvdata = None
+        self.buff = buff
+        if bind:
+            try:
+                self.socket.bind(self.client_address)
+            except:
+                self.socket.close()
+                raise
+        try:
+            self.socket.connect(self.server_address)
+        except:
+            self.socket.close()
+            raise
+
+    def handle(self, send_data):
+        pass
+
+    def client_actions(self, send_data):
+        self.socket.send(send_data.encode('utf-8') + b'\r\n')
+        try:
+            self.recvdata = self.socket.recv(self.buff)
+        except Exception as err:
+            print(err)
+            self.shutdown()
+        finally:
+            print('Server Send: %s' % (self.recvdata.decode('utf-8')))
+
+    def shutdown(self):
+        self.socket.close()
+
+
+def main():
+    tcpClie = MyTcpClient(TcpCliAddr, TcpSerAddr)
+    while True:
+        send_data = input('input the send data to server:')
+        tcpClie.client_actions(send_data)
+        if b'ByeBye' in tcpClie.recvdata or not tcpClie.recvdata:
+            break
+    tcpClie.shutdown()
+
+
+if __name__ == '__main__':
+    main()

studyLib/socket/sockServer.py

@@ -0,0 +1,33 @@
+#!/usr/bin/env python3
+# -*- coding: utf-8 -*-
+
+from network_setting import *
+from socketserver import (TCPServer as TCP, StreamRequestHandler as SRH)
+from time import ctime
+
+__author__ = 'Mr.Huo'
+
+TcpSerAddr = (LOCALIP, TCP_PORT_S)
+
+
+class MyRequestHandler(SRH):
+    def handle(self):
+        print('...connect from:', self.client_address)
+        while True:
+            data = self.rfile.readline()
+            print(type(data))
+            if not data or b'ByeBye' in data:
+                self.wfile.write(('[%s] %s' % (ctime(), b'ByeBye'.decode("UTF-8"))).encode("UTF-8"))
+                break
+            print(data)
+            self.wfile.write(('[%s] %s' % (ctime(), data.decode("UTF-8"))).encode("UTF-8"))
+
+
+def main():
+    tcpServ = TCP(TcpSerAddr, MyRequestHandler)
+    print('waiting for connection...')
+    tcpServ.serve_forever()
+
+
+if __name__ == '__main__':
+    main()