python_socket

Socket

• socket模块是针对 服务器端 和 客户端Socket 进行【打开】【读写】【关闭】。

 

#!/usr/bin/env python
#coding=utf-8
__author__ = 'yinjia'


import socket

ip_port = ('127.0.0.1',9999)

sk = socket.socket()
sk.bind(ip_port)
sk.listen()

while True:
    print("等待连接......")
    con,addr = sk.accept()

    client_data = str(con.recv(1024),encoding='utf-8')
    print(client_data)
    con.sendall(bytes("不想回答！",encoding='utf-8'))

    con.close()

#!/usr/bin/env python
#coding=utf-8
__author__ = 'yinjia'


import socket

ip_port = ('127.0.0.1',9999)

sk = socket.socket()
sk.connect(ip_port)

sk.sendall(bytes("您好，请回答问题！",encoding='utf-8'))

server_reply = sk.recv(1024)
print(str(server_reply,encoding='utf-8'))

sk.close()

• sk = socket.socket(socket.AF_INET,socket.SOCK_STREAM,0)

参数一：地址簇

　　socket.AF_INET IPv4（默认）
　　socket.AF_INET6 IPv6

　　socket.AF_UNIX 只能够用于单一的Unix系统进程间通信

参数二：类型

　　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 可靠的连续数据包服务

参数三：协议

　　0　　（默认）与特定的地址家族相关的协议,如果是 0 ，则系统就会根据地址格式和套接类别,自动选择一个合适的协议

SocketServer

• SocketServer内部使用 IO多路复用 以及 “多线程” 和 “多进程” ，从而实现并发处理多个客户端请求的Socket服务端。即：每个客户端请求连接到服务器时，Socket服务端都会在服务器是创建一个“线程”或者“进程” 专门负责处理当前客户端的所有请求。

 

ThreadingTCPServer实现的Soket服务器内部会为每个client创建一个 “线程”，该线程用来和客户端进行交互。

#!/usr/bin/env python
#coding=utf-8
__author__ = 'yinjia'

import socketserver

class MyServer(socketserver.BaseRequestHandler):

    def handle(self):
        conn = self.request
        teacher = "老师说："


        conn.sendall(bytes('欢迎使用选课系统！', encoding='utf-8'))
        #连接客户端地址信息
        while True:
            print("server waiting...")
            ret_bytes = conn.recv(1024)
            ret_str = str(ret_bytes,encoding='utf-8')
            if ret_str.lower() == 'q':
                break
            conn.sendall(bytes(teacher + '好',encoding='utf-8'))

if __name__ == '__main__':
    server = socketserver.ThreadingTCPServer(('127.0.0.1',9999),MyServer)
    server.serve_forever()

#!/usr/bin/env python
#coding=utf-8
__author__ = 'yinjia'


import socket
ip_port = ('127.0.0.1',9999)


sk = socket.socket()
sk.connect(ip_port)

ret_bytes = sk.recv(1024)
ret_str = str(ret_bytes,encoding='utf-8')
print(ret_str)

while True:
    inp = str(input("发送："))
    if inp.lower() == 'q':
        sk.sendall(bytes(inp,encoding='utf-8'))
        break
    else:
        sk.sendall(bytes(inp,encoding='utf-8'))
        ret = str(sk.recv(1024),encoding='utf-8')
        print(ret)
sk.close()

ForkingTCPServer和ThreadingTCPServer的使用和执行流程基本一致，只不过在内部分别为请求者建立 “进程”  和 “线程”。

ForkingTCPServer只是将 ThreadingTCPServer 实例中的代码如下：

server = socketserver.ThreadingTCPServer(('127.0.0.1',9999),MyServer)
变更为：
server = socketserver.ForkingTCPServer(('127.0.0.1',9999),MyServer)

 其实本质上就是在服务器端为每一个客户端创建一个进程，当前新创建的进程用来处理对应客户端的请求，所以，可以支持同时n个客户端链接（长连接）。