5-4日 socket套接字

Posted 2020-11-02 没有最晚的时刻，当你发现时

1,socket定义

Socket是应用层与TCP/IP协议族通信的中间软件抽象层，它是一组接口。在设计模式中，Socket其实就是一个门面模式，它把复杂的TCP/IP协议族隐藏在Socket接口后面，对用户来说，一组简单的接口就是全部，让Socket去组织数据，以符合指定的协议。

2，基于tcp协议的socket

tcp是基于链接的，必须先启动服务端，然后再启动客户端去链接服务端。

server端

import socket
sk = socket.socket()#创建服务端套接字

sk.bind((‘127.0.0.1‘,9090))#把地址绑定到套接字
sk.listen()#监听链接

conn,addr = sk.accept()#接受客户端链接
print(addr)#打印客户端地址
conn.send(‘你好‘.encode(‘utf-8‘))#向客户端发送信息
ret = conn.recv(1024)#接受客户端信息
print(ret.decode(‘utf-8‘))#打印客户端信息

conn.close()#关闭客户端套接字
sk.close()#关闭服务器套接字(可选)

client端

import socket

sk = socket.socket()#创建客户端套接字
sk.connect((‘127.0.0.1‘,9090))# 尝试连接服务器
ret = sk.recv(1024)#接受服务端信息
print(ret.decode(‘utf-8‘))#打印服务端信息
sk.send(‘你也好‘.encode(‘utf-8‘))# 对话(发送/接收)

sk.close()# 关闭客户套接字

3，基于UDP协议的socket

udp是无链接的，启动服务之后可以直接接受消息，不需要提前建立链接

server端

import socket
sk = socket.socket(type=socket.SOCK_DGRAM)
sk.bind((‘127.0.0.1‘,9090))
while True:
    msg,client_addr = sk.recvfrom(1024)
    print(msg.decode(‘utf-8‘))
    inp = input(‘>>>‘)
    sk.sendto(inp.encode(‘utf-8‘),client_addr)

sk.close()

client端

import socket

sk= socket.socket(type=socket.SOCK_DGRAM)
while True:
    inp = input(‘>>>‘)
    sk.sendto(inp.encode(‘utf-8‘),(‘127.0.0.1‘,9090))
    msg,addr = sk.recvfrom(1024)
    print(msg.decode(‘utf-8‘))

sk.close()

 qq轻聊版

server端

import socket
lst = {‘egon‘:‘\031[1;31m‘,‘yuan‘:‘031[1;31m‘}
sk = socket.socket(type=socket.SOCK_DGRAM)
sk.bind((‘127.0.0.1‘,9090))
while True:
    msg,client_addr = sk.recvfrom(1024)
    name,mesg = msg.decode(‘utf-8‘).split(‘:‘)
    color = lst.get(name.strip(),‘‘)
    print(‘%s%s\033[0m‘%(color,msg.decode(‘utf-8‘)))
    inp = input(‘>>>‘)
    sk.sendto(inp.encode(‘utf-8‘),client_addr)
sk.close()

client端

import socket
sk = socket.socket(type=socket.SOCK_DGRAM)

name = input(‘name‘)
while True:
    inp = input(‘>>>‘)
    sk.sendto((‘%s:%s‘%(name,inp)).encode(‘utf-8‘),(‘127.0.0.1‘,9090))
    msg,addr = sk.recvfrom(1024)
    print(msg.decode(‘utf-8‘))
sk.close()

时间服务器

server端

import time
import socket
sk = socket.socket(type = socket.SOCK_DGRAM)
sk.bind((‘127.0.0.1‘,9090))
while True:
    msg,addr = sk.recvfrom(1024)
    sk.sendto(time.strftime(msg.decode(‘utf-8‘)).encode(‘utf-8‘),addr)

sk.close()

client端

import time
import socket

sk = socket.socket(type=socket.SOCK_DGRAM)
while True:
    sk.sendto(‘%Y/%m/%d %H:%M:%S‘.encode(‘utf-8‘),(‘127.0.0.1‘,9090))
    ret,addr = sk.recvfrom(1024)
    print(ret.decode(‘utf-8‘))
    time.sleep(2)

sk.close()

 

socket参数的详解

socket.socket(family=AF_INET,type=SOCK_STREAM,proto=0,fileno=None)

创建socket对象的参数说明：

family	地址系列应为AF_INET(默认值),AF_INET6,AF_UNIX,AF_CAN或AF_RDS。 （AF_UNIX 域实际上是使用本地 socket 文件来通信）
type	套接字类型应为SOCK_STREAM(默认值),SOCK_DGRAM,SOCK_RAW或其他SOCK_常量之一。 SOCK_STREAM 是基于TCP的，有保障的（即能保证数据正确传送到对方）面向连接的SOCKET，多用于资料传送。 SOCK_DGRAM 是基于UDP的，无保障的面向消息的socket，多用于在网络上发广播信息。
proto	协议号通常为零,可以省略,或者在地址族为AF_CAN的情况下,协议应为CAN_RAW或CAN_BCM之一。
fileno	如果指定了fileno,则其他参数将被忽略,导致带有指定文件描述符的套接字返回。 与socket.fromfd()不同,fileno将返回相同的套接字,而不是重复的。 这可能有助于使用socket.close()关闭一个独立的插座。