resumeRecv

विवरण:

void Connection::resumeRecv(void)

वर्तमान कनेक्शन को डेटा प्राप्त करना जारी रखने देता है। यह विधि Connection::pauseRecv के साथ मिलकर काम करती है, जो अपलोड प्रवाह नियंत्रण के लिए बहुत उपयोगी है।

पैरामीटर

कोई पैरामीटर नहीं

उदाहरण

use Workerman\Worker;
use Workerman\Timer;
use Workerman\Connection\TcpConnection;
require_once __DIR__ . '/vendor/autoload.php';

$worker = new Worker('websocket://0.0.0.0:8484');
$worker->onConnect = function(TcpConnection $connection)
{
    // connection ऑब्जेक्ट में एक प्रॉपर्टी शामिल करें, 
    // ताकि यह भंडारण कर सके कि वर्तमान कनेक्शन द्वारा कितने अनुरोध किए गए हैं
    $connection->messageCount = 0;
};
$worker->onMessage = function(TcpConnection $connection, $data)
{
    // प्रत्येक कनेक्शन 100 अनुरोध प्राप्त करने के बाद डेटा प्राप्त करना बंद कर देता है
    $limit = 100;
    if(++$connection->messageCount > $limit)
    {
        $connection->pauseRecv();
        // 30 सेकंड बाद डेटा प्राप्त करना फिर से शुरू करें
        Timer::add(30, function($connection){
            $connection->resumeRecv();
        }, array($connection), false);
    }
};
// वर्कर चलाएँ
Worker::runAll();

संदर्भ

void Connection::pauseRecv(void) संबंधित कनेक्शन ऑब्जेक्ट को डेटा प्राप्त करना बंद कर देता है।