Learn_Day18 Socket 1

 1 import socket
 2 ip_port = (‘127.0.0.1‘,9999)
 3 sk = socket.socket(socket.AF_INET,socket.SOCK_DGRAM,0)
 4 sk.bind(ip_port)
 5 
 6 while True:
 7     data = sk.recv(1024)
 8     print data
 9 
10 
11 
12 
13 import socket
14 ip_port = (‘127.0.0.1‘,9999)
15 
16 sk = socket.socket(socket.AF_INET,socket.SOCK_DGRAM,0)
17 while True:
18     inp = raw_input(‘数据：‘).strip()
19     if inp == ‘exit‘:
20         break
21     sk.sendto(inp,ip_port)
22 
23 sk.close()

 1 # c1
 2 import socket
 3 
 4 obj = socket.socket()  # 创建对象
 5 obj.connect((‘127.0.0.1‘, 9999))  # (‘127.0.0.1‘, 9999)要连接的对象,
 6 ret_bytes = obj.recv(1024)  # 最多接收1024字节，阻塞
 7 ret_str = str(ret_bytes, encoding=‘utf-8‘)  # 将字节转换成字符串
 8 print(ret_str, ret_bytes)
 9 
10 while True:
11     inp = input(‘请输入要发送的内容：‘)
12     if inp == ‘q‘:
13         obj.sendall(bytes(inp, encoding=‘utf-8‘))  # 发送数据
14         break
15     else:
16         obj.sendall(bytes(inp, encoding=‘utf-8‘))  # 发送数据
17         ret = str(obj.recv(1024), encoding=‘utf-8‘)
18         print(ret)
19 
20 obj.close()
21 
22 # s1
23 import socket
24 
25 sk = socket.socket()  # 创建对象
26 sk.bind((‘127.0.0.1‘, 9999,))  # 绑定自己的IP和端口
27 sk.listen(5)  # 监听，限制连接人数，表示最多有5个人
28 
29 while True:
30     conn, address = sk.accept()  # 阻塞，conn表示用户与我共同用的线，address表示客户的IP与端口
31     # conn.sendall(‘Welcom!‘)  # 2.7版本
32     conn.sendall(bytes(‘welcom!欢迎！‘, encoding=‘utf-8‘))  # 发送数据
33     while True:
34         ret = str(conn.recv(1024), encoding=‘utf-8‘)  # 接收数据
35         conn.sendall(bytes(ret+‘good‘, encoding=‘utf-8‘))  # 发送数据
36 
37 print(address, conn)

 1 # client
 2 import os
 3 import socket
 4 
 5 obj = socket.socket()  # 创建对象
 6 obj.connect((‘127.0.0.1‘, 9999))  # (‘127.0.0.1‘, 9999)要连接的对象,
 7 
 8 ret_bytes = obj.recv(1024)  # 最多接收1024字节，阻塞
 9 ret_str = str(ret_bytes, encoding=‘utf-8‘)  # 将字节转换成字符串
10 print(ret_str, ret_bytes)
11 
12 # 发送当前文件大小
13 size = os.stat(‘f.jpg‘).st_size
14 obj.sendall(bytes(str(size),encoding=‘utf-8‘))
15 
16 
17 with open(‘f.jpg‘, ‘rb‘) as f:
18     for line in f:
19         obj.sendall(line)
20 
21 obj.close()
22 
23 
24 # server
25 import socket
26 
27 sk = socket.socket()  # 创建对象
28 sk.bind((‘127.0.0.1‘, 9999,))  # 绑定自己的IP和端口
29 sk.listen(5)  # 监听，限制连接人数，表示最多有5个人
30 
31 while True:
32     conn, address = sk.accept()  # 阻塞，conn表示用户与我共同用的线，address表示客户的IP与端口
33     # conn.sendall(‘Welcom!‘)  # 2.7版本
34     conn.sendall(bytes(‘welcom!欢迎！‘, encoding=‘utf-8‘))
35     # 线接收文件大小，再接收文件
36     file_size = str(conn.recv(1024), encoding=‘utf—8‘)
37     print(‘文件大小：‘, file_size)
38     total_size = int(file_size)
39     has_recv = 0
40     f = open(‘new.jpg‘, ‘wb‘)
41     # 接收文件内容，直到获取完毕
42     while True:
43         if total_size == has_recv:
44             break
45         data = conn.recv(1024)
46         f.write(data)
47         has_recv += len(data)
48 
49     f.close()