Shulou(Shulou.com)06/03 Report--

First of all, understand how socket works, client-server mode

1. Socket client:

2. Socket type

3. Socket data flow

4. Experiment

(1) write a client

Server starts listening on ip and port

AdmindeMacBook-Air-62:~ admin$ nc-l 1234

The client connects to the server, sends data, and shuts down socket

Add a socket_client.py and line to the pycharm:

Import socketHOST = '127.0.0.1'PORT = 1234s = socket.socket (socket.AF_INET, socket.SOCK_STREAM) s.connect ((HOST,PORT)) s.sendall (' hello world') s.close ()

Server exits socket

AdmindeMacBook-Air-62:~ admin$ nc-l 1234hello worldadmindeMacBook-Air-62:~ admin$

The client sends 10 times

Socket_client10.py

#-*-coding: UTF-8-*-# coding=utf-8import socketimport timeHOST = '127.0.0.1'PORT = 1234s = socket.socket (socket.AF_INET,socket.SOCK_STREAM) # meta-ancestor (network socket,tcp) s.connect ((HOST,PORT)) for i in range (10): s.sendall ('% s hello, world\ n'% I) time.sleep (1) s.close ()

Server print 10 times to exit

AdmindeMacBook-Air-62:~ admin$ nc-l 12340 hello, world1 hello, world2 hello, world3 hello, world4 hello, world5 hello, world6 hello, world7 hello, world8 hello, world9 hello, worldadmindeMacBook-Air-62:~ admin$

(2) write a server

Socket_server01.py

# coding=UTF-8import socketimport timeHOST =''# means listening 0.0.0.0PORT = 1234s = socket.socket (socket.AF_INET, socket.SOCK_STREAM) # network, tcps.bind ((HOST,PORT)) s.listen (1) # accept one at a time, write 2 also accept one connect at a time, address = s.accept () # accept the client's request A link handle connect+ address print 'connent',connectprint' Connected by', addresswhile 1: data = connect.recv (1024) if not data: break connect.sendall (data.upper ()) connect.close () admindeMacBook-Air-62:host_performance-monitor admin$ python socket_server01.py is returned

Start the program and view the port

AdmindeMacBook-Air-62:~ admin$ netstat-an | grep 1234tcp4 0 0 * .1234 *. * LISTEN

Client:

Socket-client for server.py

#-*-coding: UTF-8-*-# coding=utf-8import socketimport timeHOST = '127.0.0.1'PORT = 1234s = socket.socket (socket.AF_INET,socket.SOCK_STREAM) # Network socket Tcps.connect ((HOST,PORT)) s.sendall ('hello, world') # client sends 1024 bytes data = s.recv (1024) # accepts data sent from server s.close () print' Received', repr (data) # data print data sent by print server

The line of the client sends hello world and accepts HELLO WORLD

Python socket-client for server.pyReceived 'HELLO, WORLD'HELLO, WORLDadmindeMacBook-Air-62:host_performance-monitor admin$ python socket_server01.pyconnent Connected by (' 127.0.0.1, 63878)

Now let the client keep sending and the server receiving data all the time. One end closes the socket connection, and the other automatically closes the connection.

The server side code is basically the same.

Socket_server01.py

# coding=UTF-8import socketimport timeHOST =''# means listening 0.0.0.0PORT = 1234s = socket.socket (socket.AF_INET, socket.SOCK_STREAM) # network, tcps.bind ((HOST,PORT)) s.listen (1) # accept one at a time, write 2 also accept one connect at a time, address = s.accept () # accept the client's request Return a link handle connect+ address print 'connent',connectprint' Connected by', addresswhile 1: data = connect.recv (1024) print data if not data: break connect.sendall (data.upper ()) connect.close ()

Start server and view the port:

AdmindeMacBook-Air-62:host_performance-monitor admin$ python socket_server01.pyadmindeMacBook-Air-62:~ admin$ netstat-an | grep 1234tcp4 0 0 * .1234 *. * LISTEN

Client side code:

Vim clinet_not_stop.py#-*-coding: UTF-8-*-# coding=utf-8import socketimport timeHOST = '127.0.0.1'PORT = 1234s = socket.socket (socket.AF_INET,socket.SOCK_STREAM) # Network socket Tcps.connect ((HOST,PORT)) while True:s.sendall ('hello, world') # client sends 1024 bytes data = s.recv (1024) # accept data sent from server print datatime.sleep (1) s.close () admindeMacBook-Air-62:host_performance-monitor admin$ python python clinet_not_stop.py client accept server uppercase return HELLO, WORLDHELLO, WORLD

At the same time, you can see the sent data from client on the server side, all lowercase hello world

AdmindeMacBook-Air-62:host_performance-monitor admin$ python socket_server01.pyconnent Connected by ('127.0.0.1, 64589) hello, worldhello, world

Press ctrl+c to terminate the transmission

For the new requirement, the client sends the command, the server receives the command and the line, and returns the result, and the client uses exit or quit to exit.

Server:socket_server_command.py

#-*-coding: UTF-8-*-# coding=UTF-8import socketfrom subprocess import Popen,PIPEHOST =''# means listening 0.0.0.0PORT = 1234s = socket.socket (socket.AF_INET, socket.SOCK_STREAM) # network, tcps.bind ((HOST,PORT)) s.listen (1) # accept one at a time, write 2 also accept one connect at a time, address = s.accept () # accept the client's request Return a link handle connect+ address print 'connent',connectprint' Connected by', addresswhile 1: cmd = connect.recv (1024) p = Popen (cmd, stdout=PIPE, stderr=PIPE, shell=True) stdout= p.stdout.read () stderr= p.stderr.read () if stdout: connect.sendall (stdout) if stderr: connect.sendall (stderr) if not cmd: breakconnect.close ()

Client:socket_clinet_command.py

#-*-coding: UTF-8-*-# coding=utf-8import socketimport timeimport tab # reference: http://daixuan.blog.51cto.com/5426657/1934112HOST = '127.0.0.1'PORT = 1234s = socket.socket (socket.AF_INET,socket.SOCK_STREAM) # Network socket,tcps.connect ((HOST,PORT)) while True: cmd = raw_input ("Please input cmd:"). Strip () # remove the empty string command and make a judgment Non-empty resend if cmd.lower () = = 'exit' or cmd.lower () = =' quit': break if cmd: s.sendall (cmd) # the client sends the command data = s.recv (1024) # accept the data sent by the server print datas.close ()

Server startup service: (connection handle will be displayed if there is a client connection)

AdmindeMacBook-Air-62:host_performance-monitor admin$ python socket_server_command.pyconnent Connected by ('127.0.0.1 percent, 65512)

The client starts and executes the command:

Saturday, June 10, admindeMacBook-Air-62:host_performance-monitor admin$ python socket_clinet_command.pyPlease input cmd:date2017, 18:34:21 CSTPlease input cmd:pwd/Users/admin/Desktop/project/host_performance-monitorPlease input cmd:exit

5. Realize the FTP download function:

1 、 get source dest

2. Duplicate files and add .new

3. Print out whether the file name in get is / tmp/hosts or / tmp/hosts.new.

Server: socket_server_ftp.py

#-*-coding: UTF-8-*-# coding=UTF-8import socketfrom subprocess import Popen,PIPEHOST =''# means listening 0.0.0.0PORT = 1234s = socket.socket (socket.AF_INET, socket.SOCK_STREAM) # network, tcps.bind ((HOST,PORT)) s.listen (1) # accept one at a time, write 2 also accept one connect at a time, address = s.accept () # accept the client's request Return a join handle connect+ address print 'connent',connectprint' Connected by', addresswhile 1: cmd = connect.recv (1024) cmd_list = cmd.split () if cmd_list [0] = 'get': # if it is a get method, read data with open (cmd_list [1]) as fd: while True: # read 1024 bytes in a loop Then return a number data = fd.read (1024) connect.sendall (data) if not data: # after reading the data, jump out of the while loop connect.sendall ('EOF') break if not cmd: breakconnect.close ()

Client: socket_clinet_ftp.py

#-*-coding: UTF-8-*-# coding=utf-8import socketimport timeimport tab # reference: http://daixuan.blog.51cto.com/5426657/1934112import osHOST = '127.0.0.1'PORT = 1234s = socket.socket (socket.AF_INET,socket.SOCK_STREAM) # Network socket,tcps.connect ((HOST,PORT)) while True: cmd = raw_input ("Please input cmd:"). Strip () # remove the empty string command and make a judgment Non-empty resend if cmd.lower () = = 'exit' or cmd.lower () = =' quit': break cmd_list = cmd.split () if len (cmd_list)! = 3: print "Ex: get file1 file2" continue else: s.sendall (cmd) # client sends command if not os.path.exists (cmd_list [2]): dst_file = cmd_ List [2] else: dst_file = cmd_list [2] + '.new 'n = 1 # define a variable The first time to open the file is wb mode, the second time to open the file is a (append) way to open. While True: data_rev = s.recv (1024) # accepts the data sent by the server, but after the server sends the data, the client is still waiting and will get stuck. Use EOF For break if data_rev.endswith ('EOF'): data = data_rev [:-3] else: data = data_rev if n = = 1: with open (dst_file,' wb') as fd: fd.write (data) else: with open (dst_file 'a') as fd: fd.write (data) print data n + = 1 print "destination file is% s"% dst_file if data_rev [- 3:] = = 'EOF': # if the last three characters are EOF Exit ftp breaks.close ()

Start the server:

AdmindeMacBook-Air-62:host_performance-monitor admin$ python socket_server_ftp.pyconnent Connected by ('127.0.0.1 percent, 53858)

Start the client:

AdmindeMacBook-Air-62:host_performance-monitor admin$ python socket_clinet_ftp.pyPlease input cmd:get / etc/hosts / tmp/hostsdestination file is / tmp/hostsPlease input cmd:get / etc/hosts / tmp/hostsdestination file is / tmp/hosts.new

6 、 SocketServer

Socketserver is a class with its own multithreading

Write a hander class that inherits BaseRequestHander and overrides the handle () method

Generate a server object for tcp or udp

Call the handle_request or sever_forver method of the server object

(1) official example of socket server, a server-side kernel client in a script

Https://docs.python.org/2.7/library/socketserver.html?highlight=socketserver

Vim socket-threading-thread.pyimport socketimport threadingimport SocketServerclass ThreadedTCPRequestHandler (SocketServer.BaseRequestHandler): def handle (self): data = self.request.recv (1024) cur_thread = threading.current_thread () response = "% s% s"% (cur_thread.name, data) self.request.sendall (response) class ThreadedTCPServer (SocketServer.ThreadingMixIn, SocketServer.TCPServer): passdef client (ip, port, message): sock = socket.socket (socket.AF_INET Socket.SOCK_STREAM) sock.connect ((ip, port)) try: sock.sendall (message) response = sock.recv (1024) print response finally: sock.close () if _ _ name__ = = "_ main__": # Port 0 means to select an arbitrary unused port HOST, PORT = "localhost", 0 server = ThreadedTCPServer ((HOST, PORT), ThreadedTCPRequestHandler) ip Port = server.server_address # Start a thread with the server-- that thread will then start one # more thread for each request server_thread = threading.Thread (target=server.serve_forever) # Exit the server thread when the main thread terminates server_thread.daemon = True server_thread.start () print "Server loop running in thread:", server_thread.name client (ip, port, "Hello World 1") client (ip, port, "Hello World 2") client (ip, port "Hello World 3") server.shutdown () server.server_close () admindeMacBook-Air-62:host_performance-monitor admin$ python socket-threading-thread.pyServer loop running in thread: Thread-1Thread-2 Hello World 1Thread-3 Hello World 2Thread-4 Hello World 3

(2) multiple clients connect to a server at the same time

The server does not exit

Any client will have the result returned.

Server code:

Vim socket_clinet_command.py#-*-coding: UTF-8-*-# coding=UTF-8import socketimport threadingimport SocketServerclass ThreadedTCPRequestHandler (SocketServer.BaseRequestHandler): def handle (self): while True: self.data = self.request.recv (1024). Strip () print self.client_address [0] print self.data self.request.sendall (self.data.upper ()) If not self.data: breakclass ThreadedTCPServer (SocketServer.ThreadingMixIn SocketServer.TCPServer): passif _ _ name__ = = "_ main__": # Port 0 means to select an arbitrary unused port # HOST, PORT = "localhost", 9999 HOST = 'localhost' PORT = 9999 server = ThreadedTCPServer ((HOST, PORT)) ThreadedTCPRequestHandler) # Start a thread with the server-- that thread will then start one # more thread for each request server_thread = threading.Thread (target=server.serve_forever) # Exit the server thread when the main thread terminates server_thread.daemon = True server_thread.start () print "Server loop running in thread:", server_thread.name # # main processes do not exit server.serve_forever ()

Client code:

Socketserver_clinet.py#-*-coding: UTF-8-*-# coding=utf-8import socketimport timeimport tab # reference: http://daixuan.blog.51cto.com/5426657/1934112import osHOST = 'localhost'PORT = 9999s = socket.socket (socket.AF_INET,socket.SOCK_STREAM) s.connect ((HOST,PORT)) while True: s.sendall (' hello, world') data = s.recv (1024) print data time.sleep (1) s.close ()

Start the server

Server loop running in thread: Thread-1127.0.0.1hello, world127.0.0.1hello, world

Start two clients respectively:

The returned results are all uppercase helloworld and do not affect each other.

HELLO, WORLDHELLO, WORLD

(3) use threading multithreading of socketserver to realize ftp function (multi-client)

Server-side code:

#-*-coding: UTF-8-*-# coding=UTF-8import socketimport threadingimport SocketServerclass ThreadedTCPRequestHandler (SocketServer.BaseRequestHandler): def handle (self): while True: self.cmd = self.request.recv (1024). Strip () self.cmd_list = self.cmd.split () if self.cmd_list [0] = 'get': # if it is a get method Read data with open (self.cmd_list [1]) as fd: while True: # cycle to read 1024 bytes, and then return a number self.data = fd.read (1024) self.request.sendall (self.data) if not self.data: # data has been read Jump out of the while loop self.request.sendall ('EOF') break if not self.cmd: breakclass ThreadedTCPServer (SocketServer.ThreadingMixIn, SocketServer.TCPServer): passif _ _ name__ = = "_ main__": # Port 0 means to select an arbitrary unused port # HOST, PORT = "localhost" 9999 HOST =''PORT = 12345 server = ThreadedTCPServer ((HOST, PORT), ThreadedTCPRequestHandler) # Start a thread with the server-- that thread will then start one # more thread for each request server_thread = threading.Thread (target=server.serve_forever) # Exit the server thread when the main thread terminates server_thread.daemon = True server_thread.start () print "Server loop running in thread:", server_thread.name # # main processes do not exit server.serve_forever ()

Start the server listening port:

/ System/Library/Frameworks/Python.framework/Versions/2.7/bin/python2.7 / Users/admin/Desktop/project/host_performance-monitor/socket-threading-thread-server-ftp.pyServer loop running in thread: Thread-1

Client code:

Socket_clinet_ftp.py

#-*-coding: UTF-8-*-# coding=utf-8import socketimport timeimport tab # reference: http://daixuan.blog.51cto.com/5426657/1934112import osHOST = '127.0.0.1'PORT = 12345s = socket.socket (socket.AF_INET,socket.SOCK_STREAM) # Network socket,tcps.connect ((HOST,PORT)) while True: cmd = raw_input ("Please input cmd:"). Strip () # remove the empty string command and make a judgment Non-empty re-send if cmd.lower () = 'exit' or cmd.lower () = =' quit': break cmd_list = cmd.split () if len (cmd_list)! = 3: print "Ex: get file1 file2" continue else: s.sendall (cmd) # client sends command if not os.path.exists (cmd_list [2]): Dst_file = cmd_list [2] else: dst_file = cmd_list [2] + '.new 'n = 1 # define a variable The first time to open the file is wb mode, the second time to open the file is a (append) way to open. While True: data_rev = s.recv (1024) # accepts the data sent by the server, but after the server sends the data, the client is still waiting and will get stuck. Use EOF For break if data_rev.endswith ('EOF'): data = data_rev [:-3] else: data = data_rev if n = = 1: with open (dst_file,' wb') as fd: fd.write (data) else: with open (dst_file 'a') as fd: fd.write (data) print data n + = 1 print "destination file is% s"% dst_file if data_rev [- 3:] = = 'EOF': # if the last three characters are EOF Exit ftp breaks.close ()

If you start two clients separately, you can use the get method at the same time, and disconnecting one of the clients has no effect on the server.

Client 1:/System/Library/Frameworks/Python.framework/Versions/2.7/bin/python2.7 / Users/admin/Desktop/project/host_performance-monitor/socket_clinet_ftp.pyPlease input cmd:lsEx: get file1 file2Please input cmd:get / tmp/1.txt / tmp/2.txtdestination file is / tmp/2.txtPlease input cmd: client 2:/System/Library/Frameworks/Python.framework/Versions/2.7/bin/python2.7 / Users/admin/Desktop/project/ Host_performance-monitor/socket_clinet_ftp.pyPlease input cmd:get / tmp/1.txt / tmp/2.txtdestination file is / tmp/2.txt.newdestination file is / tmp/2.txt.newPlease input cmd:Ex: get file1 file2Please input cmd:get / tmp/1.txt / tmp/2.txtdestination file is / tmp/2.txt.newdestination file is / tmp/2.txt.newPlease input cmd:

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.