Socket学习笔记(一)

# 服务端
from socket import *

ip_port = (‘localhost‘, 8081)
BUFSIZE = 1024
s=socket(AF_INET,SOCK_STREAM) 
s.bind(ip_port) 
s.listen(5)     

while True:                       
    conn, addr = s.accept()            
    while True:                         
        msg = conn.recv(BUFSIZE)            
        if len(msg) == 0: break        #如果不加,那么正在链接的客户端突然断开,recv便不再阻塞,死循环发生
        print(msg)
        conn.send(msg.upper())         
    conn.close()                    
s.close()


# 客户端
from socket import *
ip_port = (‘127.0.0.1‘, 8081)
BUFSIZE = 1024
s = socket(AF_INET, SOCK_STREAM)
s.connect_ex(ip_port)      
while True:                            
    msg = input(‘>>: ‘).strip()
    if len(msg) == 0:continue
    s.send(msg.encode(‘utf-8‘))      
    feedback = s.recv(BUFSIZE)                      
    print(feedback.decode(‘utf-8‘))
s.close()  

#加入一条socket配置，重用ip和端口

phone=socket(AF_INET,SOCK_STREAM)
phone.setsockopt(SOL_SOCKET,SO_REUSEADDR,1) #就是它，在bind前加
phone.bind((‘127.0.0.1‘,8080))

# 服务端
from socket import *

ip_port = (‘localhost‘,9000)
BUF = 1024
udp_server = socket(AF_INET,SOCK_DGRAM)

udp_server.bind(ip_port)

while True:
    msg,addr = udp_server.recvfrom(BUF)
    print(msg,addr)

    udp_server.sendto(msg.upper(),addr)

# 客户端
from socket import *

ip_port = (‘localhost‘,9000)
BUF = 1024

udp_client = socket(AF_INET,SOCK_DGRAM)

while True:
    msg = input(">>>>:").strip()
    if not msg:continue

    udp_client.sendto(msg.encode(‘utf-8‘), ip_port)

    back_msg,addr = udp_client.recvfrom(BUF)
    print(back_msg.decode(‘utf-8‘),addr)

# 服务端
import socket
ip_port=(‘127.0.0.1‘,8081)
udp_server_sock=socket.socket(socket.AF_INET,socket.SOCK_DGRAM) 
udp_server_sock.bind(ip_port)

while True:
    qq_msg,addr=udp_server_sock.recvfrom(1024)
    print(‘来自[%s:%s]的一条消息:\033[1;44m%s\033[0m‘ %(addr[0],addr[1],qq_msg.decode(‘utf-8‘)))
    back_msg=input(‘回复消息: ‘).strip()
    udp_server_sock.sendto(back_msg.encode(‘utf-8‘),addr)

# 客户端
import socket
BUFSIZE=1024
udp_client_socket=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)

qq_name_dic={
    ‘悟空‘:(‘127.0.0.1‘,8081),
    ‘八戒‘:(‘127.0.0.1‘,8081),
    ‘沙和尚‘:(‘127.0.0.1‘,8081),
    ‘小白龙‘:(‘127.0.0.1‘,8081),
}


while True:
    qq_name=input(‘请选择聊天对象: ‘).strip()
    while True:
        msg=input(‘请输入消息,回车发送: ‘).strip()
        if msg == ‘quit‘:break
        if not msg or not qq_name or qq_name not in qq_name_dic:continue
        udp_client_socket.sendto(msg.encode(‘utf-8‘),qq_name_dic[qq_name])

        back_msg,addr=udp_client_socket.recvfrom(BUFSIZE)
        print(‘来自[%s:%s]的一条消息:\033[1;44m%s\033[0m‘ %(addr[0],addr[1],back_msg.decode(‘utf-8‘)))

udp_client_socket.close()

tcp协议：

（1）如果收消息缓冲区里的数据为空，那么recv就会阻塞（阻塞很简单，就是一直在等着收）

（2）只不过tcp协议的客户端send一个空数据就是真的空数据，客户端即使有无穷个send空，也跟没有一个样。

（3）tcp基于链接通信

    基于链接，则需要listen（backlog），指定半连接池的大小
    基于链接，必须先运行的服务端，然后客户端发起链接请求
    对于mac系统：如果一端断开了链接，那另外一端的链接也跟着完蛋recv将不会阻塞，收到的是空(解决方法是：服务端在收消息后加上if判断，空消息就break掉通信循环)
    对于windows/linux系统：如果一端断开了链接，那另外一端的链接也跟着完蛋recv将不会阻塞，收到的是空(解决方法是：服务端通信循环内加异常处理，捕捉到异常后就break掉通讯循环)

udp协议

（1）如果如果收消息缓冲区里的数据为“空”，recvfrom也会阻塞

（2）只不过udp协议的客户端sendinto一个空数据并不是真的空数据（包含：空数据+地址信息，得到的报仍然不会为空），所以客户端只要有一个sendinto（不管是否发送空数据，都不是真的空数据），服务端就可以recvfrom到数据。

（3）udp无链接

    无链接，因而无需listen（backlog），更加没有什么连接池之说了
    无链接，udp的sendinto不用管是否有一个正在运行的服务端，可以己端一个劲的发消息，只不过数据丢失
    recvfrom收的数据小于sendinto发送的数据时，在mac和linux系统上数据直接丢失，在windows系统上发送的比接收的大直接报错
    只有sendinto发送数据没有recvfrom收数据，数据丢失