.jpg)
onReceive
接收到數(shù)據(jù)時(shí)回調(diào)此函數(shù)，發(fā)生在worker進(jìn)程中。函數(shù)原型：? ? ? ? ? （推薦學(xué)習(xí)： swoole視頻教程）
function?onReceive(swoole_server?$server,?int?$fd,?int?$reactor_id,?string?$data);
$server，Server對(duì)象
$fd，TCP客戶端連接的唯一標(biāo)識(shí)符
$reactor_id，TCP連接所在的Reactor線程ID
$data，收到的數(shù)據(jù)內(nèi)容，可能是文本或者二進(jìn)制內(nèi)容
關(guān)于$fd和$reactor_id 詳細(xì)的解釋
未開啟自動(dòng)協(xié)議選項(xiàng)，onReceive單次收到的數(shù)據(jù)最大為64K
開啟了自動(dòng)協(xié)議處理選項(xiàng)，onReceive將收到完整的數(shù)據(jù)包，最大不超過 package_max_length
支持二進(jìn)制格式，$data可能是二進(jìn)制數(shù)據(jù)
使用底層提供的open_eof_check/open_length_check/open_http_protocol，可以保證數(shù)據(jù)包的完整性
不使用底層的協(xié)議處理，在onReceive后php代碼中自行對(duì)數(shù)據(jù)分析，合并/拆分?jǐn)?shù)據(jù)包。
例如：代碼中可以增加一個(gè) $buffer = Array()，使用$fd作為key，來保存上下文數(shù)據(jù)。 每次收到數(shù)據(jù)進(jìn)行字符串拼接，$buffer[$fd] .= $data，然后在判斷$buffer[$fd]字符串是否為一個(gè)完整的數(shù)據(jù)包。
默認(rèn)情況下，同一個(gè)fd會(huì)被分配到同一個(gè)Worker中，所以數(shù)據(jù)可以拼接起來。使用dispatch_mode = 3時(shí)。
請(qǐng)求數(shù)據(jù)是搶占式的，同一個(gè)fd發(fā)來的數(shù)據(jù)可能會(huì)被分到不同的進(jìn)程。所以無法使用上述的數(shù)據(jù)包拼接方法
關(guān)于粘包問題如SMTP協(xié)議，客戶端可能會(huì)同時(shí)發(fā)出2條指令。在Server中可能一次性收到，這時(shí)應(yīng)用層需要自行拆包。SMTP是通過rn來分包的，所以業(yè)務(wù)代碼中需要 explode(“rn”, $data)來拆分?jǐn)?shù)據(jù)包。
如果是請(qǐng)求應(yīng)答式的服務(wù)，無需考慮拆分?jǐn)?shù)據(jù)的問題。原因是客戶端在發(fā)起一次請(qǐng)求后，必須等到服務(wù)器端返回當(dāng)前請(qǐng)求的響應(yīng)數(shù)據(jù)，才會(huì)發(fā)起第二次請(qǐng)求，不會(huì)同時(shí)發(fā)送2個(gè)請(qǐng)求
.png)
