首頁 後端開發 php教程 php socket通信演示以及socket操作类

php socket通信演示以及socket操作类

Jun 23, 2016 pm 01:06 PM

  

  准备做Java的课程设计,一个通讯录。采用C/S架构。客户端用java FX和Java,服务器端用php,采用socket通信。

  下面来讲一讲php的socket通信:

  将之前,得先讲一下TCP/IP,UDP。随着互联网应用的日益广泛,相信很多人或多或少都听说过这些协议,那么到底它们是什么呢?

  1、什么是TCP/IP、UDP?

         TCP/IP(Transmission Control Protocol/Internet Protocol)即传输控制协议/网间协议,是一个工业标准的协议集,它是为广域网(WANs)设计的。TCP/IP协议族包括运输层、网络层、链路层。
         UDP(User Data Protocol,用户数据报协议)是与TCP相对应的协议。它是属于TCP/IP协议族中的一种。

            下面我们上图直观地展示一下它们的关系:

               

   这里我们并没有socket什么事,那socket到底在哪里呢?又有什么用?别急,接下来我们就来介绍一下socket与它们的关系。同样上图。

      
    现在明白它们的关系了吧。那socket到底是什么?又有什么用?

       2、socket是什么?有什么用?

    Socket是应用层与TCP/IP协议族通信的中间软件抽象层,它是一组接口。在设计模式中,Socket其实就是一个门面模式,它把复杂的TCP/IP协议族隐藏在Socket接口后面,对用户来说,一组简单的接口就是全部,让Socket去组织数据,以符合指定的协议。

       既然socket是一组封装好的接口,那我们如何去运用他来通信呢?具体是一个什么流程呢?我们可以详细一下我们打电话的过程。首先我们的电话肯定是处于监听状态的,没错吧。如果不是,那肯定也不会接到别人打的电话。当被人打电话过来时,首先是先拨号,号码是目标,也是唯一的。拨号后电话会开始连接,接通了之后就可以开始交谈,聊完了之后要挂断电话,这样别人才能再打通这个号码。 socket也是一样的,服务器端要先建立socket监听自己电脑某个端口,当有客户端创建socket发起连接请求时接受,这样就可以开始传递信息了,传输完之后再把socket关闭。当然,服务器端也可以主动向客户端发起连接请求然后开始通信。这是区别于ajax,是可以双向通信的。下面看图:

        

  先从服务器端说起。服务器端先初始化Socket,然后与端口绑定(bind),对端口进行监听(listen),调用accept阻塞,等待客户端连接。在这时如果有个客户端初始化一个Socket,然后连接服务器(connect),如果连接成功,这时客户端与服务器端的连接就建立了。客户端发送数据请求,服务器端接收请求并处理请求,然后把回应数据发送给客户端,客户端读取数据,最后关闭连接,一次交互结束

 

       3、socket的相关函数 :

socket_accept() 接受一个Socket连接
socket_bind() 把socket绑定在一个IP地址和端口上
socket_clear_error() 清除socket的错误或最后的错误代码
socket_close() 关闭一个socket资源
socket_connect() 开始一个socket连接
socket_create_listen() 在指定端口打开一个socket监听
socket_create_pair() 产生一对没有差别的socket到一个数组里
socket_create() 产生一个socket,相当于产生一个socket的数据结构
socket_get_option() 获取socket选项
socket_getpeername() 获取远程类似主机的ip地址
socket_getsockname() 获取本地socket的ip地址
socket_iovec_add() 添加一个新的向量到一个分散/聚合的数组
socket_iovec_alloc() 这个函数创建一个能够发送接收读写的iovec数据结构
socket_iovec_delete() 删除一个已分配的iovec
socket_iovec_fetch() 返回指定的iovec资源的数据
socket_iovec_free() 释放一个iovec资源
socket_iovec_set() 设置iovec的数据新值
socket_last_error() 获取当前socket的最后错误代码
socket_listen() 监听由指定socket的所有连接
socket_read() 读取指定长度的数据
socket_readv() 读取从分散/聚合数组过来的数据
socket_recv() 从socket里结束数据到缓存
socket_recvfrom() 接受数据从指定的socket,如果没有指定则默认当前socket
socket_recvmsg() 从iovec里接受消息
socket_select() 多路选择
socket_send() 这个函数发送数据到已连接的socket
socket_sendmsg() 发送消息到socket
socket_sendto() 发送消息到指定地址的socket
socket_set_block() 在socket里设置为块模式
socket_set_nonblock() socket里设置为非块模式
socket_set_option() 设置socket选项
socket_shutdown() 这个函数允许你关闭读、写、或指定的socket
socket_strerror() 返回指定错误号的周详错误
socket_write() 写数据到socket缓存
socket_writev() 写数据到分散/聚合数组

 

 

4、socket通信演示:

//服务器端:<br /><?php//确保在连接客户端时不会超时set_time_limit(0);$ip = '127.0.0.1';$port = 1935;/* +------------------------------- *    @socket通信整个过程 +------------------------------- *    @socket_create *    @socket_bind *    @socket_listen *    @socket_accept *    @socket_read *    @socket_write *    @socket_close +-------------------------------- */if(($sock = socket_create(AF_INET,SOCK_STREAM,SOL_TCP)) < 0) {    echo "socket_create() 失败的原因是:".socket_strerror($sock)."\n";}if(($ret = socket_bind($sock,$ip,$port)) < 0) {    echo "socket_bind() 失败的原因是:".socket_strerror($ret)."\n";}if(($ret = socket_listen($sock,4)) < 0) {    echo "socket_listen() 失败的原因是:".socket_strerror($ret)."\n";}$count = 0;do {    if (($msgsock = socket_accept($sock)) < 0) {        echo "socket_accept() failed: reason: " . socket_strerror($msgsock) . "\n";        break;    } else {                //发到客户端        $msg ="测试成功!\n";        socket_write($msgsock, $msg, strlen($msg));                echo "测试成功了啊\n";        $buf = socket_read($msgsock,8192);                        $talkback = "收到的信息:$buf\n";        echo $talkback;                if(++$count >= 5){            break;        };                }    socket_close($msgsock);} while (true);socket_close($sock);?>
登入後複製

//客户端<br /><?phperror_reporting(E_ALL);set_time_limit(0);$ip = "127.0.0.1";$port = 1935;/* +------------------------------- *    @socket连接整个过程 +------------------------------- *    @socket_create *    @socket_connect *    @socket_write *    @socket_read *    @socket_close +-------------------------------- */$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);if ($socket < 0) {    echo "socket_create() failed: reason: " . socket_strerror($socket) . "\n";}else {    echo "OK.\n";}echo "试图连接 '$ip' 端口 '$port'...\n";$result = socket_connect($socket, $ip, $port);if ($result < 0) {    echo "socket_connect() failed.\nReason: ($result) " . socket_strerror($result) . "\n";}else {    echo "连接OK\n";}$in = "Ho\r\n";$in .= "first blood\r\n";$out = '';if(!socket_write($socket, $in, strlen($in))) {    echo "socket_write() failed: reason: " . socket_strerror($socket) . "\n";}else {    echo "发送到服务器信息成功!\n";    echo "发送的内容为:<font color='red'>$in</font> <br>";}while($out = socket_read($socket, 8192)) {    echo "接收服务器回传信息成功!\n";    echo "接受的内容为:",$out;}echo "关闭SOCKET...\n";socket_close($socket);echo "关闭OK\n";?>
登入後複製

  注意:1)服务器端要用CLI方式运行,也就是命令行模式运行。不要用CGI方式(浏览器访问);找到php.exe所在目录,然后运行以下代码,php 服务器文件;

    

2)运行之后可以另开dos窗口下运行netstat -ano查看端口占用情况。

    

  5、把socket封装成类:

//ServerSocket.class.php<br />//客户端socket操作类
登入後複製
<?php   error_reporting(E_ALL);   set_time_limit(0);      class ServerSocket {        private $server_host;  //服务器IP     private $server_port;  //服务器端口     private $client_host;  //客户端IP     private $client_port;  //客户端端口     private $create_socket=null;        private $accept_socket=null;     private $get_data="";     private $send_data="";              //够造函数     public function __construct($host,$port){         if(!extension_loaded("socket")){             exit("请先打开socket扩展!");         }         if(empty($host))              exit("请输入目标主机IP!");         if(empty($port))             exit("请输入有效端口号!");         $this->server_host=$host;         $this->server_port=$port;         $this->CreateSocket();     }          //创建一个socket并将其用来绑定监听端口     private function createSocket(){           if($this->create_socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)==false){                 echo "socket_create() failed. reason:".socket_strerror(socket_last_error())."\n";           }           if(socket_bind($this->create_socket,$this->server_host,$this->server_port)==false){               echo "socket_bind()failed. reason:".socket_strerror(socket_last_error($this->create_socket))."\n";           }           if(socket_listen($this->create_socket,5)==false){               echo "socket_listen()failed. reason:".socket_strerror(socket_last_error($this->create_socket))."\n";           }             }          //向目标主机发起连接     public function connectClient(){         if(socket_getpeername($this->create_socket,$this->client_host,$this->client_port)==null){             echo "socket_getpeername()failed. reason:".socket_strerror(socket_last_error($this->create_socket))."\n";         }         if(socket_connect($this->create_socket,$this->client_host,$this->client_port)==false){             echo "socket_connect()failed. reason:".socket_strerror(socket_last_error($this->create_socket))."\n";         }     }     //接受连接获取到一个socket资源,想客户端读取以及传输信息     public function wr(){         do{   //循环防止阻塞延迟             if($this->accept_socket=socket_accept($this->create_socket)==null){                 echo "socket_accept()failed. reason:".socket_strerror(socket_last_error($this->create_socket))."\n";                 break;             }                          $this->get_data = socket_read($this->accept_socket, 8192);             $this->send_data=$this->operateData($this->get_data);             if (socket_write($this->accept_socket,$this->send_data, strlen($this->send_data))==false) {                 echo "socket_write() failed reason:" . socket_strerror(socket_last_error($this->accept_socket)) ."\n";             }             socket_close($this->accept_socket);         }while(true);               }          //数据处理     private function operateData(){                  return ;     }          //关闭监听socket     private function closeSocket(){         socket_close($this->createSocket);     }          //析构函数     public function  __destruct(){          $this->closeSocket();     }   }        
登入後複製

//ClientSocket.class.php//客户端socke操作类class Socket {    private $host;//连接socket的主机    private $port;//socket的端口号     private $error=array();    private $socket=null;//socket的连接标识    private $queryStr="";//发送的数据    public function __construct($host,$port) {        if(!extension_loaded("sockets")){            exit("请打开socket扩展 ");        }        if(empty($host)) exit("请输入目标地址");        if(empty($port)) exit("请输入有效的端口号");        $this->host=$host;        $this->port=$port;        $this->CreateSocket();//创建连接            }    //创建socket    private function CreateSocket(){        !$this->socket&&$this->socket=socket_create(AF_INET, SOCK_STREAM, SOL_TCP);//创建socket        $r=@socket_connect($this->socket,$this->host,$this->port);        if($r){            return $r;        }else{            $this->error[]=socket_last_error($this->socket);            return false;        }    }    //向socket服务器写入数据并读取    public function wr($contents){        $this->queryStr="";        $this->queryStr=$contents;        !$this->socket&&$this->CreateSocket();        $contents=$this->fliterSendData($contents);        $result=socket_write($this->socket,$contents,strlen($contents));        if(!intval($result)){            $this->error[]=socket_last_error($this->socket);            return false;        }        $response=socket_read($this->socket,12048);        if(false===$response){            $this->error[]=socket_last_error($this->socket);            return false;        }        return $response;    }    //对发送的数据进行过滤    private function fliterSendData($contents){        //对写入的数据进行处理        return $contents;    }    //所有错误信息     public function getError(){        return $this->error;    }    //最后一次错误信息    public function getLastError(){        return $this->error(count($this->error));    }        //获取最后一次发送的消息    public function getLastMsg(){        return $this->queryStr;    }    public function getHost(){        return $this->host;    }    public function getPort(){        return $this->port;    }    //关闭socket连接    private function close(){        $this->socket&&socket_close($this->socket);//关闭连接        $this->socket=null;//连接资源初始化    }    public function __destruct(){        $this->close();    }}
登入後複製

 

本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn

熱AI工具

Undresser.AI Undress

Undresser.AI Undress

人工智慧驅動的應用程序,用於創建逼真的裸體照片

AI Clothes Remover

AI Clothes Remover

用於從照片中去除衣服的線上人工智慧工具。

Undress AI Tool

Undress AI Tool

免費脫衣圖片

Clothoff.io

Clothoff.io

AI脫衣器

Video Face Swap

Video Face Swap

使用我們完全免費的人工智慧換臉工具,輕鬆在任何影片中換臉!

熱門文章

<🎜>:泡泡膠模擬器無窮大 - 如何獲取和使用皇家鑰匙
3 週前 By 尊渡假赌尊渡假赌尊渡假赌
北端:融合系統,解釋
3 週前 By 尊渡假赌尊渡假赌尊渡假赌
Mandragora:巫婆樹的耳語 - 如何解鎖抓鉤
3 週前 By 尊渡假赌尊渡假赌尊渡假赌

熱工具

記事本++7.3.1

記事本++7.3.1

好用且免費的程式碼編輯器

SublimeText3漢化版

SublimeText3漢化版

中文版,非常好用

禪工作室 13.0.1

禪工作室 13.0.1

強大的PHP整合開發環境

Dreamweaver CS6

Dreamweaver CS6

視覺化網頁開發工具

SublimeText3 Mac版

SublimeText3 Mac版

神級程式碼編輯軟體(SublimeText3)

熱門話題

Java教學
1666
14
CakePHP 教程
1425
52
Laravel 教程
1324
25
PHP教程
1272
29
C# 教程
1251
24
說明PHP中的安全密碼散列(例如,password_hash,password_verify)。為什麼不使用MD5或SHA1? 說明PHP中的安全密碼散列(例如,password_hash,password_verify)。為什麼不使用MD5或SHA1? Apr 17, 2025 am 12:06 AM

在PHP中,應使用password_hash和password_verify函數實現安全的密碼哈希處理,不應使用MD5或SHA1。1)password_hash生成包含鹽值的哈希,增強安全性。 2)password_verify驗證密碼,通過比較哈希值確保安全。 3)MD5和SHA1易受攻擊且缺乏鹽值,不適合現代密碼安全。

PHP和Python:比較兩種流行的編程語言 PHP和Python:比較兩種流行的編程語言 Apr 14, 2025 am 12:13 AM

PHP和Python各有優勢,選擇依據項目需求。 1.PHP適合web開發,尤其快速開發和維護網站。 2.Python適用於數據科學、機器學習和人工智能,語法簡潔,適合初學者。

PHP行動:現實世界中的示例和應用程序 PHP行動:現實世界中的示例和應用程序 Apr 14, 2025 am 12:19 AM

PHP在電子商務、內容管理系統和API開發中廣泛應用。 1)電子商務:用於購物車功能和支付處理。 2)內容管理系統:用於動態內容生成和用戶管理。 3)API開發:用於RESTfulAPI開發和API安全性。通過性能優化和最佳實踐,PHP應用的效率和可維護性得以提升。

PHP:網絡開發的關鍵語言 PHP:網絡開發的關鍵語言 Apr 13, 2025 am 12:08 AM

PHP是一種廣泛應用於服務器端的腳本語言,特別適合web開發。 1.PHP可以嵌入HTML,處理HTTP請求和響應,支持多種數據庫。 2.PHP用於生成動態網頁內容,處理表單數據,訪問數據庫等,具有強大的社區支持和開源資源。 3.PHP是解釋型語言,執行過程包括詞法分析、語法分析、編譯和執行。 4.PHP可以與MySQL結合用於用戶註冊系統等高級應用。 5.調試PHP時,可使用error_reporting()和var_dump()等函數。 6.優化PHP代碼可通過緩存機制、優化數據庫查詢和使用內置函數。 7

PHP的持久相關性:它還活著嗎? PHP的持久相關性:它還活著嗎? Apr 14, 2025 am 12:12 AM

PHP仍然具有活力,其在現代編程領域中依然佔據重要地位。 1)PHP的簡單易學和強大社區支持使其在Web開發中廣泛應用;2)其靈活性和穩定性使其在處理Web表單、數據庫操作和文件處理等方面表現出色;3)PHP不斷進化和優化,適用於初學者和經驗豐富的開發者。

PHP類型提示如何起作用,包括標量類型,返回類型,聯合類型和無效類型? PHP類型提示如何起作用,包括標量類型,返回類型,聯合類型和無效類型? Apr 17, 2025 am 12:25 AM

PHP類型提示提升代碼質量和可讀性。 1)標量類型提示:自PHP7.0起,允許在函數參數中指定基本數據類型,如int、float等。 2)返回類型提示:確保函數返回值類型的一致性。 3)聯合類型提示:自PHP8.0起,允許在函數參數或返回值中指定多個類型。 4)可空類型提示:允許包含null值,處理可能返回空值的函數。

PHP和Python:代碼示例和比較 PHP和Python:代碼示例和比較 Apr 15, 2025 am 12:07 AM

PHP和Python各有優劣,選擇取決於項目需求和個人偏好。 1.PHP適合快速開發和維護大型Web應用。 2.Python在數據科學和機器學習領域佔據主導地位。

PHP與其他語言:比較 PHP與其他語言:比較 Apr 13, 2025 am 12:19 AM

PHP適合web開發,特別是在快速開發和處理動態內容方面表現出色,但不擅長數據科學和企業級應用。與Python相比,PHP在web開發中更具優勢,但在數據科學領域不如Python;與Java相比,PHP在企業級應用中表現較差,但在web開發中更靈活;與JavaScript相比,PHP在後端開發中更簡潔,但在前端開發中不如JavaScript。

See all articles