python模块之socket

43、python模块之socket：

Python在网络通讯方面功能强大，学习一下Socket通讯的基本方式

UDP通讯：

Server:

import socket

port=8081

s=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)

#从指定的端口，从任何发送者，接收UDP数据

s.bind(('',port))

print('正在等待接入...')

while True:

    #接收一个数据

    data,addr=s.recvfrom(1024)

    print('Received:',data,'from',addr)

Client:

import socket

port=8081

host='localhost'

s=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)

s.sendto(b'hello,this is a test info !',(host,port))

很简单。下面是TCP方式：

Server:

#-*- coding: utf-8 -*-from socket import *

from time import ctime

HOST=''

PORT=12345

BUFSIZ=1024

ADDR=(HOST, PORT)

sock=socket(AF_INET, SOCK_STREAM)

sock.bind(ADDR)

sock.listen(5)

while True:

    print('waiting for connection')

    tcpClientSock, addr=sock.accept()

    print('connect from ', addr)

    while True:

        try:

            data=tcpClientSock.recv(BUFSIZ)

        except:

            print(e)

            tcpClientSock.close()

            break

        if not data:

            break

        s='Hi,you send me :[%s] %s' %(ctime(), data.decode('utf8'))

        tcpClientSock.send(s.encode('utf8'))

        print([ctime()], ':', data.decode('utf8'))

tcpClientSock.close()

sock.close()

Client:

#-*- coding: utf-8 -*-from socket import *

class TcpClient:

    HOST='127.0.0.1'

    PORT=12345

    BUFSIZ=1024

    ADDR=(HOST, PORT)

    def __init__(self):

        self.client=socket(AF_INET, SOCK_STREAM)

        self.client.connect(self.ADDR)

        while True:

            data=input('>')

            if not data:

                break

            self.client.send(data.encode('utf8'))

            data=self.client.recv(self.BUFSIZ)

            if not data:

                break

            print(data.decode('utf8'))

if __name__ == '__main__':

    client=TcpClient()

上面的TCP方式有个问题，不能退出，好吧，我们改造一下，使这个程序可以发送quit命令以退出：

Server:

#-*- coding: utf-8 -*-from socket import *

from time import ctime

from time import localtime

import time

HOST=''

PORT=1122  #设置侦听端口

BUFSIZ=1024

ADDR=(HOST, PORT)

sock=socket(AF_INET, SOCK_STREAM)

sock.bind(ADDR)

sock.listen(5)

#设置退出条件

STOP_CHAT=False

while not STOP_CHAT:

    print('等待接入，侦听端口:%d' % (PORT))

    tcpClientSock, addr=sock.accept()

    print('接受连接，客户端地址：',addr)

    while True:

        try:

            data=tcpClientSock.recv(BUFSIZ)

        except:

            #print(e)            tcpClientSock.close()

            break

        if not data:

            break

        #python3使用bytes，所以要进行编码

        #s='%s发送给我的信息是:[%s] %s' %(addr[0],ctime(), data.decode('utf8'))

        #对日期进行一下格式化

        ISOTIMEFORMAT='%Y-%m-%d %X'

        stime=time.strftime(ISOTIMEFORMAT, localtime())

        s='%s发送给我的信息是:%s' %(addr[0],data.decode('utf8'))

        tcpClientSock.send(s.encode('utf8'))

        print([stime], ':', data.decode('utf8'))

        #如果输入quit(忽略大小写),则程序退出

        STOP_CHAT=(data.decode('utf8').upper()=="QUIT")

        if STOP_CHAT:

            break

tcpClientSock.close()

sock.close()

Client:

#-*- coding: utf-8 -*-from socket import *

class TcpClient:

    #测试，连接本机

    HOST='127.0.0.1'

    #设置侦听端口

    PORT=1122

    BUFSIZ=1024

    ADDR=(HOST, PORT)

    def __init__(self):

        self.client=socket(AF_INET, SOCK_STREAM)

        self.client.connect(self.ADDR)

        while True:

            data=input('>')

            if not data:

                break

            #python3传递的是bytes，所以要编码

            self.client.send(data.encode('utf8'))

            print('发送信息到%s：%s' %(self.HOST,data))

            if data.upper()=="QUIT":

                break

            data=self.client.recv(self.BUFSIZ)

            if not data:

                break

            print('从%s收到信息：%s' %(self.HOST,data.decode('utf8')))

if __name__ == '__main__':

    client=TcpClient()

注：以上代码为Python3。

巴特西

python模块之socket

最新文章

热门文章