kution 发表于 2018-8-6 12:08:13

Python-socket总结

  socket是什么
  什么是socket所谓socket通常也称作"套接字",用于描述IP地址和端口,是一个通信链的句柄。
  应用程序通常通过"套接字"向网络发出请求或者应答网络请求。说白了就是一种通信机制。
  列入你和移动客服咨询问题时,会有一个客服为你解决问题一样,就是你和客服间的相互通信
  在socket里就是“发送”和“接收”这两个动作就是socket通信方式
  socket.gethostname()   # 获取主机名
  from socket import *   # 避免 socket.socket()
  s=socket()
  s.bind()         # 绑定地址到套接字
  s.listen()       # 开始TCP监听
  s.accept()       # 被动接受TCP客户端连接,等待连接的到来
  s.connect()      # 主动初始化TCP服务器连接
  s.connect_ex()   # connect()函数的扩展版本,出错时返回出错码,而不是跑出异常
  s.recv()         # 接收TCP数据
  s.send()         # 发送TCP数据
  s.sendall()      # 完整发送TCP数据
  s.recvfrom()   # 接收UDP数据
  s.sendto()       # 发送UDP数据
  s.getpeername()# 连接到当前套接字的远端的地址(TCP连接)
  s.getsockname()# 当前套接字的地址
  s.getsockopt() # 返回指定套接字的参数
  s.setsockopt()   # 设置指定套接字的参数
  s.close()      # 关闭套接字
  s.setblocking()# 设置套接字的阻塞与非阻塞模式
  s.settimeout()   # 设置阻塞套接字操作的超时时间
  s.gettimeout()   # 得到阻塞套接字操作的超时时间
  s.filen0()       # 套接字的文件描述符
  s.makefile()   # 创建一个与该套接字关联的文件对象
  socket.AF_UNIX # 只能够用于单一的Unix系统进程间通信
  socket.AF_INET# 服务器之间网络通信
  socket.AF_INET6 # IPv6
  socket.SOCK_STREAM# 流式socket , for TCP
  socket.SOCK_DGRAM# 数据报式socket , for UDP
  socket.SOCK_RAW      # 原始套接字,普通的套接字无法处理ICMP、IGMP等网络报文,而SOCK_RAW可以;其次,SOCK_RAW也可以处理特殊的IPv4报文;此外,利用原始套接字,可以通过IP_HDRINCL套接字选项由用户构造IP头。
  socket.SOCK_RDM   # 是一种可靠的UDP形式,即保证交付数据报但不保证顺序。SOCK_RAM用来提供对原始协议的低级访问,在需要执行某些特殊操作时使用,如发送ICMP报文。SOCK_RAM通常仅限于高级用户或管理员运行的程序使用。
  socket.SOCK_SEQPACKET # 可靠的连续数据包服务
  基础讲解
  # 创建socket对象
  sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
  # 监听端口
  sock.bind(('127.0.0.1',8001))
  # 开始监听,
  sock.listen(5)
  while True:
  # 阻塞,deng 。。。。
  # 直到有请求连接
  print '....'
  connection, address = sock.accept()
  # connection,代表客户端socket对象,
  # address,客户端IP地址
  #handle_request(connection)
  buf = connection.recv(1024)
  print buf
  connection.send("HTTP/1.1 200 OK\r\n\r\n")
  connection.send("Hello, World")
  connection.close()
  #服务端
  import socket
  HOST=''#空代表0.0.0.0
  PORT= 6666#监听端口
  s= socket.socket(socket.AF_INET,socket.SOCK_STREAM)
  s.bind((HOST,PORT))
  s.listen(1)
  while True:
  conn,addr= s.accept()
  print'Connected by', addr
  whileTrue:
  data = conn.recv(1024) #接收1024字节数据
  if not data: break   #如果收不到客户端数据了(代表客户端断开了),就断开
  conn.sendall(data.upper())    #将收到的数据全变成大写再发给客户端
  conn.close() #关闭此客户端的连接实例
  #客户端
  import socket
  HOST=''
  PORT= 6666#监听端口
  s= socket.socket(socket.AF_INET,socket.SOCK_STREAM)
  s.bind((HOST,PORT))
  s.listen(1)
  while True:
  conn,addr= s.accept()
  print'Connected by', addr
  whileTrue:
  data = conn.recv(1024) #接收1024字节数据
  if not data: break   #如果收不到客户端数据了(代表客户端断开了),就断开
  conn.sendall(data.upper())    #将收到的数据全变成大写再发给客户端
  conn.close() #关闭此客户端的连接实例
  服务端socket在使用bind方法之后调用listen方法去监听一个给定的 地址。然后,客户端socket就可以通过使 用 connect方法(connect方法所使用的地址参数与bind相同)去连接服务端。listen方法 要求一个参数,这个参数就是等待连接队列中所能包含的连接数。
  一旦服务端socket调用了listen方法,就进入了临听状态,然后通 常使用一个无限的循环:1、开始接受客房端的连接,这通过调用accept方法来实现。调用了这个方法后将处于阻塞状态(等待客户端发起连接)直到一个客 户端连接,连接后,accept返回形如(client,address)的一个元组,其中client是一个用于与客户端通信的 socket,address是客户端的形如xxx.xxx.xxx.xxx:xxx的地址;2、然后服务端处理客户端的请求;3、处理完成之后又调用 1。
  #以上例子是单线程的只能一对一的服务,即服务端只能处理一个链接,想要处理多线程怎么办,不用急多线程的Python已给我们写好直接调用就好
  socket服务端
  #用于处理多线程的模块
  import SocketServer
  import os

  >  def handle(self):
  while True:
  self.data=self.request.recv(1024).strip() #接受数据
  if self.data == 'quit' or not self.data:break #如果没有数据或为quit 退出
  cmd_data=os.popen(self.data).read() #将命令结果存为字符串
  if cmd_data == '':cmd_data= self.data + ': Command not found' #如果命令结果为空或命令返回为空
  self.request.sendall(cmd_data) #发送所有的数据
  if __name__ == '__main__':
  HOST,PORT = '127.0.0.1',6666 #绑定端口和ip
  server = SocketServer.ThreadingTCPServer((HOST,PORT),MyTCP) #将写的类加入多线程处理
  server.serve_forever() #循环启动
  socket客户端
  import socket
  HOST='127.0.0.1'
  PORT=6666
  s=socket.socket(socket.AF_INET,socket.SOCK_STREAM) #服务期间的TCP通信
  s.connect((HOST,PORT)) #绑定端口和ip
  while True:
  while True: #如果命令为空继续输入
  cmd=raw_input('CMD:').strip()
  if cmd != '':break
  s.sendall(cmd) #发送所有数据
  data=s.recv(1024).split('\n') #以换行符分割接收的数据
  print 'cmd:'
  for line in data:print line #循环打印数据
  s.close() #关闭套接字
  用SocketServer创建一个服务器需要三步:
  1、通过子类化BaseRequestHandler类和覆盖它的handle()方法来创建一个请求处理器类,用于处理进来
  的请求;
  2、实例化服务类如TCPServer,并传递给它参数:服务器地址和请求处理器类;
  3、调用服务实例对象的handle_request()或serve_forever()方法去处理请求。
页: [1]
查看完整版本: Python-socket总结