PHP连接Socket接口进行数据交互的完整实现

核心功能目标

本例旨在构建一个简单的C/S架构测试场景：PHP客户端发起连接，发送格式化指令（例如 getmaillist\r\n{id}），Java服务端解析后返回模拟数据，最终在PHP端输出拼接后的结果字符串。

环境准备与端口配置

在进行代码编写前，请确保以下基础条件已满足：

1. 网络库支持：PHP运行环境需启用 sockets 扩展。可通过 php -m | grep sockets 检查，若未开启需在 php.ini 中取消注释 extension=sockets。
2. 端口开放：监听端口 10003 需在服务器防火墙中放行，且未被其他进程占用。
3. 编码统一：确保PHP头信息及数据流转均使用 UTF-8 编码，避免中文乱码。

第1步：编写Java Socket服务端

服务端负责监听指定端口，接收客户端发来的字节流，解析协议头部与参数，并返回处理结果。

1. 导入依赖与定义主类

使用Java标准库即可实现，无需额外框架。重点在于 ServerSocket 的绑定与 PrintWriter 的输出设置。

import java.io.InputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class Test {
  public static void main(String[] args) throws Exception {
    // 监听10003端口
    ServerSocket serverSocket = new ServerSocket(10003);

    while (true) {
      System.out.println("等待连接...");
      Socket socket = serverSocket.accept();

      InputStream is = socket.getInputStream();
      byte[] b = new byte[1024];
      int len = is.read(b);
      String inputString = new String(b, 0, len);
      
      // 自动刷新输出的PrintWriter
      PrintWriter pw=new PrintWriter(socket.getOutputStream(),true);
      String result="";

2. 协议解析逻辑

服务端需根据约定格式拆分数据：第一行：请求方法，第二行：JSON/键值对参数。若格式不符，则返回错误标识。

      // 处理发来的数据
      if(inputString.contains("\r\n")){
        String[] params=inputString.split("\r\n");
        if(params[0].equals("getmaillist")){
          String maillist=getmaillist();
          result="请求方法："+params[0]+",请求参数："+params[1]+",请求结果："+maillist;
        }else{
          result="非法参数2";
        }
      }else{
        result="非法参数1";
      }

3. 返回结果与资源释放

将拼接好的结果写回客户端，并关闭当前会话连接。为便于测试，模拟数据直接返回固定文本。

      pw.println(result);
      socket.close();
    }
  }
  
  // 模拟获取邮件列表数据的方法
  public static String getmaillist(){
    return "中国上海/2015年7月28日——服务于中国及全球华人社群的领先在线媒体公司新浪公司(Nasdaq GS: SINA)...";
  }
}

第2步：编写PHP Socket客户端

客户端封装为一个测试类 Test，核心逻辑包括创建套接字、连接目标地址、写入数据包以及循环读取响应。

1. 初始化连接配置

定义IP与端口常量，设置HTTP头以便浏览器正常显示HTML结果。

<?php
class Test{
  const IP='127.0.0.1';
  const port=10003;

  public static function main(){
    header("Content-type:text/html;Charset=UTF-8");
    $socket=new Test();
    // 构造请求字符串：方法 + 换行 + 参数
    $requestStr = "getmaillist\r\n{"id":2}\r\n";
    $result=$socket->connSocket($requestStr);
    echo $result;
  }

2. 执行Socket操作

使用 socket_create 建立IPv4 TCP流式连接。注意：连接成功后，必须使用 socket_write 发送数据，并通过 socket_read 在循环中读取所有剩余数据，直到缓冲区为空。

  private function connSocket($str){
    // 1. 创建Socket句柄
    $socket = socket_create(AF_INET,SOCK_STREAM,SOL_TCP);
    if($socket === false) {
        die("Socket创建失败: " . socket_strerror(socket_last_error()));
    }

    // 2. 连接服务端
    $res=@socket_connect($socket,self::IP,self::port);
    if(!$res){
      socket_close($socket);
      return "连接服务器失败";
    }

    // 3. 写入请求数据
    socket_write($socket,$str);

    // 4. 循环读取响应
    $result="";
    while($data = socket_read($socket,1024)){
      $result.=$data;
    }

    // 5. 关闭连接
    socket_close($socket);
    return $result;
  }
}
Test::main();
?>

效果验证

当Java服务端启动且处于监听状态时，运行上述PHP脚本，控制台或浏览器将输出如下格式的交互结果：

该结果证实了PHP成功穿透TCP连接，并向Java端传输了解析所需的结构化数据，服务端亦正确响应。

关键注意事项

• 字符编码：若涉及中文传输，建议在Java服务端使用 new String(b, 0, len, "UTF-8") 显式指定编码，防止平台默认编码差异导致乱码。
• 长连接处理：本例为短连接模式，每次请求完成后即关闭Socket。若需高性能并发，需引入异步IO或线程池管理连接生命周期。
• 异常捕获：生产环境中应对 socket_connect 和 socket_read 增加超时设置（如 socket_set_option），避免因网络阻塞导致PHP脚本挂起。

以上就是PHP请求Socket接口测试实例的详细内容，更多关于PHP Socket网络编程的资料请关注本站其它相关文章！