一個菜鳥朋友,突然問了我這個問題...現在稍稍有點時間,就寫了一個簡單的例子給他,順便貼上來
服務器端:
$name=$val;
}
private function _showError($error){
exit($error);
}
/**
* 開始進行socket服務器端監聽端口
*/
public function start(){
// 創建端口
if (($sock = socket_create ( AF_INET, SOCK_STREAM, SOL_TCP )) === false) {
$this->_showError("socket_create() failed :reason:" . socket_strerror ( socket_last_error () ));
}
// 綁定
if (socket_bind ( $sock, $this->_address, $this->_port ) === false) {
$this->_showError("socket_bind() failed :reason:" . socket_strerror ( socket_last_error ( $sock ) ));
}
// 監聽
if (socket_listen ( $sock, 5 ) === false) {
$this->_showError("socket_bind() failed :reason:" . socket_strerror ( socket_last_error ( $sock ) ) );
}
do {
//當有一個客戶端連接的時候
if ($client_socket=socket_accept ( $sock )) {
$count = count ( $this->_client_socket_list ) + 1;
//把新來的用戶加入 客戶端數組裡
$this->_client_socket_list[]=$client_socket;
echo "new connection:\r\n";//服務器端輸出當前正在連接的客戶端數量
echo "current connection:{$count}\r\n";
//接受客戶端傳過來的字符串
$msg=$this->read($client_socket);
echo "client:{$msg}\r\n";
//服務器向客戶端傳值
$my_msg="I am fine,think you\r\n";
$this->send($client_socket,$my_msg);
}
/**
* 這段代碼給你參考,用來判斷是否有客戶端主動失去連接
else{
foreach ( $this->_client_socket_list as $socket ) {
$len = socket_recv ($socket, $buffer, 2048, 0 ); // 接受一下客戶端信息,如果為0代表斷開連接
if ($len < 7) {
//這裡寫是去連接的客戶端業務
}
}
}
*/
}while(true);
}
/**
* 發送數據給客戶端
*/
public function send($client_socket,$str){
return socket_write ( $client_socket,$str, strlen ( $str ) );
}
/**
* 從客戶端接受數據
*/
public function read($client_socket){
return socket_read ( $client_socket, 8192 );//8192實際代表的接受長度,我用819292表示長一點,這樣長一點的字符串也可以接受到,不到8192也沒關系,會自動識別
}
}
$socket_server =new SocketServer();
$socket_server->start();//開始監聽
$name=$val;
}
private function _showError($error){
exit($error);
}
/**
* 開始進行socket服務器端監聽端口
*/
public function start(){
// 創建端口
if (($sock = socket_create ( AF_INET, SOCK_STREAM, SOL_TCP )) === false) {
$this->_showError("socket_create() failed :reason:" . socket_strerror ( socket_last_error () ));
}
// 綁定
if (socket_bind ( $sock, $this->_address, $this->_port ) === false) {
$this->_showError("socket_bind() failed :reason:" . socket_strerror ( socket_last_error ( $sock ) ));
}
// 監聽
if (socket_listen ( $sock, 5 ) === false) {
$this->_showError("socket_bind() failed :reason:" . socket_strerror ( socket_last_error ( $sock ) ) );
}
do {
//當有一個客戶端連接的時候
if ($client_socket=socket_accept ( $sock )) {
$count = count ( $this->_client_socket_list ) + 1;
//把新來的用戶加入 客戶端數組裡
$this->_client_socket_list[]=$client_socket;
echo "new connection:\r\n";//服務器端輸出當前正在連接的客戶端數量
echo "current connection:{$count}\r\n";
//接受客戶端傳過來的字符串
$msg=$this->read($client_socket);
echo "client:{$msg}\r\n";
//服務器向客戶端傳值
$my_msg="I am fine,think you\r\n";
$this->send($client_socket,$my_msg);
}
/**
* 這段代碼給你參考,用來判斷是否有客戶端主動失去連接
else{
foreach ( $this->_client_socket_list as $socket ) {
$len = socket_recv ($socket, $buffer, 2048, 0 ); // 接受一下客戶端信息,如果為0代表斷開連接
if ($len < 7) {
//這裡寫是去連接的客戶端業務
}
}
}
*/
}while(true);
}
/**
* 發送數據給客戶端
*/
public function send($client_socket,$str){
return socket_write ( $client_socket,$str, strlen ( $str ) );
}
/**
* 從客戶端接受數據
*/
public function read($client_socket){
return socket_read ( $client_socket, 8192 );//8192實際代表的接受長度,我用819292表示長一點,這樣長一點的字符串也可以接受到,不到8192也沒關系,會自動識別
}
}
$socket_server =new SocketServer();
$socket_server->start();//開始監聽
