php使用workman框架实现socket服务以及连接客户端
吾爱主题
阅读：138
2021-11-19 16:09:00
评论：0
- 1. 解决什么问题，为什么要用workman socket服务
都知道游戏安装包很大，渠道推广时，需要对游戏进行分包处理，而PHP命令模式是单进程，一次只能分一次包，故这里用workman实现socket服务开启多进程，对游戏进行分包处理（一个进程处理一个分包，多个进程可以同时处理多个分包）
- 2. 服务端代码
server.php
?| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 | <?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\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
?| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107 108 109 110 111 112 113 114 115 116 117 118 | <?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); } |
- 4. 使用
a. 开启服务
php server.php start //可以看到开启了多个进程
b. 客户端连接
php client.php //从代码知道，里头用了循环，可以多次连接服务，同时发送数据，服务端会把结果返回
到此这篇关于php使用workman框架实现socket服务以及连接客户端的文章就介绍到这了,更多相关php使用workman内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！
原文链接：https://blog.csdn.net/mengzuchao/article/details/81213027
声明
1.本站遵循行业规范，任何转载的稿件都会明确标注作者和来源；2.本站的原创文章，请转载时务必注明文章作者和来源，不尊重原创的行为我们将追究责任；3.作者投稿可能会经我们编辑修改或补充。
