찾다
백엔드 개발PHP 튜토리얼ThinkPHP5.1 프레임워크와 Workerman의 GatewayWorker 프레임워크 결합 사례 연구

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

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

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

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

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

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

D:\phpStudy\PHPTutorial\WWW\GatewayWorker

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

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

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

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

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

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

2. 테스트 websocket

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

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

2 . start_for_win.bat

3 다시 시작, js

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

테스트 요약: 한 파일(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连接


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를 추가할 수도 있습니다

연결 성공 후 반환 값


ThinkPHP5.1 프레임워크와 Workerman의 GatewayWorker 프레임워크 결합 사례 연구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 작업, 테스트 결과

ThinkPHP5.1 프레임워크와 Workerman의 GatewayWorker 프레임워크 결합 사례 연구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;
    }
}
서비스를 다시 시작하세요

테스트 결과

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

확장:

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 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명
이 기사는 Tinywan에서 복제됩니다. 침해가 있는 경우 admin@php.cn으로 문의하시기 바랍니다. 삭제
PHP와 Python : 다른 패러다임이 설명되었습니다PHP와 Python : 다른 패러다임이 설명되었습니다Apr 18, 2025 am 12:26 AM

PHP는 주로 절차 적 프로그래밍이지만 객체 지향 프로그래밍 (OOP)도 지원합니다. Python은 OOP, 기능 및 절차 프로그래밍을 포함한 다양한 패러다임을 지원합니다. PHP는 웹 개발에 적합하며 Python은 데이터 분석 및 기계 학습과 같은 다양한 응용 프로그램에 적합합니다.

PHP와 Python : 그들의 역사에 깊은 다이빙PHP와 Python : 그들의 역사에 깊은 다이빙Apr 18, 2025 am 12:25 AM

PHP는 1994 년에 시작되었으며 Rasmuslerdorf에 의해 개발되었습니다. 원래 웹 사이트 방문자를 추적하는 데 사용되었으며 점차 서버 측 스크립팅 언어로 진화했으며 웹 개발에 널리 사용되었습니다. Python은 1980 년대 후반 Guidovan Rossum에 의해 개발되었으며 1991 년에 처음 출시되었습니다. 코드 가독성과 단순성을 강조하며 과학 컴퓨팅, 데이터 분석 및 기타 분야에 적합합니다.

PHP와 Python 중에서 선택 : 가이드PHP와 Python 중에서 선택 : 가이드Apr 18, 2025 am 12:24 AM

PHP는 웹 개발 및 빠른 프로토 타이핑에 적합하며 Python은 데이터 과학 및 기계 학습에 적합합니다. 1.PHP는 간단한 구문과 함께 동적 웹 개발에 사용되며 빠른 개발에 적합합니다. 2. Python은 간결한 구문을 가지고 있으며 여러 분야에 적합하며 강력한 라이브러리 생태계가 있습니다.

PHP 및 프레임 워크 : 언어 현대화PHP 및 프레임 워크 : 언어 현대화Apr 18, 2025 am 12:14 AM

PHP는 현대화 프로세스에서 많은 웹 사이트 및 응용 프로그램을 지원하고 프레임 워크를 통해 개발 요구에 적응하기 때문에 여전히 중요합니다. 1.PHP7은 성능을 향상시키고 새로운 기능을 소개합니다. 2. Laravel, Symfony 및 Codeigniter와 같은 현대 프레임 워크는 개발을 단순화하고 코드 품질을 향상시킵니다. 3. 성능 최적화 및 모범 사례는 응용 프로그램 효율성을 더욱 향상시킵니다.

PHP의 영향 : 웹 개발 및 그 이상PHP의 영향 : 웹 개발 및 그 이상Apr 18, 2025 am 12:10 AM

phphassignificallyimpactedwebdevelopmentandextendsbeyondit

스칼라 유형, 반환 유형, 노조 유형 및 무효 유형을 포함한 PHP 유형의 힌트 작업은 어떻게 작동합니까?스칼라 유형, 반환 유형, 노조 유형 및 무효 유형을 포함한 PHP 유형의 힌트 작업은 어떻게 작동합니까?Apr 17, 2025 am 12:25 AM

PHP 유형은 코드 품질과 가독성을 향상시키기위한 프롬프트입니다. 1) 스칼라 유형 팁 : PHP7.0이므로 int, float 등과 같은 기능 매개 변수에 기본 데이터 유형을 지정할 수 있습니다. 2) 반환 유형 프롬프트 : 기능 반환 값 유형의 일관성을 확인하십시오. 3) Union 유형 프롬프트 : PHP8.0이므로 기능 매개 변수 또는 반환 값에 여러 유형을 지정할 수 있습니다. 4) Nullable 유형 프롬프트 : NULL 값을 포함하고 널 값을 반환 할 수있는 기능을 포함 할 수 있습니다.

PHP는 객체 클로닝 (클론 키워드) 및 __clone 마법 방법을 어떻게 처리합니까?PHP는 객체 클로닝 (클론 키워드) 및 __clone 마법 방법을 어떻게 처리합니까?Apr 17, 2025 am 12:24 AM

PHP에서는 클론 키워드를 사용하여 객체 사본을 만들고 \ _ \ _ Clone Magic 메소드를 통해 클로닝 동작을 사용자 정의하십시오. 1. 복제 키워드를 사용하여 얕은 사본을 만들어 객체의 속성을 복제하지만 객체의 속성은 아닙니다. 2. \ _ \ _ 클론 방법은 얕은 복사 문제를 피하기 위해 중첩 된 물체를 깊이 복사 할 수 있습니다. 3. 복제의 순환 참조 및 성능 문제를 피하고 클로닝 작업을 최적화하여 효율성을 향상시키기 위해주의를 기울이십시오.

PHP vs. Python : 사용 사례 및 응용 프로그램PHP vs. Python : 사용 사례 및 응용 프로그램Apr 17, 2025 am 12:23 AM

PHP는 웹 개발 및 컨텐츠 관리 시스템에 적합하며 Python은 데이터 과학, 기계 학습 및 자동화 스크립트에 적합합니다. 1.PHP는 빠르고 확장 가능한 웹 사이트 및 응용 프로그램을 구축하는 데 잘 작동하며 WordPress와 같은 CMS에서 일반적으로 사용됩니다. 2. Python은 Numpy 및 Tensorflow와 같은 풍부한 라이브러리를 통해 데이터 과학 및 기계 학습 분야에서 뛰어난 공연을했습니다.

See all articles

핫 AI 도구

Undresser.AI Undress

Undresser.AI Undress

사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover

AI Clothes Remover

사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool

Undress AI Tool

무료로 이미지를 벗다

Clothoff.io

Clothoff.io

AI 옷 제거제

AI Hentai Generator

AI Hentai Generator

AI Hentai를 무료로 생성하십시오.

뜨거운 도구

MinGW - Windows용 미니멀리스트 GNU

MinGW - Windows용 미니멀리스트 GNU

이 프로젝트는 osdn.net/projects/mingw로 마이그레이션되는 중입니다. 계속해서 그곳에서 우리를 팔로우할 수 있습니다. MinGW: GCC(GNU Compiler Collection)의 기본 Windows 포트로, 기본 Windows 애플리케이션을 구축하기 위한 무료 배포 가능 가져오기 라이브러리 및 헤더 파일로 C99 기능을 지원하는 MSVC 런타임에 대한 확장이 포함되어 있습니다. 모든 MinGW 소프트웨어는 64비트 Windows 플랫폼에서 실행될 수 있습니다.

드림위버 CS6

드림위버 CS6

시각적 웹 개발 도구

WebStorm Mac 버전

WebStorm Mac 버전

유용한 JavaScript 개발 도구

ZendStudio 13.5.1 맥

ZendStudio 13.5.1 맥

강력한 PHP 통합 개발 환경

메모장++7.3.1

메모장++7.3.1

사용하기 쉬운 무료 코드 편집기