这篇文章主要介绍了php使用workman框架实现socket服务以及连接客户端,本文列举了详细的过程和代码展示,能够帮助你学习,需要的朋友可以参考下
- 1. 解决什么问题，为什么要用workman socket服务
都知道游戏安装包很大，渠道推广时，需要对游戏进行分包处理，而PHP命令模式是单进程，一次只能分一次包，故这里用workman实现socket服务开启多进程，对游戏进行分包处理（一个进程处理一个分包，多个进程可以同时处理多个分包）
- 2. 服务端代码
server.php
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; }; /** * 响应结果. *<span style="color:transparent">来源gaodai#ma#com搞*!代#%^码网</span> * @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\n"); } // 替换\,否则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\n"); } // 从新拼接文件 $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\n"); } $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();
- 3. 客户端代码
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($ar
以上就是php使用workman框架实现socket服务以及连接客户端的详细内容，更多请关注gaodaima搞代码网其它相关文章！
搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：php使用workman框架实现socket服务以及连接客户端 
