1 #!/usr/bin/python 2 #coding=utf-8 3 #server 4 import socket 5 import sys 6 import os 7 8 server_address = ‘./test‘ 9 10 #首先确保这个文件不能存在,只是用于本地套接字的通信,如果已经存在则不可以了 11 try: 12 os.unlink(server_address) # 用于删除一个文件 13 except OSError: 14 if os.path.exists(server_address): 15 raise 16 17 sock = socket.socket(socket.AF_UNIX,socket.SOCK_STREAM) 18 19 print >>sys.stderr,‘starting up on %s‘%server_address 20 sock.bind(server_address) 21 sock.listen(5) 22 23 while True: 24 print >>sys.stderr,‘waiting for a connection‘ 25 connection,client_address = sock.accept() 26 try: 27 print >>sys.stderr,‘connection from‘,client_address 28 while True: 29 data = connection.recv(16) 30 print >>sys.stderr,‘received "%s"‘%data 31 if data: 32 print >>sys.stderr,‘sending data back to the client‘ 33 connection.sendall(data) 34 else: 35 print >>sys.stderr,‘no data from‘,client_address 36 break 37 finally: 38 connection.close()
1 #!/usr/bin/python 2 #coding=utf-8 3 #client 4 import socket 5 import sys 6 7 sock = socket.socket(socket.AF_UNIX,socket.SOCK_STREAM) 8 server_address = ‘./test‘ #本地套接字通讯是设置的不是IP而是一个文件 9 10 print >>sys.stderr,‘connection to %s‘%server_address 11 12 try: 13 sock.connect(server_address) 14 except socket.error,msg: 15 print >>sys.stderr,msg 16 sys.exit(1) 17 18 try: 19 message = ‘This is the message.It will be repeated‘ 20 print >>sys.stderr,‘sending "%s"‘%message 21 sock.sendall(message) 22 23 amount_received = 0 24 amount_expected = len(message) 25 26 while amount_received < amount_expected: 27 data = sock.recv(16) 28 amount_received += len(data) 29 print >>sys.stderr,‘received "%s"‘%data 30 finally: 31 print >>sys.stderr,‘closing socket‘ 32 sock.close()
时间: 2024-10-10 17:32:53