php-ext-coroutine-study/test.php at master · luffluo/php-ext-coroutine-study · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
<?php

study_event_init();

go(function() {
    var_dump(Co::getCid());
    Co::sleep(1);
    var_dump(Co::getCid());
});

go(function() {
    var_dump(Co::getCid());
    Co::sleep(1);
    var_dump(Co::getCid());
});

go(function() {
    var_dump(Co::getCid());
    Co::sleep(1);
    var_dump(Co::getCid());
});

study_event_wait();

exit;

while (true) {
    go(function() {
        $cid = Co::getCid();
        var_dump($cid);
    });
}
exit;

go(function() {
    var_dump('server start');
    $server = new \Study\Coroutine\Server('127.0.0.1', 8080);
    var_dump('server created');

    while (1) {
        var_dump('accept start');
        $connfd = $server->accept();
        var_dump('accept connectied ' . $connfd);

        // go(function() use ($server, $connfd) {
            // while (1) {
                var_dump('recv start');
                $buf = $server->recv($connfd);
                $responseStr = "HTTP/1.1 200 OK\r\nContent-Type: text/html\r\nConnection: close\r\nContent-Length: 11\r\n\r\nhello world\r\n";
                var_dump('send start');
                $server->send($connfd, $responseStr);
                var_dump('close start');
                $server->close($connfd);
                // $msg = $server->recv($connfd);
                // $server->send($connfd, $msg);
                // var_dump('send end');
            // }
        // });
    }
});

exit;

while (1) {
    $connfd = $server->accept();

    while (1) {
        $buf = $server->recv($connfd);
        if (false === $buf) {
            break;
        }

        $server->send($connfd, "Hello");
    }
}