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相关的资料