好，經(jīng)過上一篇不權(quán)威的講解，大家已經(jīng)能輕易地讓客戶端和服務(wù)端連接起來了。

?

但是，僅僅是連接了，可它們倆不說話不交流，那游戲就玩不起來了，玩不起來那我就賺不到錢..啊不是，玩不起來那玩家就不能開心了，錢是…啊不！玩家是最重要的嘛~不能讓玩家不開心（小若：好好好，看出來了，錢是最重要的是吧）

?

好~！這次木頭就和大家一起見證客戶端和服務(wù)端的第一次交談吧~！

?

聲明：

本教程基于FireFly1.2.2版本、Python2.7版本。

本教程面向Python和FireFly初學(xué)者中的初學(xué)者（比如我）

本教程由笨木頭花心貢獻(xiàn)，花心？不，是用心~！

轉(zhuǎn)載請注明原文地址：http://www.benmutou.com/blog/archives/727

?

1.?Pythone?struct模塊

Struct模塊主要是用來對數(shù)據(jù)進(jìn)行打包和解包的，和LiberateFactory不一樣，LiberateFactory已經(jīng)說了，是協(xié)議工廠，當(dāng)然就主要是對協(xié)議進(jìn)行封裝和解析。而struct是對更底層的數(shù)據(jù)操作，是把數(shù)據(jù)打包成二進(jìn)制的形式，然后在網(wǎng)絡(luò)中傳輸。解包也一樣，把二進(jìn)制形式的數(shù)據(jù)解包成Pythone需要或者說比較好識別的格式。

反正，總之，struct模塊是對數(shù)據(jù)進(jìn)行打包和解包的，解釋完畢~

?

2.?可以發(fā)送請求的客戶端（client.py)

我們要修改客戶端，以便它可以發(fā)送數(shù)據(jù)給服務(wù)端。

#coding:utf8''' Created on 2013-10-8@author: 笨木頭_鐘迪龍 www.benmutou.com '''from socket import AF_INET, SOCK_STREAM, socket import struct def sendData(sendstr, commandId): HEAD_0 = chr(0) # 協(xié)議頭0 HEAD_1 = chr(0) # 協(xié)議頭1 HEAD_2 = chr(0) # 協(xié)議頭2 HEAD_3 = chr(0) # 協(xié)議頭3 ProtoVersion = chr(0) # 協(xié)議頭版本號 ServerVersion = 0 # 服務(wù)器版本號 sendstr = sendstrdata = struct.pack('!sssss3I', HEAD_0, HEAD_1, HEAD_2, HEAD_3,\ ProtoVersion, ServerVersion, len(sendstr) + 4, commandId)senddata = data + sendstr return senddataif __name__ == '__main__': HOST = "localhost" # 服務(wù)端地址 PORT = 1000 # 服務(wù)端端口 ADDR = (HOST, PORT)client = socket(AF_INET, SOCK_STREAM) # 創(chuàng)建socket，TCP client.connect(ADDR) # 連接服務(wù)器 client.sendall(sendData('hello server', 1))# 發(fā)送數(shù)據(jù)給服務(wù)器 while True: pass

覺得復(fù)雜嗎？其實就多了一個sendData函數(shù)而已。（小若：但是它很復(fù)雜！）

?

2.1?協(xié)議頭部信息

我們先來解釋一下協(xié)議頭、協(xié)議頭版本號、服務(wù)器版本號。我也沒有深入了解，但就這么看，我唯一能想到的就是：這些東西是用來檢測客戶端和服務(wù)端是否同步的。

?

經(jīng)過我“深入”FireFly源碼之后，發(fā)現(xiàn)了確實有這么一個用途，當(dāng)服務(wù)端的協(xié)議工廠接收到數(shù)據(jù)時，會先判斷這些協(xié)議頭和版本號是否正確，不正確的話，是不會往下繼續(xù)執(zhí)行的。

由于這是入門教程，就不一層層地貼這些代碼了，也不繼續(xù)深入了，因為它不是本文的重點。

?

重點是struct的pack函數(shù)，大家可以看看這篇文章：

http://www.cnblogs.com/coser/archive/2011/12/17/2291160.html

只看第1、2點就暫時夠用了。

?

于是，上面代碼里的pack函數(shù)就是把4個協(xié)議頭、協(xié)議頭版本號、服務(wù)器版本號、發(fā)送的數(shù)據(jù)長度、命令碼打包。

這樣打包后的數(shù)據(jù)作為一個數(shù)據(jù)的頭部信息，顧名思義，頭部信息就是記錄一次發(fā)送數(shù)據(jù)的主要信息，比如長度、版本、命令碼。（小若：廢話！上面都說了把這些東西打包了）

?

然后我們看看這句代碼：senddata?=?data?+?sendstr。

為什么發(fā)送的數(shù)據(jù)字符串不需要參與打包呢？我也很白癡地試了一下把數(shù)據(jù)字符串也一起參與打包，結(jié)果是一樣的。

于是，據(jù)我所知，字符串可以直接傳輸（字節(jié)流），不需要再進(jìn)行什么打包了。

?

2.2?發(fā)送數(shù)據(jù)

客戶端要發(fā)送數(shù)據(jù)給服務(wù)端很簡單：client.sendall(sendData(‘hello?server’,?1))

這句代碼的意思是，發(fā)送字符串‘hello?server’給服務(wù)端，命令碼是1。

結(jié)合之前說的，命令碼1會參與到數(shù)據(jù)頭部信息一起打包，而字符串’hello?server’是直接和打包后的數(shù)據(jù)連接的，不需要參與打包。

?

2.3?為什么數(shù)據(jù)長度要+4？

不知道大家會不會有個疑問，就是打包的時候這個參數(shù)：len(sendstr)?+?4

為什么長度要+4，木頭我是弄不明白了，我查看了源碼，在解析頭部信息的時候，獲取數(shù)據(jù)長度值時，又減去了4。這看起來有點多此一舉，據(jù)我目前的研究，還沒法知道原因，希望高手支招。

?

3.?可以接收請求的服務(wù)端(server.py)

服務(wù)端的改動也很小，看代碼：

#coding:utf8 ''' Created on 2013-10-8@author: 笨木頭_鐘迪龍 www.benmutou.com '''import os import sysfrom firefly.netconnect.protoc import LiberateFactory from firefly.utils import services from twisted.internet import reactor from twisted.python import logif os.name!='nt':#對系統(tǒng)的類型的判斷，如果不是NT系統(tǒng)的話使用epoll from twisted.internet import epollreactor epollreactor.install()def command_1(_conn, data): print '我跟你說，別以為你的命令碼正確了，我只是不想讓你錯誤而已~！' print dataif __name__ == '__main__': # 有了它，就能看到日志的輸出 log.startLogging(sys.stdout)# 服務(wù)，我個人理解為對客戶端數(shù)據(jù)的邏輯處理service = services.CommandService("testService")# 添加一個命令碼處理service.mapTarget(command_1)# 處理數(shù)據(jù)封裝、協(xié)議頭封裝、分包、粘包處理的類factory = LiberateFactory();# 關(guān)于twisted的知識，暫時忽略吧，我也還沒研究，是一個Python的網(wǎng)絡(luò)框架reactor = reactor#添加服務(wù)通道factory.addServiceChannel(service)# 開始監(jiān)聽端口reactor.listenTCP(1000, factory);reactor.run()

最明顯的是多了一個command_1函數(shù)，這個函數(shù)就是用來處理命令碼為1的請求的，怎么處理？大家還記得service吧？Service就是用來處理這些請求邏輯的。

?

看看下面這兩句新增的代碼：

#?服務(wù)，我個人理解為對客戶端數(shù)據(jù)的邏輯處理

????service?=?services.CommandService(“testService”)

????#?添加一個命令碼處理

????service.mapTarget(command_1)

?

首先，我們把Service改為了CommandService，這就說明了兩個問題。第一，CommandService是專門用來處理命令碼這種類型請求的服務(wù)；第二，Service是可以自定義的，這樣就可以按我們的需要進(jìn)行自定義處理，而CommandService就是其中一個自定義的服務(wù)。

?

然后，我們只要用service的mapTarget函數(shù)就能給service新增一個處理邏輯，在這里我們就說是添加了一個命令碼的處理。

這里把函數(shù)命名為command_1是有講究的，mapTarget會把下劃線’_’后面的數(shù)值作為key值，函數(shù)對象作為value值，保存起來。當(dāng)客戶端發(fā)來請求時，就會根據(jù)命令碼找到對應(yīng)的函數(shù)對象。

?

怎么樣？服務(wù)端就是這么處理的命令碼的，很簡單吧，具體的代碼我就不貼了，因為本文是點到即止的入門教程。

?

4.?試驗一下

大家現(xiàn)在就運行服務(wù)端，然后運行客戶端，如果能看到類似以下的日志，那么就恭喜你了，你成功了：

2013-10-08?22:43:59+0800?[-]?Log?opened.

2013-10-08?22:43:59+0800?[-]?LiberateFactory?starting?on?1000

2013-10-08?22:43:59+0800?[-]?Starting?factory?<firefly.netconnect.protoc.LiberateFactory?instance?at?0x0000000002FEA588>

2013-10-08?22:44:02+0800?[firefly.netconnect.protoc.LiberateFactory]?Client?0?login?in.[127.0.0.1,20708]

2013-10-08?22:44:02+0800?[LiberateProtocol,0,127.0.0.1]?call?method?command_1?on?service[single]

2013-10-08?22:44:02+0800?[LiberateProtocol,0,127.0.0.1]?我跟你說，別以為你的命令碼正確了，我只是不想讓你錯誤而已~！

2013-10-08?22:44:02+0800?[LiberateProtocol,0,127.0.0.1]?hello?server

?

5.?再來串一遍

如果你是一個正常的、正宗的、不是假冒的初學(xué)者，那么，你現(xiàn)在一定是這樣一種狀態(tài)：代碼運行成功了，結(jié)果也正確了，好像知道了是怎么回事了，但是又沒辦法把整個流程順暢地回憶起來。

?

那就對了，我們把客戶端發(fā)送數(shù)據(jù)到服務(wù)端接收并處理數(shù)據(jù)的流程再過一遍，這樣就清楚了：

1）?客戶端發(fā)送數(shù)據(jù)：?client.sendall(sendData(‘hello?server’,?1))

2）?發(fā)送數(shù)據(jù)之前先把4個協(xié)議頭、協(xié)議頭版本號、服務(wù)器版本號、數(shù)據(jù)長度+4、命令碼打包，然后再加上數(shù)據(jù)字符串’hello?server’，整個要發(fā)送的數(shù)據(jù)就準(zhǔn)備好了，然后發(fā)送，至于怎么發(fā)送的，我們不管，這是socket的事情。

3）?經(jīng)過某些未知的步驟，我們的數(shù)據(jù)來到了LiberateFactory協(xié)議工廠，它負(fù)責(zé)解析數(shù)據(jù)，把命令碼和數(shù)據(jù)內(nèi)容拆分好，然后傳給CommandService對象

4）?CommandService根據(jù)命令碼找到對應(yīng)的函數(shù)，然后執(zhí)行函數(shù)

5）?完成。

?

當(dāng)然，也許中間有某些步驟被我不經(jīng)意間忽略了（也許是故意的，也許是能力問題），不過，作為初步了解客戶端和服務(wù)端的通信過程，也已經(jīng)足夠了。

?

再次聲明，我也是剛接觸FireFly和Python，請帶著批判的眼光看待本文，本文為木頭個人學(xué)習(xí)記錄，僅供參考。

總結(jié)

以上是生活随笔為你收集整理的[笨木头FireFly 02]入门篇_客户端发送请求，服务器处理请求的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。