iOS&phpWebSocekt

原理改天总结一下吧,直接上源码:

下载库:http://pan.baidu.com/s/1qX2u45A

然后导入到项目。

添加依赖库:

Your .app must be linked against the following frameworks/dylibs
 
libicucore.dylib
CFNetwork.framework
Security.framework
Foundation.framework

修改库里边所在PCH文件的地址引用:Prefix Header-> SRWebSocket/SocketRocket-Prefix.pch

客户端:

//
//  ViewController.m
//  WebsocketDemo
//
//  Created by skyzizhu on 16/1/5.
//  Copyright (c) 2016年 skyzizhu. All rights reserved.
//
 
#import "ViewController.h"
 
#import "SRWebSocket.h"
 
#define WindowWidth [UIScreen mainScreen].bounds.size.width
 
#define WindowHeight [UIScreen mainScreen].bounds.size.height
 
@interface ViewController ()<SRWebSocketDelegate>
 
@property (nonatomic,strong) SRWebSocket *webSocket;
 
@property (nonatomic,strong) NSString *socketConnectURL;
 
@end
 
@implementation ViewController
 
- (void)viewDidDisappear:(BOOL)animated
{
    [super viewDidDisappear:animated];
    _webSocket.delegate = nil;
    [_webSocket close];
    _webSocket = nil;
}
 
- (void)viewDidLoad {
    [super viewDidLoad];
    self.view.backgroundColor = [UIColor orangeColor];
    
    UITextField *input = [[UITextField alloc]initWithFrame:CGRectMake(20, 100, WindowWidth - 40, 70)];
    input.tag = 6440;
    input.placeholder = @"请输入链接地址或者发送内容";
    input.borderStyle = UITextBorderStyleLine;
    [self.view addSubview:input];
    
    UIButton *send = [[UIButton alloc]initWithFrame:CGRectMake(50, 200, WindowWidth - 100, 50)];
    send.backgroundColor = [UIColor grayColor];
    [send setTitleColor:[UIColor whiteColor] forState:UIControlStateNormal];
    [send setTitle:@"连接/发送" forState:UIControlStateNormal];
    [self.view addSubview:send];
    [send addTarget:self action:@selector(connectOrSendAction:) forControlEvents:UIControlEventTouchUpInside];
    
    
    // Do any additional setup after loading the view, typically from a nib.
}
 
-(void)connectOrSendAction:(UIButton *)obj
{
    UITextField *currentInput = (UITextField *)[self.view viewWithTag:6440];
    
    if(currentInput.text.length <= 0 || (_webSocket != nil && [_webSocket readyState] == SR_CONNECTING)) return;
    
    if([_webSocket readyState] != SR_OPEN){
    
        //@"ws://192.168.1.8:8000/"
        self.socketConnectURL = currentInput.text;
        
        [self connectServer];
        
    }else{
        
        [_webSocket send:currentInput.text];
        
    }
}
 
- (void)connectServer;
{
    if(_webSocket.delegate != nil){
        _webSocket.delegate = nil;
    }
    if([_webSocket readyState] < SR_CLOSING){
        [_webSocket close];
    }
    
    _webSocket = [[SRWebSocket alloc] initWithURLRequest:[NSURLRequest requestWithURL:[NSURL URLWithString:self.socketConnectURL]]];
    _webSocket.delegate = self;
    self.title = @"Opening Connection...";
    [_webSocket open];
    
}
 
#pragma websocket delegate
 
- (void)webSocketDidOpen:(SRWebSocket *)webSocket;
{
    //连接成功之后调用
    NSLog(@"Websocket Connected");
}
 
- (void)webSocket:(SRWebSocket *)webSocket didFailWithError:(NSError *)error;
{
    
    //连接出现错误时候调用的代理
    NSLog(@":( Websocket Failed With Error %@", error);
    
    _webSocket = nil;
}
 
- (void)webSocket:(SRWebSocket *)webSocket didReceiveMessage:(id)message
{
    //成功接受消息之后的代理
    NSLog(@"Received \"%@\"", message);
    
    UIAlertView *alert = [[UIAlertView alloc]initWithTitle:@"收到消息" message:message delegate:nil cancelButtonTitle:nil otherButtonTitles:@"Enter", nil];
    [alert show];
    
}
 
- (void)webSocket:(SRWebSocket *)webSocket didCloseWithCode:(NSInteger)code reason:(NSString *)reason wasClean:(BOOL)wasClean;
{
    //webSocket已经关闭之后执行的代理
    NSLog(@"WebSocket closed");
    self.title = @"Connection Closed! (see logs)";
    _webSocket = nil;
}
 
- (void)webSocket:(SRWebSocket *)webSocket didReceivePong:(NSData *)pongPayload;
{
    NSLog(@"收到服务器返回异常的代理方法");
}
 
- (void)didReceiveMemoryWarning {
    [super didReceiveMemoryWarning];
    // Dispose of any resources that can be recreated.
}
 
@end

服务器端:websocket.class.php 连接类

<?php
/*
创建类websocket($config);
$config结构:
$config=array(
  'address'=>'192.168.0.200',//绑定地址
  'port'=>'8000',//绑定端口
  'event'=>'WSevent',//回调函数的函数名
  'log'=>true,//命令行显示记录
);
 
回调函数返回数据格式
function WSevent($type,$event)
 
$type字符串 事件类型有以下三种
in  客户端进入
out 客户端断开
msg 客户端消息到达
均为小写
 
$event 数组
$event['k']内置用户列表的userid;
$event['sign']客户标示
$event['msg']收到的消息 $type='msg'时才有该信息
 
方法:
run()运行
search(标示)遍历取得该标示的id
close(标示)断开连接
write(标示,信息)推送信息
idwrite(id,信息)推送信息
 
属性:
$users 客户列表
结构:
$users=array(
[用户id]=>array('socket'=>[标示],'hand'=[是否握手-布尔值]),
[用户id]=>arr.....
)
*/
 
class websocket{
    public $log;
    public $event;
    public $signets;
    public $users;  
    public $master; 
    public function __construct($config){
        if (substr(php_sapi_name(), 0, 3) !== 'cli') {
            die("请通过命令行模式运行!");
        }
        error_reporting(E_ALL);
        set_time_limit(0);
        ob_implicit_flush();
        $this->event = $config['event'];
        $this->log = $config['log'];
        $this->master=$this->WebSocket($config['address'], $config['port']);
        $this->sockets=array('s'=>$this->master);
    }
    function WebSocket($address,$port){
        $server = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
        socket_set_option($server, SOL_SOCKET, SO_REUSEADDR, 1);
        socket_bind($server, $address, $port);
        socket_listen($server);
        $this->log('开始监听: '.$address.' : '.$port);
        return $server;
    }
  function run(){
    while(true){
      $changes=$this->sockets;
      @socket_select($changes,$write=NULL,$except=NULL,NULL);
      foreach($changes as $sign){
        if($sign==$this->master){
          $client=socket_accept($this->master);
          $this->sockets[]=$client;
          $user = array(
            'socket'=>$client,
            'hand'=>false,
          );
          $this->users[] = $user;
          $k=$this->search($client);
          $eventreturn = array('k'=>$k,'sign'=>$sign);
          $this->eventoutput('in',$eventreturn);
        }else{
          $len=socket_recv($sign,$buffer,2048,0);
          $k=$this->search($sign);
          $user=$this->users[$k];
          if($len<7){
            $this->close($sign);
            $eventreturn = array('k'=>$k,'sign'=>$sign);
            $this->eventoutput('out',$eventreturn);
            continue;
          }
          if(!$this->users[$k]['hand']){//没有握手进行握手
            $this->handshake($k,$buffer);
          }else{
            $buffer = $this->uncode($buffer);
            $eventreturn = array('k'=>$k,'sign'=>$sign,'msg'=>$buffer);
            $this->eventoutput('msg',$eventreturn);
          }
        }
      }
    }
  }
  function search($sign){//通过标示遍历获取id
    foreach ($this->users as $k=>$v){
      if($sign==$v['socket'])
      return $k;
    }
    return false;
  }
  function close($sign){//通过标示断开连接
    $k=array_search($sign, $this->sockets);
    socket_close($sign);
    unset($this->sockets[$k]);
    unset($this->users[$k]);
  }
  function handshake($k,$buffer){
    $buf  = substr($buffer,strpos($buffer,'Sec-WebSocket-Key:')+18);
    $key  = trim(substr($buf,0,strpos($buf,"\r\n")));
    $new_key = base64_encode(sha1($key."258EAFA5-E914-47DA-95CA-C5AB0DC85B11",true));
    $new_message = "HTTP/1.1 101 Switching Protocols\r\n";
    $new_message .= "Upgrade: websocket\r\n";
    $new_message .= "Sec-WebSocket-Version: 13\r\n";
    $new_message .= "Connection: Upgrade\r\n";
    $new_message .= "Sec-WebSocket-Accept: " . $new_key . "\r\n\r\n";
    socket_write($this->users[$k]['socket'],$new_message,strlen($new_message));
    $this->users[$k]['hand']=true;
    return true;
  }
  function uncode($str){
    $mask = array();  
    $data = '';  
    $msg = unpack('H*',$str);  
    $head = substr($msg[1],0,2);  
    if (hexdec($head{1}) === 8) {  
      $data = false;  
    }else if (hexdec($head{1}) === 1){  
      $mask[] = hexdec(substr($msg[1],4,2));
      $mask[] = hexdec(substr($msg[1],6,2));
      $mask[] = hexdec(substr($msg[1],8,2));
      $mask[] = hexdec(substr($msg[1],10,2));
      $s = 12;  
      $e = strlen($msg[1])-2;  
      $n = 0;  
      for ($i=$s; $i<= $e; $i+= 2) {  
        $data .= chr($mask[$n%4]^hexdec(substr($msg[1],$i,2)));  
        $n++;  
      }  
    }  
    return $data;
  }
    function code($msg){
      $msg = preg_replace(array('/\r$/','/\n$/','/\r\n$/',), '', $msg);
      $frame = array();  
      $frame[0] = '81';  
      $len = strlen($msg);  
      $frame[1] = $len<16?'0'.dechex($len):dechex($len);
      $frame[2] = $this->ord_hex($msg);
      $data = implode('',$frame);
      return pack("H*", $data);
    }
    function ord_hex($data)  {  
      $msg = '';  
      $l = strlen($data);  
      for ($i= 0; $i<$l; $i++) {  
        $msg .= dechex(ord($data{$i}));  
      }  
      return $msg;  
    }
 
    function idwrite($id,$t){//通过id推送信息
      if(!$this->users[$id]['socket']){return false;}//没有这个标示
      $t=$this->code($t);
      return socket_write($this->users[$id]['socket'],$t,strlen($t));
    }
    function write($k,$t){//通过标示推送信息
      $t=$this->code($t);
      return socket_write($k,$t,strlen($t));
    }
    function eventoutput($type,$event){//事件回调
      call_user_func($this->event,$type,$event);
    }
    function log($t){//控制台输出
      if($this->log){
        $t=$t."\r\n";
        fwrite(STDOUT, iconv('utf-8','gbk//IGNORE',$t));
      }
    }
}
<?
include 'websocket.class.php';
 
$config=array(
  'address'=>'192.168.1.8',
  'port'=>'8000',
  'event'=>'WSevent',//回调函数的函数名
  'log'=>true,
);
$websocket = new websocket($config);
$websocket->run();
function WSevent($type,$event){
  global $websocket;
    if('in'==$type){
      $websocket->log('客户进入id:'.$event['k']);
    }elseif('out'==$type){
      $websocket->log('客户退出id:'.$event['k']);
    }elseif('msg'==$type){
      $websocket->log($event['k'].'消息:'.$event['msg']);
      roboot($event['sign'],$event['msg']);
    }
}
 
function roboot($sign,$t){
  global $websocket;
  switch ($t)
  {
  case 'hello':
    $show='hello,for websocket';
    break;  
  case 'name':
    $show='my name is server';
    break;
  case 'time':
    $show='current time:'.date('Y-m-d H:i:s');
    break;
  case 'bye':
    $show='bye bye ';
    $websocket->write($sign,'server say:'.$show);
    $websocket->close($sign);
    return;
    break;
  case 'no':
    $array = array('oh no','yes or no','this is your message no no no!');
    $show = $array[rand(0,2)];
    break;
  default:
    $show='how do you do?.';
  }
  $websocket->write($sign,'server alert message:'.$show);
}
?>

运行:$ php -q server.php

原文原库:http://www.oschina.net/code/snippet_1029305_22256

https://github.com/square/SocketRocket

http://haoningabc.iteye.com/blog/2125460

Leave a Reply

Required fields are marked *