Python套接字

socket(socket_family, socket_type, protocol=0)
tcpSock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
ud pSock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

ss = socket() # 创建服务器套接字
ss.bind() # 套接字与地址绑定
ss.listen() # 监听连接
inf_loop: # 服务器无限循环
cs = ss.accept() # 接受客户端连接
comm_loop: # 通信循环
cs.recv()/cs.send() # 对话（接收/发送）
cs.close() # 关闭客户端套接字
ss .close() # 关闭服务器套接字#（可选）

cs = socket() # 创建客户端套接字
cs.connect() # 尝试连接服务器
comm_loop: # 通信循环
cs.send()/cs.recv() # 对话（发送/接收）
cs .close() # 关闭客户端套接字

# 请求处理程序MyRequestHandler，作为SocketServer
# 中StreamRequestHandler 的一个子类，并重写了它的handle()方法，该方法在基类Request 中
# 默认情况下没有任何行为。
# def handle(self):
# pass
# 当接收到一个来自客户端的消息时，它就会调用handle()方法。而StreamRequestHandler
# 类将输入和输出套接字看作类似文件的对象，因此我们将使用readline()来获取客户端消息，
# 并利用write()将字符串发送回客户端。
from socketserver import TCPServer as TCP,StreamRequestHandler as SRH
from time import  ctime
HOST=‘‘
PORT=‘21567‘
ADDR=(HOST,PORT)

class MyRequestHandle(SRH):
    def handle(self):
        print(‘...connected from:{0}‘,self.client_address)
        self.wfile.write(‘[%s]%s‘%(ctime(),self.rfile.readline()))
tcpSever=TCP(ADDR,MyRequestHandle)
print(‘waiting for connection‘)
tcpSever.serve_forever()

from socket import *
HOST=‘localhost‘
PORT=‘21567‘
BUFSIZ=1024
ADDR=(HOST,PORT)


while True:
    tcpClisocket=socket(ADDR,SOCK_STREAM)
    tcpClisocket.connect(ADDR)
    data=input(‘>‘)
    if not data:
        break
        # 因为这里使用的处理程序类对待套
        # 接字通信就像文件一样，所以必须发送行终止符（回车和换行符）
        # 而服务器只是保留并重用这里发送的终止符。当得到从服务器返回的消息时，用strip()
        # 函数对其进行处理并使用由print声明自动提供的换行符。
    tcpClisocket.send(‘%s\r\n‘%data)
    data=tcpClisocket.recv(BUFSIZ)
    if not data:
        break
    print(data.strip())
    tcpClisocket.close()

from twisted.internet import protocol,reactor
from time import ctime
PORT=21567
class TSServProtocal(protocol.Protocol):
    def connectionMade(self):
        clnt=self.clnt=self.transport.getPeer().host
        print(‘...conected from：‘,clnt)
    def dataReceived(self, data):
        self.transport.write(‘[%s]%s‘%(ctime(),data))

factory=protocol.Factory()
factory.protocol=TSServProtocal
print(‘waiting for conneciton‘)
reactor.listenTCP(PORT,factory)
reactor.run()

from twisted.internet import protocol, reactor
HOST=‘localhost‘
PORT=21567
class TSClntProtocal(protocol.Protocol):
    def sendData(self):
        data=input(‘>‘)
        if data:
            print(‘...sending%...‘%data)
        else:
            self.transport.loseConnection()
    def connectionMade(self):
        self.sendData()
    def dataReceived(self, data):
        print(data)
class TSClntFactory(protocol.Factory):
    protocol=TSClntProtocal
    clientConnectionLost=clientConnectionFailed=    lambda self,connector,reason:reactor.stop()
reactor.connectTCP(HOST,PORT,TSClntFactory())
reactor.run()