1.Socket类型

socket(family,type[,protocal])     使用给定的地址族,套接字类型,协议编号(默认是0)来创建套接字

socket类型

描述

socket.AF_UNIX

只能够用于单一的Unix系统进程间通信

socket.AF_INET

服务器之间网络通信

socket.AF_INET6

IPv6

socket.SOCK_STREAM

流式socket , for TCP

socket.SOCK_DGRAM

数据报式socket , for UDP

socket.SOCK_RAW

原始套接字，普通的套接字无法处理ICMP、IGMP等网络报文,而SOCK_RAW可以;其次,SOCK_RAW也可以处理特殊的IPv4报文;此外,利用原始套接字,可以通过IP_HDRINCL套接字选项由用户构造IP头.

socket.SOCK_SEQPACKET

可靠的连续数据包服务

创建UDP Socket

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

2.Socket函数

socket函数(服务器)

描述

s.bind(address)

将套接字绑定到地址, 在AF_INET下,以元组(host,port)的形式表示地址.

s.listen(backlog)

开始监听TCP传入连接.backlog指定在拒绝连接之前,操作系统可以挂起的最大连接数量.该值至少为1,大部分应用程序设为5就可以了.

s.accept()

接受TCP连接并返回(conn,address),其中conn是新的套接字对象,可以用来接收和发送数据.address是连接客户端的地址.

socket函数(客户端)

s.connect(address)

连接到address处的套接字.一般address的格式为元组(hostname,port),如果连接出错,返回socket.error错误.

s.connect_ex(adddress)

功能与connect(address)相同,但是成功返回0,失败返回errno的值.

公共socket函数

s.recv(bufsize[,flag])

接受TCP套接字的数据.数据以字符串形式返回,bufsize指定要接收的最大数据量.flag提供有关消息的其他信息,通常可以忽略.

s.send(string[,flag])

发送TCP数据.将string中的数据发送到连接的套接字.返回值是要发送的字节数量,该数量可能小于string的字节大小.

s.sendall(string[,flag])

完整发送TCP数据.将string中的数据发送到连接的套接字,但在返回之前会尝试发送所有数据.成功返回None,失败则抛出异常.

s.close()

关闭套接字.

s.gettimeout()

返回当前超时期的值,单位是秒,如果没有设置超时期,则返回None.

s.fileno()

返回套接字的文件描述符.

s.makefile()

创建一个与该套接字相关连的文件

3.socket原理

TCP服务端:

(1).创建套接字,绑定套接字到本地IP与端口(socket.socket(socket.AF_INET,socket.SOCK_STREAM) , s.bind())

(2).开始监听连接(s.listen())

(3).进入循环,不断接受客户端的连接请求(s.accept())

(4).然后接收传来的数据,并发送给对方数据(s.recv() , s.sendall())

(5).传输完毕后,关闭套接字(s.close())

TCP客户端:

(1).创建套接字，连接远端地址(socket.socket(socket.AF_INET,socket.SOCK_STREAM) , s.connect())

(2).连接后发送数据和接收数据(s.sendall(), s.recv())

(3).传输完毕后,关闭套接字(s.close())

4.例1:简单实现socket通信

服务端:

[root@node1 python]# vim socket12.py

#!/bin/env python

#!-*- coding:UTF-8 -*-

import socket

s=socket.socket()

host=socket.gethostname()

port=1234

s.bind((host,port))

s.listen(5)

while True:

c,addr=s.accept()

print "Got connection from,addr"

c.send("Thank you for connection")

c.close()

[root@node1 python]# chmod  755 socket12.py

[root@node1 python]# ./socket12.py

[root@node1 python]# netstat -antulp | grep 1234

tcp        0      0   0.0.0.0:1234           0.0.0.0:*                   LISTEN      31580/python

客户端:

[root@node2 ~]# vim socket12.py

#!/bin/env python

#!-*- coding:UTF-8 -*-

import socket

s=socket.socket()

host='0.0.0.0'            --服务端的IP地址

port=1234

s.connect((host,port))

print s.recv(1024)

[root@node2 ~]# chmod  755 socket12.py

[root@node2 ~]# ./socket12.py

Thank you for connection

[root@node2 ~]#

此时服务端就会有数据:

5.例2:利用socket协议在客户端操作服务器

服务器端:

[root@node1 python]# cat socket2.py

#!/bin/env python

#!-*- coding:UTF-8 -*-

import socket

import commands

host=socket.gethostname()     --服务器的主机名

port=1245                                --启动python脚本的端口

s=socket.socket()                      --实例一个socket对像

s.bind((host,port))                     --端口绑定到主机的IP地址

s.listen(5)                                  --允许多少个客户端连接

while True:

conn,addr=s.accept()           --接收客户端的信息

print "Connect by",addr       --在服务端输出客户端的IP地址

while True:

data=conn.recv(1024)

cmd_status,cmd_result=commands.getstatusoutput(data)   --获取客户端的命令

if len(cmd_result.strip()) == 0:

conn.sendall('Done.')

else:

conn.sendall(cmd_result)

conn.close()

[root@node1 python]# ./socket2.py

[root@node1 python]# netstat -antulp | grep python

tcp        0      0  0.0.0.0:1245           0.0.0.0:*                   LISTEN      2550/python

[root@node1 python]#

客户端:

[root@node2 ~]# cat socket2.py

#!/bin/env python

#!-*- coding:UTF-8 -*-

import socket,commands

host='0.0.0.0'         --服务端的IP地址

port=1245

s=socket.socket()

s.connect((host,port))

while True:

cmd=raw_input("Please input cmd:")

s.sendall(cmd)

data=s.recv(1024)

print data

s.close()

[root@node2 ~]#