簡(jiǎn)單地拿php的socket寫了個(gè)小daemo, 代碼如下:
server端:<?php
$address = "127.0.0.1";$port = 20461;//創(chuàng)建socket資源$sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP) or die("socket_create() 失敗的原因是:" . socket_strerror(socket_last_error()) . "/n");//阻塞模式socket_set_block($sock) or die("socket_set_block() 失敗的原因是:" . socket_strerror(socket_last_error()) . "/n");//綁定到socket端口$result = socket_bind($sock, $address, $port) or die("socket_bind() 失敗的原因是:" . socket_strerror(socket_last_error()) . "/n");//監(jiān)聽端口$result = socket_listen($sock) or die("socket_listen() 失敗的原因是:" . socket_strerror(socket_last_error()) . "/n");echo "OKnBinding the socket on $address:$port ... ";echo "OKnNow ready to accept connections.nListening on the socket ... n";do {
$msgsock = socket_accept($sock) or die("socket_accept() failed: reason: " . socket_strerror(socket_last_error()) . "/n");
echo "Read client data \n";
$buf = socket_read($msgsock, 8192, PHP_NORMAL_READ);
echo "Received msg: $buf \n";
//數(shù)據(jù)傳送 向客戶端寫入返回結(jié)果
$msg = "welcome" . PHP_EOL;
socket_write($msgsock, $msg, strlen($msg)) or die("socket_write() failed: reason: " . socket_strerror(socket_last_error()) ."/n");
socket_close($msgsock);
} while (true);socket_close($sock);
client端:<?phpglobal $argv;$host = "127.0.0.1";$port = 20461;$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)or die("Could not create socketn"); // 創(chuàng)建一個(gè)Socket$connection = socket_connect($socket, $host, $port) or die("Could not connet servern"); // 連接socket_write($socket, $argv[1] . PHP_EOL) or die("Write failedn");//$buff = socket_read($socket, 1024, PHP_NORMAL_READ);while ($buff = socket_read($socket, 1024, PHP_NORMAL_READ)) {
echo("Response was:" . $buff . PHP_EOL);
}socket_close($socket);
我把服務(wù)端啟動(dòng)之后,客戶端發(fā)送數(shù)據(jù)會(huì)報(bào)錯(cuò):但是把客戶端的socket_read改成PHP_BINARY_READ就可以了;
socket_read的兩個(gè)參數(shù):PHP_NORMAL_READ 和 PHP_BINARY_READ
慕運(yùn)維8079593
2019-03-16 00:15:25
