❶ python socket 模塊
Python 提供了兩個基本的 socket 模塊。第一個是 Socket,它提供了標準的 BSD Sockets API。第二個是 SocketServer,它提供了伺服器中心類,可以簡化網路伺服器的開發。
Socket 模塊提供了 UNIX ® 程序員所熟悉的基本網路服務(也稱為 BSD API)。這個模塊中提供了在構建 socket 伺服器和客戶機時所需要的所有功能。
在 Python 中,socket 方法會向應用 socket 方法的對象返回一個 socket 對象。
❷ python 2.7中有沒有socketserver這個模塊
Python提供了兩個基本的socket模塊。一個是socket,它提供了標準的BSD Socket API;另一個是socketServer,它提供了伺服器中心類,可以簡化網路伺服器的開發。
本文簡要介紹socket模塊包含的類及其使用。
1.開始了解socket模塊前,先熟悉下Python的網路編程模塊主要支持的兩種Intent協議:TCP和UDP。TCP協議是一種面向連接的可靠協議,用於建立機器之間的雙向通信流。UDP協議是一種較低級別的、以數據包為基礎的協議(無連接傳輸模式)。與TCP不同,UDP信息不可靠。
他們的區別如下圖所示:左圖為TCP連接協議,右圖為UDP連接協議
2.socket模塊的部分類方法介紹
類方法
說明
socket.socket(family, type[,proto])
創建並返回一個新的 socket對象
socket.getfqdn(name)
將使用點號分隔的 IP地址字元串轉換成一個完整的域名
socket.gethostbyname(hostname)
將主機名解析為一個使用點號分隔的 IP地址字元串
socket.gethostbyname_ex(name)
它返回一個包含三個元素的元組,從左到右分別是給定地址的主要的主機名、同一IP地址的可選的主機名的一個列表、關於同一主機的同一介面的其它IP地址的一個列表(列表可能都是空的)。
socket.gethostbyaddr(address)
作用與gethostbyname_ex相同,只是你提供給它的參數是一個IP地址字元串
Socket.getservbyname(service,protocol)
它要求一個服務名(如'telnet'或'ftp')和一個協議(如'tcp'或'udp'),返回服務所使用的埠號
socket.fromfd(fd, family, type)
從現有的文件描述符創建一個 socket對象
3.socket對象的部分方法介紹
實例方法
說明
sock.bind( (adrs, port) )
將 socket綁定到一個地址和埠上
sock.accept()
返回一個客戶機 socket(帶有客戶機端的地址信息)
sock.listen(backlog)
將 socket設置成監聽模式,能夠監聽 backlog 外來的連接請求
sock.connect( (adrs, port) )
將 socket連接到定義的主機和埠上
sock.recv( buflen[, flags] )
從 socket中接收數據,最多 buflen 個字元
sock.recvfrom( buflen[, flags] )
從 socket中接收數據,最多 buflen 個字元,同時返回數據來源的遠程主機和埠號
sock.send( data[, flags] )
通過 socket發送數據
sock.sendto( data[, flags], addr )
通過 socket發送數據
sock.close()
關閉 socket
sock.getsockopt( lvl, optname )
獲得指定 socket 選項的值
sock.setsockopt( lvl, optname, val )
設置指定 socket選項的值
4.編寫socket測試程序
(a)編寫server的步驟
第一步是創建socket對象。調用socket構造函數。如:
socket = socket.socket( family, type )
family參數代表地址家族,可為AF_INET或AF_UNIX。AF_INET家族包括Internet地址,AF_UNIX家族用於同一台機器上的進程間通信。
type參數代表套接字類型,可為SOCK_STREAM(流套接字)和SOCK_DGRAM(數據報套接字)。
第二步是將socket綁定到指定地址。這是通過socket對象的bind方法來實現的:
socket.bind( address )
由AF_INET所創建的套接字,address地址必須是一個雙元素元組,格式是(host,port)。host代表主機,port代表埠號。如果埠號正在使用、主機名不正確或埠已被保留,bind方法將引發socket.error異常。
第三步是使用socket套接字的listen方法接收連接請求。
socket.listen( backlog )
backlog指定最多允許多少個客戶連接到伺服器。它的值至少為1。收到連接請求後,這些請求需要排隊,如果隊列滿,就拒絕請求。
第四步是伺服器套接字通過socket的accept方法等待客戶請求一個連接。
connection, address = socket.accept()
調 用accept方法時,socket會時入「waiting」狀態。客戶請求連接時,方法建立連接並返回伺服器。accept方法返回一個含有兩個元素的元組(connection,address)。第一個元素connection是新的socket對象,伺服器必須通過它與客戶通信;第二個元素 address是客戶的Internet地址。
第 五步是處理階段,伺服器和客戶端通過send和recv方法通信(傳輸 數據)。伺服器調用send,並採用字元串形式向客戶發送信息。send方法返回已發送的字元個數。伺服器使用recv方法從客戶接收信息。調用recv 時,伺服器必須指定一個整數,它對應於可通過本次方法調用來接收的最大數據量。recv方法在接收數據時會進入「blocked」狀態,最後返回一個字元 串,用它表示收到的數據。如果發送的數據量超過了recv所允許的,數據會被截短。多餘的數據將緩沖於接收端。以後調用recv時,多餘的數據會從緩沖區 刪除(以及自上次調用recv以來,客戶可能發送的其它任何數據)。
傳輸結束,伺服器調用socket的close方法關閉連接。
(b)編寫client的步驟
首先創建一個socket以連接伺服器:socket =socket.socket( family, type )
使用socket的connect方法連接伺服器。對於AF_INET家族,連接格式如下:
socket.connect( (host,port) )
host代表伺服器主機名或IP,port代表伺服器進程所綁定的埠號。如連接成功,客戶就可通過套接字與伺服器通信,如果連接失敗,會引發socket.error異常。
處理階段,客戶和伺服器將通過send方法和recv方法通信。
傳輸結束,客戶通過調用socket的close方法關閉連接。
5.實例源碼:python socket半雙工聊天
(a)tcpserver.py
[python] view plain
# -*- coding: cp936 -*-
#file:tcpserver.py
import socket
from time import ctime
import sys
bufsize = 1024
host = '127.0.0.1'
port = 8100
address = (host,port)
server_sock = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
server_sock.bind(address)
server_sock.listen(1)
while True:
print 'waiting for connection...'
clientsock,addr = server_sock.accept()
print 'received from :',addr
while True:
data = clientsock.recv(bufsize)
print ' 收到---->%s\n%s' %(ctime(),data)
data = raw_input("發送----->")
clientsock.send(data)
clientsock.close()
server_sock.close()
(b)tcpclient.py
[python] view plain
## -*- coding: cp936 -*-
##file:tcpclient.py
from socket import *
from time import ctime
bufsize = 1024
host = '127.0.0.1'
port = 8100
addr = (host,port)
client_sock = socket(AF_INET,SOCK_STREAM)
client_sock.connect(addr)
while True:
data = raw_input("發送---->")
if not data:
break
else:
client_sock.send(data)
data = client_sock.recv(bufsize)
print '收到---->%s\n%s' %(ctime(),data)
client_sock.close()
❸ 如何用python方法檢測UDP埠
本文實例講述了python檢測遠程udp埠是否打開的方法。分享給大家供大家參考。具體實現方法如下:
復制代碼代碼如下:
import socket
import threading
import time
import struct
import Queue
queue = Queue.Queue()
def udp_sender(ip,port):
try:
ADDR = (ip,port)
sock_udp = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
sock_udp.sendto("abcd...",ADDR)
sock_udp.close()
except:
pass
def icmp_receiver(ip,port):
icmp = socket.getprotobyname("icmp")
try:
sock_icmp = socket.socket(socket.AF_INET, socket.SOCK_RAW, icmp)
except socket.error, (errno, msg):
if errno == 1:
# Operation not permitted
msg = msg + (
" - Note that ICMP messages can only be sent from processes"
" running as root."
)
raise socket.error(msg)
raise # raise the original error
sock_icmp.settimeout(3)
try:
recPacket,addr = sock_icmp.recvfrom(64)
except:
queue.put(True)
return
icmpHeader = recPacket[20:28]
icmpPort = int(recPacket.encode('hex')[100:104],16)
head_type, code, checksum, packetID, sequence = struct.unpack(
"bbHHh", icmpHeader
)
sock_icmp.close()
if code == 3 and icmpPort == port and addr[0] == ip:
queue.put(False)
return
def checker_udp(ip,port):
thread_udp = threading.Thread(target=udp_sender,args=(ip,port))
thread_icmp = threading.Thread(target=icmp_receiver,args=(ip,port))
thread_udp.daemon= True
thread_icmp.daemon = True
thread_icmp.start()
time.sleep(0.1)
thread_udp.start()
thread_icmp.join()
thread_udp.join()
return queue.get(False)
if __name__ == '__main__':
import sys
print checker_udp(sys.argv[1],int(sys.argv[2]))
希望本文所述對大家的Python程序設計有所幫助。
❹ python 如何測試socket連接伺服器連接數的極限並優化改進
貼Python代碼還是找個引用源吧,比如paste.openstack.org,提這類問題還是去segmentfault比較合適。優化的話,並行處理就好了,可以參考gevent
❺ python socket如何連接到華為雲伺服器
這篇文章主要介紹了python使用socket連接遠程伺服器的方法,涉及Python中socket通信的基本技巧,具有一定參考借鑒價值,需要的朋友可以參考下
本文實例講述了python使用socket連接遠程伺服器的方法。分享給大家供大家參考。具體如下:
import socket
print "Creating socket...",
s = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
print "done."
print "Looking up port number...",
port = socket.getservbyname('http', 'tcp')
print "done."
print "Connecting to remote host on port %d..." % port,
s.connect(("www.jb51.net", port))
print "done."
❻ 菜鳥求教一個關於python socket的問題
情況時這樣,最近剛學python,一直使用的文本編輯,在學到socket時自己嘗試寫了一個小腳本,部分語句如下:
import socket
self.service=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
python 運行無錯
最近又發現,原來eclipse是有python擴展包的,於是嘗試把自己寫的東西放到eclipse中運行,然後就報錯了:
self.service=socket.socket(socket.AF_INET,socket.SOCK_STREAM)
AttributeError: 'mole' object has no attribute 'AF_INET'
ctrl+左鍵放到AF_INET提示此值存放在_socket下,於是有以下嘗試:
import socket
import _socket
print _socket.AF_INET #無報錯,返回2
print socket.AF_INET #報錯
於是修改了腳本
import _socket as socket
我的腳本運行正常
首先,我系統的環境使用的時python2.6,eclipse中,windows-》preferences-》interpreter - python這裡面的lib包(指向/usr/bin/python2.6),與我在終端的輸出sys.path輸出的值時一樣的
然後,我的問題:
1,是不是在python中有兩個模塊,一個叫socket,一個叫_socket?
2,為什麼在終端執行,可以直接import socket.AF_INET,而在eclipse中則需要import _socket?
可能你的測試腳本或當前路進下有其他腳本也叫socket,優先被載入造成錯誤,試試import後立刻列印路徑看看是不是標準的那個...
>>> import socket
>>> print socket.__file__
C:\Python27\lib\socket.pyc
>>>