书中自有颜如玉。
?
鉴于好多朋友，根据官方文档苦于无法下手，特别是新手朋友们。刚接触的时候正是因为自己也有这样的困惑，才写下这篇文章，希望能帮助到你们，给到你们学习中的一点小小的动力。
一、开发环境
windows+phpstudy
创建好一个站点，新建好一个站点目录，注意php的版本必须大于7.1
二、thinkphp6的安装
?
?
?安装的一些命令，https://www.kancloud.cn/manual/thinkphp6_0/1037481?根据官方提供复制就好
composer config -g repo.packagist composer https://mirrors.aliyun.com/composer/
composer create-project topthink/think tp
?
?然后你会看到一堆
安装成功，注意去本地物理路径把文件放到根目录下，这步是根据我的个人习惯来的哈?
?然后去小皮改下项目的物理路径，thinkphp6默认的对外访问目录是public
?
本地访问下
?
恭喜你，thinkphp6安装成功
三、Workerman的安装和运用
?composer require topthink/think-worker
?恭喜，安装Workerman成功
1、自定义Workerman服务类目
?
2、WebSocket示例代码
?
view/index/index.html 代码如下?
<!DOCTYPE html>
<html>
<head>
<title>HTML5</title>
<meta charset="utf-8" />
<script src="https://cdn.bootcss.com/jquery/3.2.1/jquery.min.js"></script>
<script>
$(function() {
var socket;
var readyState = ["connecting", "connected", "closing", "closed"];
/* 打开连接事件 */
$("button:eq(0)").click(function() {
try {
/* 连接 */
// socket = new WebSocket("ws://39.96.9.241:6789");
socket = new WebSocket("ws://127.0.0.1:2345");
/* 绑定事件 */
socket.onopen = function() {
$("#msg").html("连接成功...");
};
socket.onmessage = function(e) {
$("#msg").html($("#msg").html() + "<br />" + e.data);
};
socket.onclose = function() {
$("#msg").html($("#msg").html() + "<br />关闭连接...");
};
} catch(exception) {
$("#msg").html($("#msg").html() + "<br />有错误发生");
}
});
/* 发送数据事件 */
$("button:eq(1)").click(function() {
/* 检查文本框是否为空 */
if($("#data").val() == "") {
alert("请输入数据！");
return;
}
try {
socket.send($("#data").val());
$("#msg").html($("#msg").html() + "<br />发送数据：" + $("#data").val());
} catch (exception) {
$("#msg").html($("#msg").html() + "<br />发送数据出错");
}
/* 清空文本框 */
$("#data").val("");
});
/* 断开连接 */
$("button:eq(2)").click(function() {
socket.close();
});
});
</script>
</head>
<body>
<h1>WebSocket示例</h1>
<input type="text" id="data" />
<button>打开连接</button>
<button>发送数据</button>
<button>关闭连接</button>
<p id="msg"></p>
</body>
</html>3、服务类的内容
?
<?php
namespace app\index\controller;
use think\facade\Db;
use think\worker\Server;
use Workerman\Lib\Timer;
define('HEARTBEAT_TIME', 20);// 心跳间隔55秒
class Worker extends Server
{
protected $socket = 'http://0.0.0.0:2345';
public function __construct()
{
parent::__construct();
$this->onMessage();
// 或者这样调用
$this->worker->onWorkerStart = function($worker)
{
echo "Worker starting...\n";
};
}
/**
* 收到信息
* @param $connection
* @param $data
*/
public function onMessage()
{
$this->worker->onMessage = function($connection, $data)
{
dump($data);
$connection->send($data);
};
}
}?4、开启服务
?5、简单运用
注意：细心的朋友看到最后会发现站点目录名称变了，不要紧的，附上源码地址
https://download.csdn.net/download/sinat_40751643/20720175
万水千山总是情，点个小赞行不行?
?