使用SocketRocket框架+php的Ratchet实现基于websocket的数据传输

正常app与服务端通信使用http协议就可以,但是如果我们遇到app与服务器频繁通信或者服务器需要向客户端推送消息时就可以使用websocket建立长连接进行通信。

我们只需要在app端和服务器上集成相应的框架,便可以建立websocket长连接进行通信。

1、app端集成SocketRocket框架

使用pod管理集成SocketRocket到项目中,并添加相应代码

#import  <SocketRocket.h>

- (void)initWebSocket {

    //init websocket

    NSString *urlStr = [NSString stringWithFormat:@"wss://localhost/wss2/phone_%@",[AccountManager sharedInstance].user.userId];

    self.webSocket = [[SRWebSocket alloc] initWithURL:[NSURL URLWithString:urlStr]];

    self.webSocket.delegate=self;

}

这里我们需要注意的是当调用[self.webSocket close]后,再次调用[self.webSocket open]时需要再次初始化self.webSocket。

当我们打开连接后,就可以使用[self.webSocket send:data]发送数据。

2、服务端集成Ratchet框架

这里我们的服务端是用php写的,php下有Ratchet框架来提供websocket服务,我们先使用composer来集成这个框架,随后建立两个php文件,并添加相应代码。

chat-server.php


<?php

use Ratchet\Server\IoServer;

use Ratchet\Http\HttpServer;

use Ratchet\WebSocket\WsServer;

use MyApp\Chat;

    require dirname(__DIR__).'/vendor/autoload.php';

    $server = IoServer::factory(

        new HttpServer(

            new WsServer(

                new Chat()

            )

        ),

        3000

    );

    $server->run();

?>

chat.php

<?php

namespace MyApp;

use Ratchet\MessageComponentInterface;

use Ratchet\ConnectionInterface;

class Chat implements MessageComponentInterface {

    protected $clients;

    public function __construct() {

        $this->clients = new \SplObjectStorage;

    }

    public function onOpen(ConnectionInterface $conn){

        $this->clients->attach($conn);

        echo "New connection! ({$conn->resourceId}) ({$conn->httpRequest->getRequestTarget()})\n";

    }

    public function onMessage(ConnectionInterface $from, $msg) {

     }

    public function onClose(ConnectionInterface $conn) {

        $this->clients->detach($conn);

        echo "Connection {$conn->resourceId} has disconnected\n";

    }

    public function onError(ConnectionInterface $conn, \Exception $e) {

        echo "An error has occurred:{$e->getMessage()}\n";

        $conn->close();

    }

}

?>

之后我们打开终端运行php chat-server.php命令,就可以开启websocket服务了。

如果我们的web服务是https的,我们就需要使用wss协议。ratchet框架提供SecureServer类来实现wss协议。我们也可以在apache下的httpd.conf文件中添加一行代码。

ProxyPass /wss2/ ws://localhost:3000/

使wss协议先走代理转成ws协议再使用。

3、H5代码

var wsUrl = 'wss://localhost/wss2/'.concat(arr.pop());

    var ws = new WebSocket(wsUrl);

    ws.onmessage = function(event) {

      var data = event.data;

      console.log(data);

    }

©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 英文文档,一开始我也是抗拒的,边翻译边看,也就花费了1个小时基本就阅读过了,我的英文基础其实很差。附上链接:链接:...
    lonecolonel阅读 13,450评论 3 1
  • Welcome to websocket-sharp! websocket-sharp supports: RFC...
    mtian999阅读 13,386评论 0 1
  • 我被快乐杀死了,难得像团水,你没法用手捏起来。 麻木不能让我明白该做什么,因为我毫无感知的心只剩下絮叨曾经的症结。...
    你看着我阅读 1,020评论 0 0
  • 思考,约定 1.微信图文 4小时! 2.静思 1小时! *只有自己学会思考,才能真正清晰什么是自己需要的,想要的,...
    橘子侠阅读 1,280评论 0 2
  • 她:"我曾经得了一种很严重的病。" 朋友:"什么病?" 她:"那种病……名叫爱." 朋友:″后来呢?" 她:″后来...
    作死de大喵阅读 7,042评论 0 2