phpはsocketとゲームサーバ間の小さなデータ量通信を利用する
2525 ワード
php利用のフレームワークはlaravel
せいぎょそうち
25198:ユーザid,type:ゲームサーバと約束したタイプ,value:数値
モデル:Tcp.php
モデル内のsendNoti関数からパッケージ化されたパッケージがあることが分かった
パッケージの場所はApplibsにあります
ダウンロード:https://github.com/yangshengquan87/socket.git
せいぎょそうち
25198:ユーザid,type:ゲームサーバと約束したタイプ,value:数値
public function testtcp(){
$aa = (new Tcp())->sendNoti(25198, [['type'=>0, 'value'=>10000]]);
}
モデル:Tcp.php
3, "usec"=>10 )); //
socket_set_option($socket,SOL_SOCKET,SO_SNDTIMEO,array("sec"=>2, "usec"=>10 )); // 2
if ($socket === false) {
return false;
}
$result = socket_connect($socket, $ip, $port);
if($result === false) {
return false;
}
$r = socket_write($socket, $send_data, strlen($send_data));
$buffer = socket_read($socket,1024,PHP_BINARY_READ);
if($buffer){
socket_close($socket);
return true;
}
if($r){
socket_close($socket);
return true;
}else{
socket_close($socket);
return false;
}
socket_close($socket);
return false;
}
static function packData($data, $msgId){
$len = strlen($data);
$send_data = pack("l",strlen($data) + 4, $msgId, $data);
return $send_data;
}
static function unpackData($data){
$r = unpack("lhead/lmsgId/a*body", $data);
return $r;
}
public function sendNoti($userId, $notiData = array()){
if(empty($notiData)) return true;
$noti = new RECHARGE_NOTI();
$noti->set_UserID($userId);
foreach ($notiData as $k => $v) {
$atti = new Modify_Atti();
$atti->set_Type(intval($v['type']));
$atti->set_Value(strval($v['value']));
$noti->set_attrList($k, $atti);
}
$str = $noti->SerializeToString();
$pdata = Tcp::packData($str, protoID::RECHARGE_NOTI_ID);
return Tcp::send($pdata);
}
}
モデル内のsendNoti関数からパッケージ化されたパッケージがあることが分かった
パッケージの場所はApplibsにあります
ダウンロード:https://github.com/yangshengquan87/socket.git