很简单的一个socket客户端PHP类

php 5，需要打开socket扩展

1. //socke操作类
2. class Socket {
3. private $host;//连接socket的主机
4. private $port;//socket的端口号
5. private $error=array();
6. private $socket=null;//socket的连接标识
7. private $queryStr="";//发送的数据
8. public function __construct($host,$port) {
9. if(!extension_loaded("sockets")){
10. exit("请打开socket扩展 ");
11. }
12. if(empty($host)) exit("请输入目标地址");
13. if(empty($port)) exit("请输入有效的端口号");
14. $this->host=$host;
15. $this->port=$port;
16. $this->CreateSocket();//创建连接
17. }
19. //创建socket
20. private function CreateSocket(){
21. !$this->socket&&$this->socket=socket_create(AF_INET, SOCK_STREAM, SOL_TCP);//创建socket
22. $r=@socket_connect($this->socket,$this->host,$this->port);
23. if($r){
24. return $r;
25. }else{
26. $this->error[]=socket_last_error($this->socket);
27. return false;
28. }
29. }
31. //向socket服务器写入数据并读取
32. public function wr($contents){
33. $this->queryStr="";
34. $this->queryStr=$contents;
35. !$this->socket&&$this->CreateSocket();
36. $contents=$this->fliterSendData($contents);
37. $result=socket_write($this->socket,$contents,strlen($contents));
38. if(!intval($result)){
39. $this->error[]=socket_last_error($this->socket);
40. return false;
41. }
42. $response=socket_read($this->socket,12048);
43. if(false===$response){
44. $this->error[]=socket_last_error($this->socket);
45. return false;
46. }
47. return $response;
48. }
51. //对发送的数据进行过滤
52. private function fliterSendData($contents){
53. //对写入的数据进行处理
54. return $contents;
55. }
58. //所有错误信息
59. public function getError(){
60. return $this->error;
61. }
63. //最后一次错误信息
64. public function getLastError(){
65. return $this->error(count($this->error));
66. }
67. //获取最后一次发送的消息
68. public function getLastMsg(){
69. return $this->queryStr;
70. }
72. public function getHost(){
73. return $this->host;
74. }
76. public function getPort(){
77. return $this->port;
78. }
80. //关闭socket连接
81. private function close(){
82. $this->socket&&socket_close($this->socket);//关闭连接
83. $this->socket=null;//连接资源初始化
84. }
86. public function __destruct(){
87. $this->close();
88. }
89. }

复制代码

很简单, socket, PHP