python接收消息

『壹』 我想用python自動接收微信公眾平台接收到的消息，根據消息內容再做出回復。不知道怎麼搞

現在都有微信公眾平台的智能機器人了啊，你到千呼萬喚微信公眾平台導航網站看下，在微信網路裡面有現有的源碼下載，照著教程設置就可以了！

『貳』 請教使用python作為TCP server，同時接收兩個clients傳來的數據

增加一個非同步隊列.將client的消息都傳入隊列中. python的tcp server 從隊列里的讀取消息即可

『叄』 python 伺服器收到一條信息,返回多條消息

具體原因如下：
消息發送端發送消息出去後沒有結果返回，如果只是單純發送消息，當然沒有問題了，但是在實際中，常常會需要接收端將收到的消息進行處理之後，返回給發送端。

『肆』 如何通過python的itchat庫收到有人加入群聊的新消息

作者：LittleCoder鏈接：/question/51160419/answer/124460961來源：知乎著作權歸作者所有，轉載請聯系作者獲得授權。普通的網頁點擊：1.建議通過瀏覽器或者Wireshark分析消息的交互。2.之後通過requests模擬。由於沒有具體的網址，我沒有法給出具體的代碼。給公眾號發送特定的問題：1.建議使用Python的 API（pipinstallitchat）2.由於沒有提供Python版本，我這里給出兼容的解決方案#coding=_IN_MP_DICT={u'學校 公眾號':u'學校簽到口令',u'公司 公眾號':u'公司簽到口令',}defget_day(timeGap):returnint(time.strftime('%y%m%d',time.localtime(time.time()+timeGap)))NEXT_SIGN_DATE=get_day(60*60*24)defsign_in_thread():'''簽到線程如果尚未到需要簽到的日期，則繼續循環如果到了需要簽到的日期，則完成兩個公眾號的簽到，並更新日期'''while1:ifget_day

『伍』 python怎麼編程獲取網頁的信息發到手機上

要看你是專業程序員還是編程愛好者。如果是前者。通常這樣問有些大，就是其實它挺復雜一個平台。包括採集，過濾，批量下發等。可能還需要手機客戶端。

如果你只是個人使用的編程愛好者。兩上途徑：
1.python獲取信息後，放在網站上，手機去拿
2.python獲取信息後，以短消息方式發到手機。

當然也可以混合方式。就是python獲取信息放在一個位置上，再通過手機軟體或者是短消息通知手機去拿來。

至於python如何獲取信息。這個回答挺多的。你搜索一下。作為練習python的作業是可以的。

『陸』 如何用Python編寫一個聊天室

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

暫時先給出兩種版本的,tcp+udp

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

別外還有websocket版本，這個是有web界面的和基本web服務的，如果需要的話，我會把基本的代碼貼一版上來。

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可以接收到釘釘群的消息嗎

估計不行，釘釘群的信息應該是加過密的。

『捌』 如何用C++或者python實現接收客戶端發送的post請求

一個http請求包括三個部分，分別為請求行，請求報頭（請求頭），消息主體（請求體），類似以下這樣：

{
「args」:{},
「data」:「」,
「files」:{
「file」:「Helloworld!」
},
「form」:{},
「headers」:{……
「Content-Type」:「multipart/form-data;boundary=」,
……
},
「json」:null,
……
}
---------------------
作者：weixin_40283480
來源：CSDN
原文：https://blog.csdn.net/weixin_40283480/article/details/79208413
版權聲明：本文為博主原創文章，轉載請附上博文鏈接！

『玖』 python sock.sendto消息怎麼看

# -*- coding: cp936 -*-
'''''
建立一個python server，監聽指定埠，
如果該埠被遠程連接訪問，則獲取遠程連接，然後接收數據，
並且做出相應反饋。
'''
if __name__=="__main__":
import socket
print "Server is starting"
sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.bind(('localhost', 8001)) #配置soket，綁定IP地址和埠號
sock.listen(5) #設置最大允許連接數，各連接和server的通信遵循FIFO原則
print "Server is listenting port 8001, with max connection 5"
while True: #循環輪詢socket狀態，等待訪問

connection,address = sock.accept()
try:
connection.settimeout(50)
#獲得一個連接，然後開始循環處理這個連接發送的信息
'''''
如果server要同時處理多個連接，則下面的語句塊應該用多線程來處理，
否則server就始終在下面這個while語句塊里被第一個連接所佔用，
無法去掃描其他新連接了，但多線程會影響代碼結構，所以記得在連接數大於1時
下面的語句要改為多線程即可。
'''
while True:
buf = connection.recv(1024)
print "Get value " +buf
if buf == '1':
print "send welcome"
connection.send('welcome to server!')
elif buf!='0':
connection.send('please go out!')
print "send refuse"
else:
print "close"
break #退出連接監聽循環
except socket.timeout: #如果建立連接後，該連接在設定的時間內無數據發來，則time out