thinkphp socket类的简单使用
服务端
<?php
//报错级别
error_reporting(E_ALL);
//设置长链接
set_time_limit(0);
//ip
$address = "127.0.0.1";
//端口
$port = 10005;
//创建一个套接字
if( ($sock = socket_create(AF_INET, SOCK_STREAM, SOL_TCP)) ===false){
echo "创建一个套接字 失败" . "\n";
}
//启动套接字
if(socket_bind($sock, $address,$port)===false){
echo "启动套接字 失败" . socket_strerror(socket_last_error($sock)) . "\n";
}
//监听端口
if(socket_listen($sock,5) === false){
echo "监听端口 失败" . socket_strerror(socket_last_error($sock)) . "\n";
}
do {
//似乎是接收客户端传来的消息
if(($msgsock=socket_accept($sock))===false){
echo "socket_accepty() failed :reason:".socket_strerror(socket_last_error($sock)) . "\n";
break;
}
//echo "读取客户端传来的消息"."\n";
$buf = socket_read($msgsock, 8192);
$talkback = "我已经成功接到客户端的信息了。现在我还回信息给客户端"."\n";
if(false=== socket_write($msgsock, $talkback)){
echo "socket_write() failed reason:" . socket_strerror(socket_last_error($sock)) ."\n";
}else{
echo "return info msg ku fu duan success"."\n";
}
socket_close($msgsock);
}while (true);
socket_close($sock);
?>
客户端
引入Tp的socket类
<?php
require("./Socket.class.php");
$confing = array(
'persistent' => false,
'host' => 'localhost',
'protocol' => 'tcp',
'port' => 10005,
'timeout' => 1800
);
$Socket = new Socket($confing);
if($Socket->connect()){
echo "TP类 创建Socket链接成功!<hr>";
}else{
echo "TP类 创建Socket链接失败!<hr>";
}
$data = "我是客户端,我要发数据给服务端";
$Socket->write($data);
$read = $Socket->read();
//$read 是服务端还回的数据
echo $read."<hr >";
$Socket->disconnect();
?>
附件
socket.zip
( 3.06 KB 下载:1250 次 )