form socket import *

tcpsock = socket(AF_INTE, SOCK_STREMA)

 服务器：

#!/use/bin/env python

from socket import *
import time

HOST = ‘‘
PORT = 21567
BUFSIZE = 1024
ADDR = (HOST, PORT)

tcpSerSock = socket(AF_INET)
tcpSerSock.bind(ADDR)
tcpSerSock.listen(5)

while True:
   print ‘waiting to connection...‘
   tcpCliSock, addr = tcpSerSock.accept()
   print ‘....connected from:‘,addr

   while True:
      data = tcpCliSock.recv(BUFSIZE)
      if not data:
         break
      lotime = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
      tcpCliSock.send(‘[%s] %s‘ % (lotime, data))

   tcpCliSock.close()
tcpSerSock.close()　

#!/use/bin/env python

from socket import *

HOST = ‘localhost‘
PORT = 21567
BUFSIZE = 1024
ADDR = (HOST, PORT)

tcpCliSock = socket(AF_INET)
tcpCliSock.connect(ADDR)

while True:
    data = raw_input(‘> ‘)
    if not data:
        break
    tcpCliSock.send(data)
    data = tcpCliSock.recv(BUFSIZE)
    if not data:
        break
    print data

tcpCliSock.close()

#!/use/bin/env python

from socket import *
import time

HOST = ‘‘
PORT = 21567
BUFSIZE = 1024
ADDR = (HOST, PORT)

udpSerSock = socket(AF_INET, SOCK_DGRAM)
udpSerSock.bind(ADDR)

while True:
    print(‘waittinng for meaasge...‘)
    data, addr = udpSerSock.recvfrom(BUFSIZE)
    lotime = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
    udpSerSock.sendto(b‘[%s] %s‘ %(lotime, data), addr)
    print(‘...received from and returned to: ‘, addr)
    
udpSerSock.close()

#!/use/bin/env python

from socket import *

HOST = ‘localhost‘
PORT = 21567
BUFSIZE = 1024
ADDR = (HOST, PORT)

udpCliSock = socket(AF_INET, SOCK_DGRAM)

while True:
    data = raw_input(‘> ‘)
    if not data:
        break
    udpCliSock.sendto(data, ADDR)
    data, addr = udpCliSock.recvfrom(BUFSIZE)
    if not data:
        break
    print(data.decode(‘utf-8‘))
udpCliSock.close()

                                                   socket 模块属性

 SocketServer 模块类

#!/use/bin/env python
# -*- coding: utf-8 -*-

from SocketServer import (TCPServer as TCP, StreamRequestHandler as SRH)
import time

HOST = ‘‘
PORT = 21567
BUFSIZE = 1024
ADDR = (HOST, PORT)

#重写SocketServer的子类StreamRequestHandler的handle方法，该方法默认没有任何行为
class MyRequestHandler(SRH):
   def handle(self):
         print ‘...connected from:‘, self.client_address
         lotime = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
         #readline()来获取客户端消息，write()将字符串发回客户端
         self.wfile.write(‘[%s] %s‘ % (lotime, self.rfile.readline()))

#创建TCP服务器，并无限循环的等待客户端请求
tcpServ = TCP(ADDR, MyRequestHandler)
print ‘waiting for conntion....‘
tcpServ.serve_forever()

#!/use/bin/env python
# -*- coding: utf-8 -*-

from socket import *

HOST = ‘localhost‘
PORT = 21567
BUFSIZE = 1024
ADDR = (HOST, PORT)

while True:
    tcpCliSock = socket(AF_INET)
    tcpCliSock.connect(ADDR)
    data = raw_input(‘> ‘)
    if not data:
        break
    tcpCliSock.send(‘%s\r\n‘ % data)
    data = tcpCliSock.recv(BUFSIZE)
    if not data:
        break
    print data.strip()
    tcpCliSock.close()

sudo apt-get install python-setuptools
sudo apt-get install python-dev
sudo easy_install twisted　　

# -*- coding: utf-8 -*-

from twisted.internet import protocol, reactor
import time

PORT = 21567

#获得protocol类并为时间戳服务器调用TSServProtocol，然后重写了connetctionMade()和dataReceived()方法
class TSServProtocol(protocol.Protocol):
   #当客户端连接到服务器时就执行connectionMade()
   def connectionMade(self):
        clnt =self.clnt = self.transport.getPeer().host
        print ‘...connected from:‘, clnt
   #当服务器接收到客户端请求时执行dataReceived()
   def dataReceived(self, data):
        lotime = time.strftime("%Y-%m-%d %H:%M:%S", time.localtime())
        self.transport.write(‘[%s] %s‘ % (lotime, data))

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

#!/use/bin/env python
# -*- coding: utf-8 -*-

from twisted.internet import protocol, reactor

HOST = ‘localhost‘
PORT = 21567

class TSClntProtocol(protocol.Protocol):
    def sendData(self):
        data = raw_input(‘> ‘)
        if data:
            print ‘...sending %s...‘ % data
            self.transport.write(data)
        else:
            self.transport.loseConnection()
    
    def connectionMade(self):
        self.sendData()

    def dataReceived(self, data):
        print data
        self.sendData()

class TSClntFactory(protocol.ClientFactory):
    protocol = TSClntProtocol
    clientConnectionLost = clientConnectionFalied = lambda self, connector, reason: reactor.stop()

reactor.connectTCP(HOST, PORT, TSClntFactory())
reactor.run()