Python Udp Socket

提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

socket（套接字），传输层通信的端点，由IP和端口号组成（IP,Port），可以通过socket精确地找到服务器上的进程并与之通信

python2.6实现，基于AF_INET（网络套接字）
类型SOCKET_STREAM（TCP套接字），SOCKET_DGRAM（UDP套接字）

UDP socket实现较TCP要简单，没有建立连接的过程，服务端无限循环接收数据，处理数据返回，客户端也无需建立通信连接，
直接发送数据接收数据即可

UDP socket通信逻辑
UDP服务端：创建socket>>>绑定本地服务器>>>无限循环>>>接收信息返回信息
UDP客户端：创建socket>>>发送信息接收信息

Python Udp Socket服务端

#!/usr/bin/python
#-*-coding utf-8-*- # filename : Udpsocket.py
# author :
# create date : 2015-03-25
# modify date :
# description : udp socket #import stander lib
from socket import socket, AF_INET, SOCK_DGRAM
import sys
sys.path.append( '..' ) class Udpsocket():
'''
Udpsocket类，建立udp socket服务端
用法：
p = Udpsocket.Udpsocket()
p.listen()
无限循环监听端口，process重写数据处理方式
''' def __init__( self ):
'''
初始化，建立socket，ip端口绑定
'''
self.udpServerSocket = socket( AF_INET, SOCK_DGRAM )
self.udpServerSocket.bind( ('127.0.0.1', 20015) )
self.buffer_size = 1024 #缓冲区为1k def receive( self ):
'''
收取端口传来的数据
'''
raw_data, addr = self.udpServerSocket.recvfrom( int(self.buffer_size) )
print 'conn from : ', addr
print 'receive from udp client : ', raw_data return ( raw_data, addr ) def process( self, data ):
'''
socket传输的数据加工处理，继承重写该函数
'''
result = data
return result def send( self, addr, result ):
'''
返回信息
'''
self.udpServerSocket.sendto( result, addr ) def listen( self ):
'''
监听端口，无限循环
'''
while True:
print 'wait for connect'
socket_data = self.receive() #接收数据
result = self.process( socket_data[0] ) #处理接收的信息
self.send( socket_data[1], str(result) ) #返回数据
self.close() def close( self ):
'''
关闭连接
'''
self.udpServerSocket.close() def __del__( self ):
self.close() if __name__ == '__main__':
p = Udpsocket()
p.listen()

Python Udp Socket客户端

#!/usr/bin/env python
#-*-coding:utf-8-*- from socket import * HOST = '127.0.0.1' #主机
PORT = 20015 #端口
BUFFSIZE = 1024 #缓冲区大小
ADDR = ( HOST, PORT ) #地址 #建立socket监听
udpClientSocket = socket( AF_INET, SOCK_DGRAM ) #传送接收数据
udpClientSocket.sendto( 'hello', ADDR )
data, addr = udpClientSocket.recvfrom( BUFFSIZE )
print 'receive data : ', data
#data, addr = udpClientSocket.recvfrom( BUFFSIZE )
udpClientSocket.close()