python3sendall_如何實現Python多進程http伺服器

⑴ python3中，建立一個socket客戶端向服務端發送json數據是報 unknown url type，為什麼呢

參考這個客戶端程序，我覺得是你的服務端有問題
import socket

HOST = '127.0.0.1' # 伺服器的主機名或者 IP 地址
PORT = 65432 # 伺服器使用的埠

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
s.connect((HOST, PORT))
s.sendall(b'Hello, world')
data = s.recv(1024)

print('Received', repr(data))

服務端寫法
import socket

HOST = '127.0.0.1' # 標準的回環地址 (localhost)
PORT = 65432 # 監聽的埠 (非系統級的埠: 大於 1023)

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
s.bind((HOST, PORT))
s.listen()
conn, addr = s.accept()
with conn:
print('Connected by', addr)
while True:
data = conn.recv(1024)
if not data:
break
conn.sendall(data)

⑵ 石頭剪刀布的python題怎麼寫

python3代碼如下：

# coding:utf-8

import random

guess_list = ["石頭", "剪刀", "布"]

win_combination = [["布", "石頭"], ["石頭", "剪刀"], ["剪刀", "布"]]

while True:

computer = random.choice(guess_list)

user = input('請輸入：石頭、剪刀、布 ').strip() #刪除首尾的空格

if user not in guess_list:

continue

elif computer == user:

print("平局，再來")

elif [computer, user] in win_combination:

print("你輸了，哈哈")

else:

print("你贏了，恭喜")

break

運行結果如下：

平局或輸都會繼續游戲，直到贏才會結束

⑶ Python用socket傳輸文件，收到的文件大小不一樣，求解答，謝謝

1.電腦已經搭建python環境

2.深入到需要傳輸的文件目錄下，此處以分享 nemo-huiyuanfei 文件為例

3.在路徑欄輸入 cmd 按回車進入終端
4.輸入命令 python -m SimpleHTTPServer 8090 按回車（埠號可以任意，不用必須為8090）

5.在區域網中任意瀏覽器輸入框輸入文件所在主機 IP + Port 即可訪問此文件目錄並下載（）

6.點擊需要下載的文件即可下載
7. 【注意】python3.X 的命令輸入為 python -m http.server 8090

⑷ python中3種調用可執行文件.exe的方法

方法一、os.system() 會保存可執行程序中的列印值和主函數的返回值，且會將執行過程中要列印的內容列印出來。

import os

main = "project1.exe"

r_v = os.system(main)

print (r_v )

方法二、commands.getstatusoutput() 會保存可執行程序中的列印值和主函數的返回值，但不會將執行過程中要列印的內容列印出來。

import subprocess

import os

main = "project1.exe"

if os.path.exists(main):

rc,out= subprocess.getstatusoutput(main)

print (rc)

print ('*'*10)

print (out)

方法三、popen() 會保存可執行程序中的列印值，但不會保存主函數的返回值，也但不會將執行過程中要列印的內容列印出來。

import os

main = "project1.exe"

f = os.popen(main)

data = f.readlines()

f.close()

print (data)

另外，上面提到的三種方式，實際上都是在python中執行命令，因此他們不只是用來執行可執行文件，也可以用來執行linux系統中別的指令。

關於python中3種調用可執行文件.exe的方法，環球青藤小編就和大家分享到這里了，學習是永無止境的，學習一項技能更是受益終身，所以，只要肯努力學，什麼時候開始都不晚。如果您還想繼續了解關於python編程的學習方法及素材等內容，可以點擊本站其他文章學習。

⑸ 如何安裝Python 3中，並設置本地編程環境在CentOS 7

介紹

Python是一種多功能編程語言，可以用於許多不同的編程項目。開發團隊於1991年首先發表了一個名叫靈感來源於英國喜劇組織Monty Python的名字，他希望Python能夠成為一種有趣的語言。對於初學者和經驗豐富的開發人員來說，Python易於設置，並且以相對直接的方式編寫，並提供對錯誤的即時反饋。Python 3是該語言的最新版本，被認為是Python的未來。

本教程將指導您在本地CentOS 7機器上安裝Python 3，並通過命令行設置編程環境。

先決條件

您將需要一台連接到互聯網的非root超級用戶帳戶的CentOS 7計算機。

第1步 - 准備系統

我們將通過命令行來完成這個安裝。如果您的CentOS 7計算機啟動了圖形用戶界面（GUI）桌面，則可以通過菜單訪問命令行界面，方法是導航到應用程序，然後導航到實用程序，然後單擊終端。如果您需要更多關於終端的指導，請務必閱讀文章「Linux終端簡介」。

在開始安裝之前，讓我們確保更新默認的系統應用程序以獲得最新版本。

我們將使用開源包管理工具yum，代表Yellowdog Updater Modified。這是一個常用的工具，用於在基於Red Hat的Linux系統（如CentOS）上處理軟體包。它可以讓你輕松地安裝和更新，以及刪除您的計算機上的軟體包。

我們首先通過運行這個命令來確保yum是最新的：（更新系統是可選執行）

sudo yum -y update

該-y標志用於警告系統，我們知道我們正在進行更改，防止終端提示我們確認。

接下來，我們將安裝yum-utils，這是一個擴展和補充yum的實用程序和插件的集合：（也可以不安裝）

sudo yum -y install yum-utils

最後，我們將安裝CentOS開發工具，這些工具用於允許您從源代碼構建和編譯軟體：（也可以不安裝）

sudo yum -y groupinstall development

一旦安裝好了，我們的安裝就緒了，我們可以繼續安裝Python 3。

第2步 - 安裝和設置Python 3

CentOS源自RHEL（紅帽企業Linux），其穩定性是其主要焦點。正因為如此，經過測試和穩定版本的應用程序是最常見的系統和可下載的軟體包，所以在CentOS上，你只能找到Python 2。

因為我們想要安裝Python 3的最新上游穩定版本，我們需要安裝IUS，代表Inline with Upstream Stable。作為一個社區項目，IUS為選擇軟體的一些更新版本提供了紅帽軟體包管理器（RPM）軟體包。

要安裝IUS，先要安裝epel-release7包我們來安裝它yum：

sudo yum -y install epel-release-7-11.noarch.rpm

sudo yum -y install ius-release.rpm

一旦IUS完成安裝，我們可以安裝最新版本的Python：

sudo yum -y install python36u

當Python的安裝過程完成後，我們可以通過以下python3.6命令檢查其安裝是否成功：

python3.6 -V

使用成功安裝的Python 3.6版本，我們將收到以下輸出：

Output

Python3.6.1

接下來我們將安裝pip，它將管理Python的軟體包：

sudo yum -y install python36u-pip

一個用於Python的工具，我們將使用pip來安裝和管理我們可能想在我們的開發項目中使用的編程包。你可以通過鍵入以下命令來安裝Python包

sudo pip3.6 install package_name

在這里，package_name可以參考任何Python包或者庫，比如用於Web開發的Django或者用於科學計算的NumPy。所以如果你想安裝NumPy，你可以使用命令來完成pip3.6 install numpy。

最後，我們將需要安裝IUS軟體包python36u-devel，它為我們提供了Python 3開發所需的庫和頭文件：

sudo yum -y install python36u-devel

該VENV模塊將用於建立一個虛擬的環境，為我們下一步的發展項目。

第3步 - 建立一個虛擬環境

現在，我們已經安裝了Python，並且已經安裝好了系統，我們可以繼續使用venv創建我們的編程環境。

虛擬環境使您能夠在計算機上為Python項目設置一個獨立的空間，確保您的每個項目都擁有自己的一組依賴項，不會中斷任何其他項目。

建立一個編程環境使我們能夠更好地控制我們的Python項目以及如何處理不同版本的包。使用第三方軟體包時，這一點尤為重要。

您可以根據需要設置盡可能多的Python編程環境。每個環境基本上都是您的計算機中的一個目錄或文件夾，其中包含一些腳本以使其充當環境。

選擇你想把你的Python編程環境放入哪個目錄，或者創建一個新目錄mkdir，如下所示：

mkdir environments
cd environments

一旦進入了你想要環境所在的目錄，就可以通過運行以下命令來創建一個環境：

python3.6 -m venv my_env

本質上，這個命令會創建一個新的目錄（在本例中稱為my_env），其中包含一些我們可以通過ls命令看到的項目：

bin include lib lib64 pyvenv.cfg

這些文件一起工作，以確保您的項目與本地計算機的更廣泛的上下文隔離，以便系統文件和項目文件不會混合。這是版本控制的好習慣，並確保您的每個項目都可以訪問它所需的特定軟體包。

要使用這個環境，你需要激活它，你可以通過輸入以下命令來調用目錄中的激活腳本bin：

source my_env/bin/activate

您的提示現在將以您的環境的名稱作為前綴，在這種情況下，它被稱為my_env：

這個前綴讓我們知道my_env環境當前是活動的，這意味著當我們在這里創建程序時，他們將只使用這個特定環境的設置和包。

注意：在虛擬環境中，您可以使用命令python而不是python3.6，而pip不是pip3.6如果您願意的話。如果您在環境外使用Python 3，則需要專門使用python3.6和pip3.6命令。

遵循這些步驟之後，即可使用您的虛擬環境。

第4步 - 創建一個簡單的程序

現在我們已經建立了虛擬環境，我們來創建一個簡單的「Hello，World！」程序。這將確保我們的環境正在工作，並且使我們有機會更熟悉Python，如果我們還沒有。

為此，我們將打開一個名為vim的命令行文本編輯器，並創建一個新文件：

vi hello.py

一旦文本文件在我們的終端窗口打開，我們將不得不鍵入i進入插入模式，然後我們可以寫我們的第一個程序：

print("Hello, World!")

現在按下ESC退出插入模式。接下來，輸入:x然後ENTER保存並退出文件。

我們現在准備好運行我們的程序：

python hello.py

剛剛創建的hello.py程序應該使終端產生以下輸出：

Output

Hello, World!

要離開環境，只需鍵入命令，deactivate然後返回到原始目錄。

結論

恭喜！此時，您已經在本地CentOS 7機器上安裝了Python 3編程環境，並且可以開始一個編碼項目！

⑹ Python 3 所有口令全稱（例：Del.Delete...刪除符號）以及使用方法

開頭要改成小寫的字母：
Del.Delete...刪除符號
Def.Define...輸入符號
If...假設符號
Import...引入符號
Print...塗改符號
Else/Elif...約質符號
While...條件符號
Return/Break...結束符號
True/False...判斷符號(None)
Input/Int...增添符號
From...提取符號
Self...自本符號
Except...
Try...嘗試符號
For _ in _ ...循環符號
Class...
Object...
Dict...
List...
Learn...
Range...復回符號
……

⑺ python怎麼建立socket服務端

socket伺服器再細分可分為多種了，tcp,udp,websocket，都是調用socket模塊，但是具體實現起來有一點細微的差別

先給出一個tcp和udp通過socket協議實現的聊天室的例子

python聊天室(python2.7版本)：

都是分別運行server.py和client.py，就可以進行通訊了。

TCP版本：

socket-tcp-server.py（服務端）:

#-*-encoding:utf-8-*-
#socket.getaddrinfo(host,port,family=0,socktype=0,proto=0,flags=0)
#根據給定的參數host/port，相應的轉換成一個包含用於創建socket對象的五元組，
#參數host為域名，以字元串形式給出代表一個IPV4/IPV6地址或者None.
#參數port如果字元串形式就代表一個服務名，比如「http」"ftp""email"等，或者為數字，或者為None
#參數family為地主族，可以為AF_INET，AF_INET6，AF_UNIX.
#參數socktype可以為SOCK_STREAM(TCP)或者SOCK_DGRAM(UDP)
#參數proto通常為0可以直接忽略
#參數flags為AI_*的組合，比如AI_NUMERICHOST，它會影響函數的返回值
#附註：給參數host,port傳遞None時建立在C基礎，通過傳遞NULL。
#該函數返回一個五元組(family,socktype,proto,canonname,sockaddr)，同時第五個參數sockaddr也是一個二元組(address,port)
#更多的方法及鏈接請訪問
#Echoserverprogram
fromsocketimport*
importsys
importthreading
fromtimeimportctime
fromtimeimportlocaltime
importtraceback
importtime
importsubprocess
reload(sys)
sys.setdefaultencoding("utf8")


HOST='127.0.0.1'
PORT=8555#設置偵聽埠
BUFSIZ=1024

classTcpServer():
def__init__(self):
self.ADDR=(HOST,PORT)
try:
self.sock=socket(AF_INET,SOCK_STREAM)
print'%disopen'%PORT

self.sock.bind(self.ADDR)
self.sock.listen(5)
#設置退出條件
self.STOP_CHAT=False

#所有監聽的客戶端
self.clients={}
self.thrs={}
self.stops=[]

exceptException,e:
print"%disdown"%PORT
returnFalse

defIsOpen(ip,port):

s=socket(AF_INET,SOCK_STREAM)
try:
s.connect((ip,int(port)))
#s.shutdown(2)
#利用shutdown()函數使socket雙向數據傳輸變為單向數據傳輸。shutdown()需要一個單獨的參數，
#該參數表示s了如何關閉socket。具體為：0表示禁止將來讀；1表示禁止將來寫；2表示禁止將來讀和寫。
print'%disopen'%port
returnTrue
except:
print'%disdown'%port
returnFalse

deflisten_client(self):
whilenotself.STOP_CHAT:
print(u'等待接入，偵聽埠:%d'%(PORT))
self.tcpClientSock,self.addr=self.sock.accept()
print(u'接受連接，客戶端地址：',self.addr)
address=self.addr
#將建立的clientsocket鏈接放到列表self.clients中
self.clients[address]=self.tcpClientSock
#分別將每個建立的鏈接放入進程中，接收且分發消息
self.thrs[address]=threading.Thread(target=self.readmsg,args=[address])
self.thrs[address].start()
time.sleep(0.5)defreadmsg(self,address):
#如果地址不存在，則返回False
ifaddressnotinself.clients:
returnFalse
#得到發送消息的clientsocket
client=self.clients[address]
whileTrue:
try:
#獲取到消息內容data
data=client.recv(BUFSIZ)
except:
print(e)
self.close_client(address)
break
ifnotdata:
break
#python3使用bytes，所以要進行編碼
#s='%s發送給我的信息是:[%s]%s'%(addr[0],ctime(),data.decode('utf8'))
#對日期進行一下格式化
ISOTIMEFORMAT='%Y-%m-%d%X'
stime=time.strftime(ISOTIMEFORMAT,localtime())
s=u'%s發送給我的信息是:%s'%(str(address),data.decode('utf8'))
#將獲得的消息分發給鏈接中的clientsocket
forkinself.clients:
self.clients[k].send(s.encode('utf8'))
self.clients[k].sendall('sendall:'+s.encode('utf8'))
printstr(k)
print([stime],':',data.decode('utf8'))
#如果輸入quit(忽略大小寫),則程序退出
STOP_CHAT=(data.decode('utf8').upper()=="QUIT")
ifSTOP_CHAT:
print"quit"
self.close_client(address)
print"alreadyquit"
break

defclose_client(self,address):
try:
client=self.clients.pop(address)
self.stops.append(address)
client.close()
forkinself.clients:
self.clients[k].send(str(address)+u"已經離開了")
except:
pass
print(str(address)+u'已經退出')


if__name__=='__main__':
tserver=TcpServer()
tserver.listen_client()

——————————華麗的分割線——————————

socket-tcp-client.py（客戶端）：

#-*-encoding:utf-8-*-
fromsocketimport*
importsys
importthreading
importtime
reload(sys)
sys.setdefaultencoding("utf8")


#測試，連接本機
HOST='127.0.0.1'
#設置偵聽埠
PORT=8555
BUFSIZ=1024

classTcpClient:

ADDR=(HOST,PORT)
def__init__(self):
self.HOST=HOST
self.PORT=PORT
self.BUFSIZ=BUFSIZ
#創建socket連接
self.client=socket(AF_INET,SOCK_STREAM)
self.client.connect(self.ADDR)
#起一個線程，監聽接收的信息
self.trecv=threading.Thread(target=self.recvmsg)
self.trecv.start()

defsendmsg(self):
#循環發送聊天消息，如果socket連接存在則一直循環，發送quit時關閉鏈接
whileself.client.connect_ex(self.ADDR):
data=raw_input('>:')
ifnotdata:
break
self.client.send(data.encode('utf8'))
print(u'發送信息到%s：%s'%(self.HOST,data))
ifdata.upper()=="QUIT":
self.client.close()
printu"已關閉"
break
defrecvmsg(self):
#接收消息，如果鏈接一直存在，則持續監聽接收消息
try:
whileself.client.connect_ex(self.ADDR):
data=self.client.recv(self.BUFSIZ)
print(u'從%s收到信息：%s'%(self.HOST,data.decode('utf8')))
exceptException,e:
printstr(e)

if__name__=='__main__':
client=TcpClient()
client.sendmsg()

UDP版本：

socket-udp-server.py

#-*-coding:utf8-*-

importsys
importtime
importtraceback
importthreading
reload(sys)
sys.setdefaultencoding('utf-8')

importsocket
importtraceback

HOST="127.0.0.1"
PORT=9555
CHECK_PERIOD=20
CHECK_TIMEOUT=15

classUdpServer(object):
def__init__(self):
self.clients=[]
self.beats={}
self.ADDR=(HOST,PORT)
try:
self.sock=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
self.sock.bind(self.ADDR)#綁定同一個域名下的所有機器
self.beattrs=threading.Thread(target=self.checkheartbeat)
self.beattrs.start()
exceptException,e:
traceback.print_exc()
returnFalse

deflisten_client(self):
whileTrue:
time.sleep(0.5)
print"hohohohohoo"
try:
recvData,address=self.sock.recvfrom(2048)
ifnotrecvData:
self.close_client(address)
break
ifaddressinself.clients:
senddata=u"%s發送給我的信息是:%s"%(str(address),recvData.decode('utf8'))
ifrecvData.upper()=="QUIT":
self.close_client(address)
ifrecvData=="HEARTBEAT":
self.heartbeat(address)
continue
else:
self.clients.append(address)
senddata=u"%s發送給我的信息是:%s"%(str(address),u'進入了聊天室')
forcinself.clients:
try:
self.sock.sendto(senddata,c)
exceptException,e:
printstr(e)
self.close_client(c)
exceptException,e:
#traceback.print_exc()
printstr(e)
pass

defheartbeat(self,address):
self.beats[address]=time.time()

defcheckheartbeat(self):

whileTrue:
print"checkheartbeat"
printself.beats
try:
forcinself.clients:
printtime.time()
printself.beats[c]
ifself.beats[c]+CHECK_TIMEOUT<time.time():
printu"%s心跳超時，連接已經斷開"%str(c)
self.close_client(c)
else:
printu"checkp%s,沒有斷開"%str(c)
exceptException,e:
traceback.print_exc()
printstr(e)
pass
time.sleep(CHECK_PERIOD)

defclose_client(self,address):
try:
ifaddressinself.clients:
self.clients.remove(address)
ifself.beats.has_key(address):
delself.beats[address]
printself.clients
forcinself.clients:
self.sock.sendto(u'%s已經離開了'%str(address),c)
print(str(address)+u'已經退出')
exceptException,e:
printstr(e)
raise

if__name__=="__main__":
udpServer=UdpServer()
udpServer.listen_client()

——————————華麗的分割線——————————
socket-udp-client.py:
#-*-coding:utf8-*-

importsys
importthreading
importtime
reload(sys)
sys.setdefaultencoding('utf-8')

importsocket

HOST="127.0.0.1"
PORT=9555
#BEAT_PORT=43278
BEAT_PERIOD=5


classUdpClient(object):
def__init__(self):
self.clientsock=socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
self.HOST=HOST
self.ADDR=(HOST,PORT)
self.clientsock.sendto(u'請求建立鏈接',self.ADDR)
self.recvtrs=threading.Thread(target=self.recvmsg)
self.recvtrs.start()
self.hearttrs=threading.Thread(target=self.heartbeat)
self.hearttrs.start()

defsendmsg(self):
whileTrue:
data=raw_input(">:")
ifnotdata:
break
self.clientsock.sendto(data.encode('utf-8'),self.ADDR)
ifdata.upper()=='QUIT':
self.clientsock.close()
break

defheartbeat(self):
whileTrue:
self.clientsock.sendto('HEARTBEAT',self.ADDR)
time.sleep(BEAT_PERIOD)

defrecvmsg(self):
whileTrue:
recvData,addr=self.clientsock.recvfrom(1024)
ifnotrecvData:
break
print(u'從%s收到信息：%s'%(self.HOST,recvData.decode('utf8')))if__name__=="__main__":
udpClient=UdpClient()
udpClient.sendmsg()

⑻ 如何實現Python多進程http伺服器

埠只能綁定一個進程。
1 換成線程實現 SocketServer.ThreadingTCPServer
2 主進程調度分發。主進程收到埠請求後通過進程間通信讓其他進程工作。
我想要用 python 的 multiprocessing 模塊實現一個多進程多線程的 http 伺服器，伺服器會使用進程池 Pool 創建多個子進程，然後每個子進程再用 socketserver 創建多線程的 http 伺服器，但是現在我遇到一個問題，就是伺服器運行以後，只有第一個子進程可以處理 http 連接，如何做到讓每一個子進程都可以處理連接？
備註：通過 getpid 可以看到每次接受請求的都是同一個子進程
# Python 3import os, socketserver, signal, sysfrom multiprocessing import Poolclass MyTCPHandler(socketserver.BaseRequestHandler):

def handle(self):
self.data = self.request.recv(1024)
respone = b'HTTP/1.1 200 OK\r\n\r\nOK%d' % os.getpid()
self.request.sendall(respone)def httpd_task():
socketserver.ThreadingTCPServer.allow_reuse_address = True
server = socketserver.ThreadingTCPServer(('0.0.0.0', 80), MyTCPHandler) try:
server.serve_forever() except: pass
server.server_close()if __name__=='__main__':

p = Pool(4) for i in range(4):
p.apply_async(httpd_task)
p.close()
p.join()

導航:首頁 > 編程語言 > python3sendall

python3sendall

與python3sendall相關的資料