php socket服務端和OC客戶端

2019-11-09 17:09:41
字體：大中小
來源：轉載
供稿：網友
轉自：http://www.cnblogs.com/lost-1987/articles/3225500.html
socketserver.class.php
<?php/** * Created by JetBrains PhpStorm. * User: lost * Date: 13-6-24 * Time: 下午1:53 * To change this template use File | Settings | File Templates. */final class SocketServer extends SocketBase{    PRotected  $max_connection_limit;    protected  $socketclients;    protected  $clientcount;//如果接收的數據比128大 則會分多次進行傳輸 參考readFromClient 中用while循環來接受數據,如果接收的數據小于這里設置的大小,//則readFromClient中就無需使用循環,可使用if,如果不確定數據大小的話還是使用while
protected   $bufsize=128;    protected  $endString='/0';    protected  $run_mode ;    protected  $clientInfo;    static $socketServer;    private function __construct(){}    public static function getInstance(){        if(is_null(self::$socketServer)){            self::$socketServer = new SocketServer();        }        return self::$socketServer;    }    public function changeRunMode($mode=self::_REUSEADDR){            $this->run_mode = $mode;    }    public function changeBuffSize($size=128){            $this->bufsize = $size;    }    public function changeEndString($endString='/0'){            $this->endString = $endString;    }    private function initProperties($host,$port,$common_protocol,$type,$protocol,$timeout=60,$max_connection_limit=1){        set_time_limit($timeout);        $this -> host = $host;        $this -> port = $port;        $this -> common_protocol = $common_protocol;        $this -> type = $type;        $this -> protocol = $protocol;        $this -> timeout = $timeout;        $this -> max_connection_limit = $max_connection_limit;        $this -> clientcount = 0;        $this -> socketclients = array();        $this -> run_mode = self::_REUSEADDR;    }    /**     * @param $host     * @param $port     * @param $protocol     * @param $type     * @param $common_protocol     * @param $timeout     * @param $connection_count     * @return resource     */    public function createSocketServer($host,$port,$protocol,$type,$common_protocol,$timeout,$max_connection_limit){        $common_protocol = getprotobyname($common_protocol);        $this->initProperties($host,$port,$protocol,$type,$common_protocol,$timeout,$max_connection_limit);        $this->socket = socket_create($protocol,$type,$common_protocol);return $this->socket;    }    public function run(){        error_log('deamon is running ~');        socket_setopt($this->socket,SOL_SOCKET,$this->run_mode,1);        socket_bind($this->socket,$this->host,$this->port);         socket_listen($this->socket,$this->max_connection_limit);while(1){            $readFD = array($this->socket);            for($i=0;$i<$this->clientcount ; $i++){                if(isset($this->socketclients[$i]))                $readFD[] = $this->socketclients[$i];            }            //select 多路復用 在沒有任何客戶端數據的情況下 應該利用阻塞停止CPU資源的消耗            if(FALSE === @socket_select($readFD,$this->null,$this->null,0))$this->shutdown();            //select 多路復用 在沒有任何客戶端數據的情況下 應該利用阻塞停止CPU資源的消耗            else if(@socket_select($readFD,$this->null,$this->null,0)<1)                continue;            if(in_array($this->socket,$readFD)){//檢查是否有新連接                    $this -> accept_connection(); //接收新連接            }            //遍歷所有連接客戶端 判斷是否有數據            for($i= 0 ; $i<$this->clientcount;$i++){                    if(!isset($this->socketclients[$i]))                        continue;                    if(in_array($this->socketclients[$i],$readFD)){                            $data = $this->readFromClient($i);                            if(!$data){//如果沒有數據 就關閉連接                                   if($this->run_mode != SO_KEEPALIVE)                                        $this->closeConnection($i);                            }else{error_log(strval($this->socketclients[$i]).' data :'.$data);                            }                     }            }        }        $this -> shutdown();    }    private function readFromClient($clientIndex){            $cur_client = $this->socketclients[$clientIndex];            $data = '';            while($buf = socket_read($cur_client,$this->bufsize)){                    $endString = substr($buf,-strlen($this->endString));                    if($endString == $this->endString || $buf == NULL){                        $data .= substr($buf,0,strlen($buf)-strlen($this->endString));                        break;                    }else{                        $data .= $buf;                    }            }            if($buf === FALSE){                error_log( socket_last_error($cur_client) );            }      //  error_log(socket_read($cur_client,$this->bufsize));            return $data;    }    private function accept_connection(){            for($i = 0 ; $i <= $this->clientcount;$i++){                if(!isset($this->socketclients[$i]) || $this->socketclients[$i] == null){//如果不存在就創建                        //檢查是否超過最大連接                        if($this->clientcount+1 > $this->max_connection_limit){                               error_log('超過最大連接數:'.$this->max_connection_limit);                               return FALSE;                               break;                        }                        $this->socketclients[$i] = socket_accept($this->socket);                        socket_setopt( $this->socketclients[$i], SOL_SOCKET, $this->run_mode, 1 );                       $this->clientcount++;                        $peer_host = "";                        $peer_port = "";                        socket_getpeername( $this->socketclients[$i], $peer_host, $peer_port );                        $this->clientInfo[$i] = array(                            "host"   => $peer_host,                            "port"   => $peer_port,                            "connectOn" => time()                        );                        error_log(strval($this->socketclients[$i]).' is connected client Index :'.$i);                        return $i;                }            }            return FALSE;    }    private function closeConnection($clientIndex){            if(isset($this->socketclients[$clientIndex])){                socket_close($this->socketclients[$clientIndex]);                unset($this->socketclients[$clientIndex]);                unset($this->clientInfo[$clientIndex]);                $this->clientcount--;            }    }    private function shutdown(){           for($i = 0 ; $i<$this->clientcount;$i++){                  $this->closeConnection($i);           }           socket_close($this->socket);    }}socketbase.class.php
<?php/** * Created by JetBrains PhpStorm. * User: lost * Date: 13-6-24 * Time: 下午3:49 * To change this template use File | Settings | File Templates. */abstract class SocketBase{    const _AF_INET = AF_INET;    const _SOCK_STREAM = SOCK_STREAM;    const _TCP = 'tcp';    const _UDP = 'udp';    const _KEEPALIVE = SO_KEEPALIVE;    const _REUSEADDR = SO_REUSEADDR;    protected  $host;    protected  $port;    protected  $socket;    protected  $timeout;    protected  $protocol;    protected  $common_protocol;    protected  $type;}守護進程deamon.php
#!/usr/bin/php<?php/*******php 守護進程測試********/    require 'socketbase.class.php';require 'socketserver.class.php';$host = '127.0.0.1';$port = 5443;$socket = SocketServer::getInstance();$socket  -> createSocketServer($host,$port,SocketServer::_AF_INET,SocketServer::_SOCK_STREAM,SocketServer::_TCP,0,SOMAXCONN);$socket ->  changeBuffSize(128);//設置接收字符大小$socket -> changeEndString('/0');//設置結束字符$socket -> changeRunMode($socket::_REUSEADDR);$socket -> run();?>    linux下啟動守護進程 
nohup ./deamon.php客戶端測試OC代碼 //socket.m
////  Socket.m//  NSStream////  Created by 卜 峘 on 13-7-26.//  Copyright (c) 2013年 卜 峘. All rights reserved.//#import "Socket.h"@implementation Socket@synthesize input,output,host,port;-(id)init{    [super init];    port = 0;    return self;}+(Socket *)instance{    static Socket *instance;    if(nil == instance){        instance = [[self alloc]init];    }    return instance;}-(void)connect{    if(nil == host || 0 == port)assert("error");        CFReadStreamRef readStream;    CFWriteStreamRef writeStream;        CFStreamCreatePairWithSocketToHost(nil, (CFStringRef)host, port, &readStream, &writeStream);    input = CFBridgingRelease(readStream);//把管理權 移交給oc    output = CFBridgingRelease(writeStream);    [input setDelegate:self];    [output setDelegate:self];        [input scheduleInRunLoop:[NSRunLoop currentRunLoop]forMode:NSDefaultRunLoopMode];    [output scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];        [input open];//打開流    [output open];        [[NSRunLoop currentRunLoop] run];//啟動socket}-(void)stream:(NSStream *)aStream handleEvent:(NSStreamEvent)eventCode{        if(aStream == input){//input        [self inputStreamHandler:aStream handleEvent:eventCode];    }else{//output        [self outputStreamHandler:aStream handleEvent:eventCode];    }}-(void)inputStreamHandler:(NSStream *)aStream handleEvent:(NSStreamEvent)eventCode{    NSString *event;        switch (eventCode) {        case NSStreamEventNone://沒有事件發生            event = @"EventNone";            break;                    case NSStreamEventErrorOccurred://有錯誤發生            event = @"EventErrorOccurred";            NSLog(@"can not connected to %@",self.host);            break;                    case NSStreamEventEndEncountered://到達流的末尾            event = @"EventEndEncounted";            /**             當NSInputStream對象到達steam的末尾的時候，它會向stream:handleEvent:函數發送一個NSStreamEventEndEncountered事件類型常量，delegate函數應該做出與準備使用流對象相反的操作，也就是說，需要關閉流對象，從run loop中移除，最終釋放流對象             **/            [aStream close];            [aStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];            [aStream release];            aStream = nil;            break;                    case NSStreamEventOpenCompleted://打開流成功            event = @"EventOpenCompleted";            break;                    case NSStreamEventHasSpaceAvailable://可以向流中寫入數據            event = @"EventHasSpaceAvailable";            break;                    case NSStreamEventHasBytesAvailable://可以讀取流中的數據            event = @"EventHasBytesAvailable";                       NSMutableData *data = [[[NSMutableData alloc]autorelease ]init];            uint8_t buffer[1024];            int len;                            while([input hasBytesAvailable]){                    len = (int)[input read:buffer maxLength:sizeof(buffer)];                    if(len > 0){                        [data appendBytes:buffer length:len];                    }            }            NSString *result = [[[NSString alloc]autorelease ]initWithData:data encoding:NSUTF8StringEncoding];            NSLog(@"%@",result);                        break;                    default: event=@"default";            break;    }    // NSLog(@"%@",event);}-(void)outputStreamHandler:(NSStream *)aStream handleEvent:(NSStreamEvent)eventCode{    NSString *event;        switch (eventCode) {        case NSStreamEventNone://沒有事件發生            event = @"EventNone";            break;                    case NSStreamEventErrorOccurred://有錯誤發生            event = @"EventErrorOccurred";            NSLog(@"can not connected to %@",self.host);            return;            break;                    case NSStreamEventEndEncountered://到達流的末尾            event = @"EventEndEncounted";            /**             當NSInputStream對象到達steam的末尾的時候，它會向stream:handleEvent:函數發送一個NSStreamEventEndEncountered事件類型常量，delegate函數應該做出與準備使用流對象相反的操作，也就是說，需要關閉流對象，從run loop中移除，最終釋放流對象             **/            [aStream close];            [aStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];            [aStream release];            aStream = nil;            break;                    case NSStreamEventOpenCompleted://打開流成功            event = @"EventOpenCompleted";            break;                    case NSStreamEventHasSpaceAvailable://可以向流中寫入數據            event = @"EventHasSpaceAvailable";            if([output hasSpaceAvailable]){               // NSString *info = [NSString stringWithFormat:@"%d",rand()];               // uint8_t *buff =  (uint8_t *)[info UTF8String];                uint8_t buff[] = "aaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdaaaaaaasssdasdsadasdadasdadasdasdadasdtest info /0";                [output write:buff maxLength:strlen((char*)buff)];                [output close];//關閉輸出流 不然會不停的發送消息            }            break;                    case NSStreamEventHasBytesAvailable://可以讀取流中的數據            event = @"EventHasBytesAvailable";            break;                               default: event=@"default";            break;    }    // NSLog(@"%@",event);}@endoc main 函數
////  main.m//  NSStream////  Created by 卜 峘 on 13-7-26.//  Copyright (c) 2013年 卜 峘. All rights reserved.//#import <Foundation/Foundation.h>#import "Socket.h"int main(int argc, const char * argv[]){    @autoreleasepool {                Socket *socket = [Socket instance];        socket.host = @"127.0.0.1";        socket.port = 5443;        [socket connect];    }    return 0;}