ThinkPHP5.1 프레임워크와 Workerman의 GatewayWorker 프레임워크 결합 사례 연구

GatewayWorker는 Workerman을 기반으로 개발된 분산 배포형 TCP 장기 연결 프레임워크로, 앱 푸시 서버, 인스턴트 IM 서버, 게임 서버, 사물 인터넷, 스마트 홈 등과 같은 TCP 장기 연결 애플리케이션을 신속하게 개발하는 데 특별히 사용됩니다.

문서 주소: http://www.workerman.net/gatewaydoc/

1. 공식 DEMO 테스트(Windows 버전)

1. 데모를 다운로드하세요(아래 댓글에서 선택하세요). )

2. 다음 위치에 압축을 풉니다.

D:\phpStudy\PHPTutorial\WWW\GatewayWorker

3. GatewayWorker 디렉토리를 입력합니다.

4 시작하려면. (오류가 발생하는 경우 여기를 참조하여 PHP 환경 변수를 설정하십시오.) 효과는 다음과 같습니다

5. 명령줄 창에서 telnet 127.0.0.1 8282를 실행하고 채팅할 문자를 입력합니다(비 -네이티브 테스트 중, 127.0.0.1을 실제 IP로 교체하세요.)

PS: 위 내용은 TCP 연결 테스트가 성공했음을 나타냅니다

2. 테스트 websocket

1을 수정하여 websocket 프로토콜을 지정해야 합니다.

$gateway = new Gateway(websocket://0.0.0.0:7272);

2 . start_for_win.bat

3 다시 시작, js

테스트 요약: 한 파일(start_gateway.php)의 프로토콜과 포트만 변경하면 되며 다른 변경 사항은 필요하지 않습니다.

3. ThinkPHP5.1 프레임워크와의 통합

(1) 서버는 클라이언트에 메시지를 적극적으로 푸시합니다.

원리:

1 GatewayWorker의 독립적인 배포는 방해하지 않습니다. 와 함께

2 , 모든 비즈니스 로직은 TP5.1 프레임워크

3의 컨트롤러에 대한 게시/가져오기 요청을 사용하여 웹사이트(websocket 연결) 페이지에서 완료됩니다. GatewayWorker는 클라이언트에서 전송된 데이터를 허용하지 않습니다. , GatewayWorker는 비즈니스 로직을 처리하지 않으며 GatewayWorker는 단방향 푸시 채널로만 사용됩니다

4. TP5.1 프레임워크가 데이터를 브라우저에 적극적으로 푸시해야 하는 경우에만 Gateway API(GatewayClient)가 호출됩니다. push

특정 구현 단계를 완료하기 위한 TP5.1 프레임워크

1. 웹사이트 페이지는 GatewayWorker

ws = new WebSocket("ws://127.0.0.1:7272");

와 웹소켓 연결을 설정합니다. 2. GatewayWorker는 페이지가 연결을 시작하는 것을 발견하면 해당 페이지의 client_id를 보냅니다. 웹사이트 페이지에 연결

Event.php content

public static function onConnect($client_id)
{
    $resData = [
        'type' => 'init',
        'client_id' => $client_id,
        'msg' => 'connect is success' // 初始化房间信息
    ];
    Gateway::sendToClient($client_id, json_encode($resData));
}

index.html Content

    
    


GatewayWorker的websocket连接

3. 웹사이트 페이지가 client_id를 받은 후 ajax 요청(index/chat_room/bind)을 실행하여 client_id를 TP5.0 백엔드에 바인딩합니다. 백엔드가 client_id를 받은 후 GatewayClient를 사용하여 Gateway::bindUid($client_id, $uid)를 호출하여 client_id를 현재 uid(사용자 ID 또는 클라이언트)에 바인딩합니다. 고유 식별자). 그룹 또는 그룹 전송 기능이 있는 경우 Gateway::joinGroup($client_id, $group_id)을 사용하여 해당 그룹에 client_id를 추가할 수도 있습니다

연결 성공 후 반환 값

PS: 위 반환 값은 GatewayWorker 서비스 연결입니다. 성공 후 반환된 json 데이터

5. 페이지에서 시작된 모든 요청은 메시지 보내기를 포함하여 통합 처리를 위해 mvc 프레임워크에 직접 게시/가져옵니다.

sendMessage를 통해 메시지 보내기(서버가 적극적으로 푸시함) 메시지를 클라이언트로 전송)

/*
 * 用户登录后初始化以及绑定client_id
 */
public function bind()
{
    // 设置GatewayWorker服务的Register服务ip和端口，请根据实际情况改成实际值
    Gateway::$registerAddress = '127.0.0.1:1238';
    $uid = $this->userId;
    $group_id = $this->groupId;
    $client_id = request()->param('client_id');
    // client_id与uid绑定
    Gateway::bindUid($client_id, $uid);
    // 加入某个群组（可调用多次加入多个群组）
    Gateway::joinGroup($client_id, $group_id);
}

6. mvc 프레임워크가 비즈니스 처리 중에 특정 uid 또는 그룹에 데이터를 보내야 하는 경우 GatewayClient 인터페이스 Gateway::sendToUid Gateway::sendToGroup을 직접 호출하고 전송을 기다립니다

Access 브라우저를 통한 sendMessage 작업, 테스트 결과

PS: 위 메시지는 GatewayClientGateway를 통해 TP5.0에서 보낸 메시지이며 GatewayWorker 서비스와 직접적인 관계는 없습니다

위는 서버가 적극적으로 메시지를 푸시하는 내용입니다. 클라이언트

구별 사항에 유의하세요.

1. 서버가 클라이언트에 메시지를 푸시합니다.

2. 클라이언트가 클라이언트에 메시지를 푸시합니다.

(2) 클라이언트가 클라이언트에 메시지를 푸시합니다.

전송 내용을 수정합니다. 클라이언트에서 클라이언트로 메시지 수신 아래 GatewayWorker의 Events.php를 수정하세요(개발 독자는 이 파일만 주의하면 됩니다)

// mvc后端发消息 利用GatewayClient发送 Events.php
public function sendMessage()
{
    // stream_socket_client(): unable to connect to tcp://127.0.0.1:1236
    $uid = $this->userId;
    $group = $this->groupId;
    $message = json_encode([
      'type'=>'say',
      'msg'=>'Hello ThinkPHP5'
    ]);
    // 设置GatewayWorker服务的Register服务ip和端口，请根据实际情况改成实际值
    Gateway::$registerAddress = '127.0.0.1:1238';
    // 向任意uid的网站页面发送数据
    Gateway::sendToUid($uid, $message);
    // 向任意群组的网站页面发送数据，如果开启，则会向页面发送两条一样的消息
    //Gateway::sendToGroup($group, $message);
}

index.html 채팅방 페이지

public static function onConnect($client_id)
{
    $resData = [
        'type' => 'init',
        'client_id' => $client_id,
        'msg' => 'connect is success' // 初始化房间信息
    ];
    Gateway::sendToClient($client_id, json_encode($resData));
}
 
/**
 * 当客户端发来消息时触发
 * @param int $client_id 连接id
 * @param mixed $message 具体消息
 */
public static function onMessage($client_id, $message)
{
    // 服务端console输出
    //echo "msg : $message \r\n";
 
    // 解析数据
    $resData = json_decode($message, true);
    $type = $resData['type'];
    $roomId = $resData['roomId'];
    $userId = $resData['userId']; // 未登录，则传递一个随机
    $userName = $resData['userName']; // 未登录，则传递一个随机
    $content = isset($resData['content']) ? $resData['content'] : 'default content';
     
    //将时间全部置为服务器时间
    $serverTime = date('Y-m-d H:i:s', time());
 
    switch ($type) {
        case 'join':  // 用户进入直播间
            //将客户端加入到某一直播间
            Gateway::joinGroup($client_id, $roomId);
            $resData = [
                'type' => 'join',
                'roomId' => $roomId,
                'userName' => $userName,
                'msg' => "enters the Room", // 发送给客户端的消息，而不是聊天发送的内容
                'joinTime' => $serverTime // 加入时间                   
            ];
 
            // 广播给直播间内所有人，谁？什么时候？加入了那个房间？
            Gateway::sendToGroup($roomId, json_encode($resData));
            break;
        case 'say':  // 用户发表评论
            $resData = [
                'type' => 'say',
                'roomId' => $roomId,
                'userName' => $userName,
                'content' => $content,
                'commentTime' => $serverTime // 发表评论时间
            ];
            // 广播给直播间内所有人
            Gateway::sendToGroup($roomId, json_encode($resData));
            break;
        case 'pong':
            break; // 接收心跳
        default:
            //Gateway::sendToAll($client_id,$json_encode($resData));
            break;
    }
}

서비스를 다시 시작하세요

테스트 결과

확장:

Redis에 메시지를 저장하고 라이브 방송실에서 Redis 통계 PV를 사용할 수 있습니다

$redis = new \Redis;
$redis->connect('127.0.0.1',6379);
$key = "PV:ROOM:".$roomId;
$field = "ROOM_TOTAL_PV";
// 进入房间的人数增长，自增 ，增加PV统计
$redis->hIncrBy($key,$field,1);

相关推荐：《PHP教程》

위 내용은 ThinkPHP5.1 프레임워크와 Workerman의 GatewayWorker 프레임워크 결합 사례 연구의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!