简体中文
简体中文
在 PHP 中，使用 socket 进行网络通信时，关闭连接的方式有很多种。其中，stream_socket_shutdown 函数是一种常见的方式，它允许开发者更精细地控制 socket 的关闭过程。了解 stream_socket_shutdown 的作用及其适用场景，对于提高代码的健壮性和性能至关重要。
stream_socket_shutdown 是 PHP 中用于关闭 socket 连接的一种方法。与简单的 fclose() 或 socket_close() 不同，它提供了更多的控制选项，允许开发者选择是否关闭读写操作，或者完全关闭连接。函数原型如下：
<span><span><span class="hljs-keyword">bool</span></span><span> </span><span><span class="hljs-title function_ invoke__">stream_socket_shutdown</span></span><span>(resource </span><span><span class="hljs-variable">$socket</span></span><span>, </span><span><span class="hljs-keyword">int</span></span><span> </span><span><span class="hljs-variable">$how</span></span><span>);
</span></span>$socket：表示待关闭的 socket 资源。
$how：控制关闭的操作类型。可以是以下几种：
STREAM_SHUT_RD：只关闭读取操作，保持写入功能。
STREAM_SHUT_WR：只关闭写入操作，保持读取功能。
STREAM_SHUT_RDWR：同时关闭读取和写入操作，完全关闭连接。
在某些应用场景中，客户端或服务器在发送完数据后不再需要写入，只需等待对方的响应。例如，HTTP 请求完成后，客户端不再发送数据，只需要等待服务器返回响应。这时可以使用 stream_socket_shutdown 来关闭写操作，减少资源消耗，提升性能。
示例代码：
<span><span><span class="hljs-variable">$socket</span></span><span> = </span><span><span class="hljs-title function_ invoke__">stream_socket_client</span></span><span>(</span><span><span class="hljs-string">"tcp://example.com:80"</span></span><span>);
</span><span><span class="hljs-title function_ invoke__">fwrite</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, </span><span><span class="hljs-string">"GET / HTTP/1.1\r\nHost: example.com\r\n\r\n"</span></span><span>);
</span><span><span class="hljs-comment">// 发送完请求后关闭写操作，不再发送数据</span></span><span>
</span><span><span class="hljs-title function_ invoke__">stream_socket_shutdown</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, STREAM_SHUT_WR);
</span><span><span class="hljs-comment">// 读取服务器响应</span></span><span>
</span><span><span class="hljs-variable">$response</span></span><span> = </span><span><span class="hljs-title function_ invoke__">fread</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, </span><span><span class="hljs-number">1024</span></span><span>);
</span><span><span class="hljs-title function_ invoke__">fclose</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>);
</span></span>在这个例子中，客户端已经发送完 HTTP 请求，不再需要向服务器写入数据，所以调用 stream_socket_shutdown 关闭写操作。
在某些应用中，客户端或服务器可能只需要从对方读取数据，而不再发送数据。此时，可以使用 stream_socket_shutdown 来关闭写操作，确保连接不再消耗无谓的写资源。例如，FTP 协议的某些模式下，客户端和服务器只需要进行数据读取，而不需要再进行写操作。
示例代码：
<span><span><span class="hljs-variable">$socket</span></span><span> = </span><span><span class="hljs-title function_ invoke__">stream_socket_client</span></span><span>(</span><span><span class="hljs-string">"tcp://example.com:21"</span></span><span>);
</span><span><span class="hljs-title function_ invoke__">fwrite</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, </span><span><span class="hljs-string">"USER anonymous\r\n"</span></span><span>);
</span><span><span class="hljs-title function_ invoke__">fwrite</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, </span><span><span class="hljs-string">"PASS anonymous\r\n"</span></span><span>);
</span><span><span class="hljs-comment">// 不再发送数据，关闭写操作</span></span><span>
</span><span><span class="hljs-title function_ invoke__">stream_socket_shutdown</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, STREAM_SHUT_WR);
</span><span><span class="hljs-comment">// 读取服务器返回的响应</span></span><span>
</span><span><span class="hljs-variable">$response</span></span><span> = </span><span><span class="hljs-title function_ invoke__">fread</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, </span><span><span class="hljs-number">1024</span></span><span>);
</span><span><span class="hljs-title function_ invoke__">fclose</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>);
</span></span>通过关闭写操作，可以减少不必要的资源占用，保证通信过程更高效。
对于一些需要双向通信的应用，如实时聊天系统或者网络游戏，通常会在客户端或服务器端完成数据交换后，调用 stream_socket_shutdown 来彻底关闭连接，释放所有相关资源。使用 STREAM_SHUT_RDWR 关闭连接，确保读取和写入操作都被妥善结束。
示例代码：
<span><span><span class="hljs-variable">$socket</span></span><span> = </span><span><span class="hljs-title function_ invoke__">stream_socket_client</span></span><span>(</span><span><span class="hljs-string">"tcp://example.com:12345"</span></span><span>);
</span><span><span class="hljs-comment">// 进行双向数据交换</span></span><span>
</span><span><span class="hljs-title function_ invoke__">fwrite</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, </span><span><span class="hljs-string">"Hello Server!"</span></span><span>);
</span><span><span class="hljs-variable">$response</span></span><span> = </span><span><span class="hljs-title function_ invoke__">fread</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, </span><span><span class="hljs-number">1024</span></span><span>);
</span><span><span class="hljs-comment">// 完成双向通信后彻底关闭连接</span></span><span>
</span><span><span class="hljs-title function_ invoke__">stream_socket_shutdown</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, STREAM_SHUT_RDWR);
</span><span><span class="hljs-title function_ invoke__">fclose</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>);
</span></span>此时，双方都已经不再需要继续通信，调用 stream_socket_shutdown 关闭读取和写入操作，确保 socket 连接完全关闭。
在一些特殊的情况下，网络连接可能因异常中断或错误需要被关闭。使用 stream_socket_shutdown 可以更细粒度地控制 socket 的关闭过程。例如，如果发生网络中断或应用程序异常，可以选择性地关闭读取或写入操作，防止继续占用资源。
示例代码：
<span><span><span class="hljs-variable">$socket</span></span><span> = </span><span><span class="hljs-title function_ invoke__">stream_socket_client</span></span><span>(</span><span><span class="hljs-string">"tcp://example.com:80"</span></span><span>);
</span><span><span class="hljs-keyword">if</span></span><span> (!</span><span><span class="hljs-variable">$socket</span></span><span>) {
</span><span><span class="hljs-keyword">die</span></span><span>(</span><span><span class="hljs-string">"Unable to connect to server"</span></span><span>);
}
</span><span><span class="hljs-comment">// 假设某些错误发生，停止数据写入</span></span><span>
</span><span><span class="hljs-title function_ invoke__">stream_socket_shutdown</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, STREAM_SHUT_WR);
</span><span><span class="hljs-comment">// 继续读取错误信息或者通知用户</span></span><span>
</span><span><span class="hljs-variable">$response</span></span><span> = </span><span><span class="hljs-title function_ invoke__">fread</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, </span><span><span class="hljs-number">1024</span></span><span>);
</span><span><span class="hljs-title function_ invoke__">fclose</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>);
</span></span>在这里，出现异常或错误时，我们通过关闭写操作，避免进一步尝试写入数据，减轻对服务器的影响。
有些应用可能需要实现超时机制，即在连接长时间没有响应时主动关闭 socket 连接。在这种情况下，stream_socket_shutdown 可以用来关闭不再需要的连接，从而避免等待死锁或长时间占用网络资源。
示例代码：
<span><span><span class="hljs-variable">$socket</span></span><span> = </span><span><span class="hljs-title function_ invoke__">stream_socket_client</span></span><span>(</span><span><span class="hljs-string">"tcp://example.com:80"</span></span><span>, </span><span><span class="hljs-variable">$errno</span></span><span>, </span><span><span class="hljs-variable">$errstr</span></span><span>, </span><span><span class="hljs-number">30</span></span><span>);
</span><span><span class="hljs-keyword">if</span></span><span> (!</span><span><span class="hljs-variable">$socket</span></span><span>) {
</span><span><span class="hljs-keyword">die</span></span><span>(</span><span><span class="hljs-string">"Unable to connect: <span class="hljs-subst">$errstr</span></span></span><span> (</span><span><span class="hljs-subst">$errno</span></span><span>)");
}
</span><span><span class="hljs-comment">// 设置超时机制，超时后关闭连接</span></span><span>
</span><span><span class="hljs-title function_ invoke__">stream_set_timeout</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, </span><span><span class="hljs-number">10</span></span><span>); </span><span><span class="hljs-comment">// 设置超时时间为10秒</span></span><span>
</span><span><span class="hljs-variable">$response</span></span><span> = </span><span><span class="hljs-title function_ invoke__">fread</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, </span><span><span class="hljs-number">1024</span></span><span>);
</span><span><span class="hljs-keyword">if</span></span><span> (</span><span><span class="hljs-title function_ invoke__">feof</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>)) {
</span><span><span class="hljs-keyword">echo</span></span><span> </span><span><span class="hljs-string">"Connection timed out or completed.\n"</span></span><span>;
</span><span><span class="hljs-title function_ invoke__">stream_socket_shutdown</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>, STREAM_SHUT_RDWR);
}
</span><span><span class="hljs-title function_ invoke__">fclose</span></span><span>(</span><span><span class="hljs-variable">$socket</span></span><span>);
</span></span>在这个例子中，如果连接在 10 秒内没有响应，stream_socket_shutdown 会被调用来关闭连接。
stream_socket_shutdown 在 PHP 中是一个非常有用的函数，能够提供对 socket 连接关闭的细粒度控制。它适用于多种场景，包括单向通信时关闭写操作、双向通信完成后的连接关闭、网络异常处理等。了解其使用方式，能够帮助开发者更有效地管理网络资源，提高应用的稳定性和性能。
