1234567891011121314151617181920212223242526 |
- <?php
- //Server
- go(function () {
- $socket = new Co\Socket(AF_INET, SOCK_DGRAM, 0);
- $socket->bind('127.0.0.1', 9601);
- while (true) {
- $peer = null;
- $data = $socket->recvfrom($peer);
- echo "[Server] recvfrom[{$peer['address']}:{$peer['port']}] : $data\n";
- $socket->sendto($peer['address'], $peer['port'], "Swoole: $data");
- }
- });
- //Client
- go(function () {
- $socket = new Co\Socket(AF_INET, SOCK_DGRAM, 0);
- $i = 0;
- while (true)
- {
- $socket->sendto('127.0.0.1', 9601, "HELO-" . $i++);
- $peer = null;
- $data = $socket->recvfrom($peer);
- echo "[Client] recvfrom[{$peer['address']}:{$peer['port']}] : $data\n";
- co::sleep(1);
- }
- });
|