您的位置:首页 > 编程语言 > Python开发

python实现socket通讯(UDP)

2010-10-27 15:38 585 查看
Server:

import socket

address = ('127.0.0.1', 31500)
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.bind(address)

while True:
data, addr = s.recvfrom(2048)
if not data:
print "client has exist"
break
print "received:", data, "from", addr

s.close()


Client:

import socket

address = ('127.0.0.1', 31500)
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)

while True:
msg = raw_input()
if not msg:
break
s.sendto(msg, address)

s.close()


运行结果:

server

[work@db-testing-com06-vm3.db01.baidu.com python]$ python udp_ss.py
received: aaaaaa from ('127.0.0.1', 10169)
received: 123456 from ('127.0.0.1', 10169)
received: abcdef from ('127.0.0.1', 10169)

client

[work@db-testing-com06-vm3.db01.baidu.com python]$ python udp_cc.py
aaaaaa
123456
abcdef

[work@db-testing-com06-vm3.db01.baidu.com python]$

===============================================================================

参考:http://www.javaeye.com/topic/401391

前言

python实在是太方便,太易用了,三方库的支持又全,语法又简单,对开发人员来说,实在是居家旅行,XXXX的必备利器。周末研究了下python的网络支持,做一下记录,以备随后翻阅。

python支持BSD的socket进行网络编程,其API跟C中的大同小异,先看看TCP方式的,说到网络编程,肯定会设计到server和client,分别来看下

TCP方式

server端

server端的socket一般流程是这样:

建立一个socket(可以选择socket类型INET,UNIX等,以及连接方式TCP/UDP)

使用bind公开一个端口,使得client可以方便连接

设置一个listen队列的大小

进入一个无限循环,在此无限循环中,使用accept函数来等待客户连接,此函数返回一个新的socket, 对应于客户端的socket,建立通信信道。对socket的处理一般放在外部单独的函数中(并发)

通过send()/recv()来对socket进行读写操作

好了,下面看一下例子:

Python代码



def tcpServer():

srvsock = socket.socket( socket.AF_INET, socket.SOCK_STREAM)

srvsock.bind(('', 9527))

srvsock.listen(5)

while True:

clisock, (remoteHost, remotePort) = srvsock.accept()

print "[%s:%s] connected" % (remoteHost, remotePort)

#do something on the clisock

clisock.close()

if __name__ == "__main__":

tcpServer()

def tcpServer():
srvsock = socket.socket( socket.AF_INET, socket.SOCK_STREAM)
srvsock.bind(('', 9527))
srvsock.listen(5)

while True:
clisock, (remoteHost, remotePort) = srvsock.accept()
print "[%s:%s] connected" % (remoteHost, remotePort)
#do something on the clisock
clisock.close()

if __name__ == "__main__":
tcpServer()


client端

建立一个新的socket

使用connect函数与远程主机获得连接

在此socket上进行I/O操作

Python代码



def tcpClient():

clisock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)

clisock.connect(('localhost', 9527))

#I/O on this clisock

#clisock.send("")

#dat = clisock.recv(len)

print dat

if __name__ == "__main__":

tcpClient()

def tcpClient():
clisock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
clisock.connect(('localhost', 9527))

#I/O on this clisock
#clisock.send("")
#dat = clisock.recv(len)

print dat

if __name__ == "__main__":
tcpClient()

由代码量可见python之简单,想要将这个例子改造成一个文件传输器,估计只需要增加不到20行代码即可。

UDP方式

UDP号称无连接传输,全然没有TCP那么复杂,三次握手,错误重传之类的机制都没有,发的只管发,收得只管收,收到没有?不知道,顺序不对怎么办?不管!就是这样,但是速度就要比TCP高得多了。在对数据帧要求不是很高的地方,这确实是很好用的,比如网络上的视频传输,音频传输等。

server端

建立数据报形式的socket

公开一个端口,一边客户端连接

开始接收数据

Python代码



def udpServer():

address = ('', 9527)

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

srvsock.bind(address)

#data,addr = srvsock.recvfrom(2048)

if __name__ == "__main__":

udpServer()

def udpServer():
address = ('', 9527)
srvsock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
srvsock.bind(address)
#data,addr = srvsock.recvfrom(2048)

if __name__ == "__main__":
udpServer()

需要注意的是,server中address元组中的引号表示可以接受任何地址来的数据报,TCP例子中的则表示可以接受任意地址发起的连接。

client端

新建一个数据报socket

收发数据

Python代码



def udpClient():

address = ('localhost', 9527)

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

#clisock.sendto(data, address)

if __name__ == "__main__":

udpClient()

def udpClient():
address = ('localhost', 9527)
clisock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
#clisock.sendto(data, address)

if __name__ == "__main__":
udpClient()

文中给出的例子已经具有网络程序的基本结构,在实际应用中,应该自行扩展对socket的处理,socket说到底跟文件句柄,文件描述符,管道描述符等都是一个概念,可以对其进行I/O处理,事实上,在UNIX类系统中,对socket的操作跟对文件句柄的操作没有任何形式上的差异。
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: