php 는 workman 프레임 워 크 를 사용 하여 socket 서비스 와 연결 클 라 이언 트 를 실현 합 니 다.
게임 설치 패키지 가 매우 크다 는 것 을 잘 알 고 있 습 니 다.채널 을 홍보 할 때 게임 을 하 도 급 처리 해 야 합 니 다.PHP 명령 모드 는 단일 프로 세 스 이 고 한 번 에 한 번 만 하 도 급 으로 나 눌 수 있 습 니 다.그래서 여기 서 workman 으로 socket 서 비 스 를 실현 하여 다 중 프로 세 스 를 시작 하고 게임 을 하 도 급 처리 합 니 다(한 프로 세 스 가 하 나 를 처리 하고 여러 프로 세 스 가 여러 하 나 를 동시에 처리 할 수 있 습 니 다)
서버 코드
server.php
<?php
/**
* . die exit .
*
* User: yzm
* Data: 2018/1/16
*/
require_once './vendor/workerman/workerman/Autoloader.php';
require_once './Lib/Function.php';
require_once __DIR__ . '/Lib/Db.php';
require_once __DIR__ . '/Lib/DbConnection.php';
require_once __DIR__ . '/Config/Db.php';
use Workerman\Worker;
// #### create socket and listen 1234 port ####
$tcp_worker = new Worker("tcp://0.0.0.0:9998");
/**
* .
*/
define('REP_SUCCESS', 0); //
define('REP_FAIL', -1); //
define('REP_FAIL_NO_COMPLETED', 1); //
// 16 processes, cpu
$tcp_worker->count = 16;
$msg = '';
define('ORGPKG', '/Volumes/VMware\ Shared\ Folders/orgpkg/');
define('DISTPKG', '/Volumes/VMware\ Shared\ Folders/');
//define('SYS_IP', '39.108.223.28');
define('SYS_IP', '120.92.142.115');
define('IOS_URL','http://ios.package.tonguu.cn/');
// Emitted when new connection come
$tcp_worker->onConnect = function ($connection) {
$connection->sized = 0;
// xcode
$certMobile = '/mnt/www/DIVIDE_PKG/Cert/%d/mslabEnt.mobileprovision'; //
$shell = "/mnt/www/DIVIDE_PKG/Lib/dividePkg/resign sign -ipapath %s -destpath %s -pppath %s -agentid %s";
$connection->shell = $shell;
$connection->pppath = $certMobile;
echo date("Y-m-d H:i:s") . " connect!" . getclientip() . PHP_EOL;
};
/**
* .
*
* @author yzm
*/
function resonse($conn, $msg, $error = REP_FAIL, $data = [])
{
$res = ['msg' => $msg, 'error' => intval($error)];
if (!empty($data)) {
$res['content'] = $data;
}
debug($res);
// JSON
$rst = json_encode($res);
$conn->send($rst);
}
// Emitted when data received
$tcp_worker->onMessage = function ($connection, $data) {
set_time_limit(0);
ini_set('memory_limit', -1);
$db = \Lib\Db::instance('btmox');
$data = @json_decode($data, true);
try{
if (empty($data['authId'])) {
throw new \Exception(' ');
}
//1. ios
$iosPkg = $db
->select('a.id,a.vid,a.filename,a.agent,d.pinyin,b.name,c.package_name')
->from('cy_ct_ios_package a')
->where("a.status=0 AND c.is_send=1")
->leftJoin('cy_ct_ios_mobileversion b','b.id=a.m_v_id')
->rightJoin('cy_ct_ios_version c','c.id=a.vid')
->leftJoin('cy_game d','d.id=c.game_id')
->orderByASC(['a.create_time'])->query();
if(empty($iosPkg)) throw new \Exception(' '.PHP_EOL);
//2.
foreach($iosPkg as $one){
try{
// ‘ '
$db->update('cy_ct_ios_package')->cols([
'status' => 2,
])->where("id=".$one['id'])->query();
$filename = $one['pinyin'];
//
$verId = @$one['vid'];
$agent = @$one['agent'];
$location = isset($data['location']) ? $data['location'] : 1;
$authId = @intval($data['authId']); //
if (empty($verId) || empty($agent)) {
throw new \Exception(" :".$one['id']." 、 \r
");
}
// \, PHP
$orgPkg = str_replace('\\', '', ORGPKG) . "{$filename}.ipa";
debug($one['id'].' :' . $orgPkg);
debug($one['id'].' :' . is_file($orgPkg));
if (!is_file($orgPkg)) {
throw new \Exception(" :".$one['id']." -$orgPkg\r
");
}
//
$orgPkg = ORGPKG . "{$filename}.ipa";
//
$distPkgPath = getDistPkgPath($location);
$distPkg = $distPkgPath . "$filename/vers_{$verId}/{$filename}_$agent.ipa";
debug(' :' . $distPkg);
if (file_exists($filename)) {
@unlink($filename);
}
//
$certMobile = sprintf($connection->pppath, $authId);
//
list($msg, $code) = dividePkg($connection->shell, $orgPkg, $distPkg, $agent, $certMobile);
debug('$code' . $code);
if ($code != 0) {
throw new \Exception(" :".$msg."\r
");
}
$distPkg = str_replace($distPkgPath, '', $distPkg);
}catch (\Exception $ex){
debug($ex->getMessage());
$code = -1;
$msg = $ex->getMessage();
}
//3. , ,
$status = $code == 0 ? 1 : 2;
$sdata['status'] = $status;
$sdata['message'] = $msg;
if($status == 1){
$sdata['url'] = IOS_URL.$distPkg;
}
$db->update('cy_ct_ios_package')->cols($sdata)->where("id=".$one['id'])->query();
}
resonse($connection, $msg,$code);
}catch (\Exception $ex){
resonse($connection, $ex->getMessage());
}
};
// Emitted when new connection come
$tcp_worker->onClose = function ($connection) {
echo date("Y-m-d H:i:s") . " closed!" . PHP_EOL;
};
Worker::runAll();
클 라 이언 트 코드client.php
<?php
/**
* socket .
*
* @author yzm
*
* @param $socket
* @param bool|true $isDividePkg
* @return array|null|string
*/
function socketRead($socket, $isDividePkg = true)
{
$rst = null;
$buf = socket_read($socket, 8192);
if ($isDividePkg) {
$_buf = @json_decode($buf, true);
$rst = !empty($_buf) ? [$_buf['error'], $_buf['msg'], @$_buf['content']] : $buf;
} else {
$rst = $buf;
}
return $rst;
}
/**
* socket .
*
* @param $args
* @return bool
* @throws \Exception
*/
function sendSocket($args)
{
set_time_limit(0);
ini_set('memory_limit', -1);
$type = isset($args['type']) ? $args['type'] : 0;
if (!$type) throw new \Exception(' ');
$port = 9998;
$ip = "127.0.0.1";
// socket
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
if ($socket <= 0) throw new \Exception(' socket ,REASON:' . socket_strerror($socket));
try {
//
$result = socket_connect($socket, $ip, $port);
if ($result < 0 || is_null($result) || !$result) throw new \Exception(' ,REASON:' . socket_strerror($result));
$in = json_encode($args);
//
if (!socket_write($socket, $in, strlen($in))) throw new \Exception(' ,REASON:' . socket_strerror($socket));
// socket
list($error, $msg, $data) = socketRead($socket);
if ($type != 3 && $error != 0) throw new \Exception('104 ,REASON:' . $msg);
// socket
socket_close($socket);
switch ($type) {
case 2: //
$rst = $data['url'];
break;
case 3: //
if ($error == -1) {
throw new \Exception(' ,REASON:' . $msg);
}
$rst = $error;
break;
default:
$rst = true;
break;
}
} catch (\Exception $ex) {
// socket
@socket_close($socket);
throw new \Exception($ex->getMessage());
}
return $rst;
}
/**
* . die exit .
*
* User: yzm
* Data: 2018/1/16
*/
require_once './Lib/Function.php';
$i=0;
while ($i<30){
try{
$data['type'] = 1;
$data['authId'] = 2;
$data['location'] = 1;
sendSocket($data);
}catch (\Exception $ex){
echo $ex->getMessage();
}
$i++;
sleep(5);
}
사용 서비스 개시php server.php start //여러 프로 세 스 가 열 린 것 을 볼 수 있 습 니 다.
b.클 라 이언 트 연결
php client.php //코드 를 통 해 알 수 있 듯 이 안에 순환 을 사용 하여 여러 번 서 비 스 를 연결 할 수 있 고 데 이 터 를 보 내 면 서버 에서 결 과 를 되 돌려 줍 니 다.
php 가 workman 프레임 워 크 를 사용 하여 socket 서 비 스 를 실현 하고 클 라 이언 트 를 연결 하 는 것 에 관 한 이 글 은 여기까지 소개 되 었 습 니 다.더 많은 관련 php 가 workman 콘 텐 츠 를 사용 하 는 것 은 우리 의 이전 글 을 검색 하거나 아래 의 관련 글 을 계속 조회 하 시기 바 랍 니 다.앞으로 많은 응원 바 랍 니 다!
이 내용에 흥미가 있습니까?
현재 기사가 여러분의 문제를 해결하지 못하는 경우 AI 엔진은 머신러닝 분석(스마트 모델이 방금 만들어져 부정확한 경우가 있을 수 있음)을 통해 가장 유사한 기사를 추천합니다:
Laravel - 변환된 유효성 검사 규칙으로 API 요청 제공동적 콘텐츠를 위해 API를 통해 Laravel CMS에 연결하는 모바일 앱(또는 웹사이트) 구축을 고려하십시오. 이제 앱은 CMS에서 번역된 콘텐츠를 받을 것으로 예상되는 다국어 앱이 될 수 있습니다. 일반적으로 ...
텍스트를 자유롭게 공유하거나 복사할 수 있습니다.하지만 이 문서의 URL은 참조 URL로 남겨 두십시오.
CC BY-SA 2.5, CC BY-SA 3.0 및 CC BY-SA 4.0에 따라 라이센스가 부여됩니다.