laravel中使用workman進(jìn)行長(zhǎng)連接

workman官方文檔http://doc3.workerman.net/640361

1.將推送的端口號(hào)在服務(wù)器開(kāi)放，阿里云在安全組規(guī)則里進(jìn)行添加

2.本人使用的是寶塔琐谤，用寶塔的小伙伴還需要再寶塔面板的安全中斗忌，放行端口號(hào)

3.php.ini中的extension=php_sockets.dll 擴(kuò)展打開(kāi)旺聚，（去掉前面的砰粹；即可）

4.查看phpinfo中的socket是否是enable

以上這些確定之后就可以正式開(kāi)始開(kāi)發(fā)socket了~

服務(wù)端

安裝workman

? composer require workerman/workerman

執(zhí)行php artisan

? ?執(zhí)行php artisan make:command orderSocketCommand?在app\Console\Commands生成orderSocketCommand?.php文件

? ??<?php

? ? ?namespace App\Console\Commands;

????use Illuminate\Console\Command;

????use Workerman\Worker;

????use Workerman\Lib\Timer;

????use Log;

????class orderSocketCommand extends Command

????{

? ? ????protected $signature = 'orderSocketCommand {action} {-d?}';#若果加上該選項(xiàng)碱璃，則以守護(hù)進(jìn)程運(yùn)行

? ? ????protected $description = 'Start a orderSocketCommand server';

? ? ????protected $heartbeatTime = 60;#消息間隔

? ? ????public function __construct() {

? ? ? ? ????parent::__construct();

? ????? }

? ????? public function handle() {

? ? ? ? ????global $argv;

? ? ? ? ????global $worker;

? ? ? ????? // argv[0] 默認(rèn)是當(dāng)前文件，可以不修改

? ? ? ? ????$argv[1] = $argv[2];

? ? ? ? ????$argv[2] = isset($argv[3]) ? "-{$argv[3]}" : '';

? ? ? ????? // 創(chuàng)建一個(gè)Worker監(jiān)聽(tīng)6666端口界酒，不使用任何應(yīng)用層協(xié)議

? ? ? ? ????$worker = new Worker("websocket://0.0.0.0:6666");

? ? ? ? ????$arg = $this->argument('action');

? ? ? ? ????switch ($arg) {

? ? ? ? ? ? ????case 'start':

? ? ? ? ? ? ? ? ????$this->start($worker);

? ? ? ? ? ? ? ????? break;

? ? ? ? ? ? ????case 'stop':

? ? ? ? ? ? ? ? ????$this->stop($worker);

? ? ? ? ? ? ? ? ????break;

? ? ? ????? }

? ????? }

? ? ????private function start($worker) {

? ? ? ? ????// 啟動(dòng)1個(gè)進(jìn)程對(duì)外提供服務(wù)

? ? ? ? ????$worker->count = 1;

? ? ? ? ????// worker進(jìn)程啟動(dòng)后建立一個(gè)內(nèi)部通訊端口

? ? ? ? ????$worker->onWorkerStart = function($worker){

? ? ? ? ? ????? // 每10秒執(zhí)行一次------需要加心跳檢測(cè)的打開(kāi)這個(gè)注釋?zhuān)⑿薷淖约旱倪壿?/p>

? ? ? ? ? ? ????// $timeInterval = 10;

? ? ? ? ? ????? // Timer::add($timeInterval, function() use ($worker) {

? ? ? ? ? ? ????//? ? ?$timeNow = time();

? ? ? ? ? ? ????//? ? ?foreach ($worker->connections as $connection) {

? ? ? ? ? ? ????//? ? ? ? ?// 有可能該connection還沒(méi)收到過(guò)消息庇谆，則lastMessageTime設(shè)置為當(dāng)前時(shí)間

? ? ? ? ? ? ????//? ? ? ? ?if (empty($connection->lastMessageTime)) {

? ? ? ? ? ? ????//? ? ? ? ? ? ?$connection->lastMessageTime = $timeNow;

? ? ? ? ? ? ????//? ? ? ? ?}

? ? ? ? ? ? ????//? ? ? ? ?// 上次通訊時(shí)間間隔大于心跳間隔，則認(rèn)為客戶端已經(jīng)下線串述，關(guān)閉連接

? ? ? ? ? ????? //? ? ? ? ?if ($timeNow - $connection->lastMessageTime > $this->heartbeatTime) {

? ? ? ? ? ????? //? ? ? ? ? ? ?// 檢測(cè)客戶端是否斷開(kāi)纲酗，客戶端是否回應(yīng)，未回應(yīng)斷開(kāi)

? ? ? ? ? ????? //? ? ? ? ? ? ?$connection->close();

? ? ? ? ? ????? //? ? ? ? ?}

? ? ? ? ? ? ????//? ? ?}

? ? ? ? ? ????? // });

? ? ? ? ? ????? // 開(kāi)啟一個(gè)內(nèi)部端口右蕊，方便內(nèi)部系統(tǒng)推送數(shù)據(jù)饶囚，Text協(xié)議格式文本+換行符

? ? ? ? ? ? ????$inner_text_worker = new Worker('text://0.0.0.0:8888');

? ? ? ? ? ? ????$inner_text_worker->onMessage = function($connection, $buffer)

? ? ? ? ? ? ????{

? ? ? ? ? ? ? ? ????global $worker;

? ? ? ? ? ? ? ? ????// $data數(shù)組格式萝风，里面有orderType紫岩，表示向那個(gè)orderType的頁(yè)面推送數(shù)據(jù)

? ? ? ? ? ? ? ? ????$data = json_decode($buffer, true);

? ? ? ? ? ? ? ? ????$orderType = $data['orderType'];

? ? ? ? ? ? ? ? ????// 通過(guò)workerman被因，向orderType的頁(yè)面推送數(shù)據(jù)

? ? ? ? ? ? ? ????? $result = $this->sendMessageByorderType($orderType, $buffer);

? ? ? ? ? ? ? ????? // 返回給客戶端推送結(jié)果

? ? ? ? ? ? ? ????? $connection->send($result? 'success' : 'fail');

? ? ? ? ? ????? };

? ? ? ? ? ? ????$inner_text_worker->listen();

? ? ? ? ????};

? ? ? ????? // 新增加一個(gè)屬性，用來(lái)保存orderType到connection的映射

? ? ? ? ????$worker->orderTypeConnections = array();

? ? ? ? ????// 當(dāng)有客戶端發(fā)來(lái)消息時(shí)執(zhí)行的回調(diào)函數(shù)

? ? ? ? ????$worker->onMessage = function($connection, $data)use($worker) {

? ? ? ? ? ????? // 判斷當(dāng)前客戶端是否已經(jīng)驗(yàn)證,既是否設(shè)置了orderType

? ? ? ? ? ????? if(!isset($connection->orderType)) {

? ? ? ? ? ? ? ? ????Log::info("Command orderSocketCommand 當(dāng)有客戶端發(fā)來(lái)orderType消息時(shí)執(zhí)行的回調(diào)函數(shù)中的send data：".$data);

? ? ? ? ? ? ? ????? $data = json_decode($data,true);

? ? ? ? ? ? ? ? ????$type = $data['orderType'];

? ? ? ? ? ? ? ? ????$connection->orderType =? $data['uid'] .'-'. $data['orderType'];

? ? ? ? ? ? ? ????? // 保存orderType到connection的映射堕花，這樣可以方便的通過(guò)orderType查找connection粥鞋，實(shí)現(xiàn)針對(duì)特定orderType推送數(shù)據(jù)

? ? ? ? ? ? ? ????? $worker->orderTypeConnections[$type][$connection->orderType] = $connection;

? ? ? ? ? ? ? ? ????$connection->send(json_encode($data));

? ? ? ? ? ? ? ? ????return;

? ? ? ? ? ????? }else{

? ? ? ? ? ? ? ? ????Log::info("Command orderSocketCommand 客戶端發(fā)來(lái)的所有消息：".json_encode($data));

? ? ? ? ? ? ? ? ????$connection->send($data);

? ? ? ? ? ? ? ? ????return;

? ? ? ? ? ????? }

? ? ? ????? };

? ? ? ? ????Worker::runAll();

? ? ????}

? ? ????// 針對(duì)orderType推送數(shù)據(jù)

? ????? private function sendMessageByorderType($orderType, $message) {

? ? ? ? ????global $worker;

? ? ? ? ????foreach($worker->orderTypeConnections[$orderType] as $connection) {

? ? ? ? ? ? ????$connection->send($message);

? ? ? ? ? ????? Log::info("Command orderSocketCommand 一個(gè)內(nèi)部端口呻粹，方便內(nèi)部系統(tǒng)推送數(shù)據(jù)send data：".json_encode($message));

? ? ? ?????}

? ? ? ?????return true;

? ? ????}

? ? ????private function stop($worker) {

? ? ? ? ????$worker->reloadable = false;

? ? ? ? ????$worker->onClose = function($connection) {

? ? ? ? ? ? ????echo "orderSocketCommand stop";

? ? ? ? ????};

? ? ? ? ????// 運(yùn)行worker

? ? ? ????? Worker::runAll();

? ????? }

????}

Kernel.php中添加

? ???protected $commands = [

? ? ? ? ? ? ? ? ......

????????? ? ? ? Commands\orderSocketCommand::class

????????? ? ];

?運(yùn)行

????????php artisan workerman start d

? ??????

????????Workerman[artisan] start in DEBUG mode

????????----------------------- WORKERMAN -----------------------------

????????Workerman version:3.5.22? ? ? ? ? PHP version:7.1.13

????????------------------------ WORKERS -------------------------------

????????user? ? ? ? ? worker? ? ? ? listen? ? ? ? ? ? ? ? ? ? ? ? ? processes status

????????root? ? ? ? ? none? ? ? ? ? websocket://0.0.0.0:666? ?1? ? ? ? ?[OK]?

????????----------------------------------------------------------------

????????Start success

這樣服務(wù)端就寫(xiě)好了等浊，官方文檔要好好看真的很有用

其中connection的映射這一塊一定要仔細(xì)看官網(wǎng)的例子：

????WorkerMan中如何向某個(gè)特定客戶端發(fā)送數(shù)據(jù)http://doc3.workerman.net/315238

客戶端

?將需要的數(shù)據(jù)信息推送到服務(wù)端（我寫(xiě)的數(shù)據(jù)邏輯之后，可以公共調(diào)用）

?<?php

????????namespace App\Models;

????????use Log;

????????class Common{

????????????public static function push($data){

????????????// 建立socket連接到內(nèi)部推送端口

????????????$client = stream_socket_client('tcp://127.0.0.1:8888', $errno, $errmsg, 1);//本地測(cè)試

????????????if (!$client) {

????????????????? ? ? ? ? ? throw new \Exception("{$errstr} ({$errno})", 1);

? ? ? ? ? ? ?}

????????????// 發(fā)送數(shù)據(jù)，注意5678端口是Text協(xié)議的端口撒踪，Text協(xié)議需要在數(shù)據(jù)末尾加上換行符

????????????fwrite($client, json_encode($data)."\n");

????????????// 讀取推送結(jié)果

????????????$result = fread($client, 4096);

????????????fclose($client);

????????????return $result;

????????}

? ?}

客戶端接收數(shù)據(jù)

?????var ws = null;

? ? connect();

? ? function connect() {

? ? ? ? // 創(chuàng)建一個(gè) websocket 連接

? ? ? ? ws = new WebSocket("ws://127.0.0.1:6666");//本地測(cè)試

? ? ? ? // websocket 創(chuàng)建成功事件

? ? ? ? ws.onopen = onopen;

? ? ? ? // websocket 接收到消息事件

? ? ? ? ws.onmessage = onmessage;

? ? ? ? ws.onclose = onclose;

? ? ? ? ws.onerror = onerror;

? ? }

?????function onopen(){

? ????????var orderType = document.querySelector("input#type").value;//這個(gè)用來(lái)區(qū)分socket的不同數(shù)據(jù)

? ????????var uid = document.querySelector("input#uid").value;

? ? ? ? ????var data = {'orderType':orderType,'uid':uid}

? ? ? ? ????ws.send(JSON.stringify(data));

? ? ? ? ????heartCheck.reset().start();? ? ? //心跳檢測(cè)重置

? ? }

?????// 接受服務(wù)端數(shù)據(jù)是觸發(fā)事件

? ? function onmessage(e) {

? ????heartCheck.reset().start();? ? ? //拿到任何消息都說(shuō)明當(dāng)前連接是正常的

? ????// socket推送的數(shù)據(jù)屬于string類(lèi)型掸绞，將其轉(zhuǎn)換成json格式

? ? ? ? var data = e.data;

? ? ? ? data = JSON.parse(data);

? ? ? ? if (data.hasOwnProperty('uid')) {

????????? console.log('不是所需要的數(shù)據(jù)')

? ? ? ? }else {

????????????? if (typeof(data) != 'number') {//心跳檢測(cè)的數(shù)據(jù)是999衔掸，這是不需要的數(shù)據(jù)

? ? ? ? ? ? ? var _token=$('meta[name=token]').attr('content');

? ????????????$.ajax({

????????????????????type: "post",

????????????????????url: "/sys/order/deal_data",

????????????????????data: {'_token':_token,'type':data.orderType},

????????????????????dataType: 'JSON',

????????????????????success: function(json) {

????????????????????????? var html = ''

? ? ? ? ? ? ? ? ? ? ? ? ? for (var i = 0; i < json.data.length; i++) {

????????????????????????????html += ``

????????????????????????????if (json.data[i].users == null) {

? ????????????????????????????html += ``

????????????????????????????}else{

? ? ? ? ? ? ? ? ? ? ? ? ? ? ? html += `` + json.data[i].users['username'] + `

????????????????????????????}

????????????????????????????html += `` + json.data[i].number + ``

????????????????????}

????????????????????var content = document.querySelector('#content');

????????????????????content.innerHTML = html

????????????????????// 自動(dòng)播放鈴聲

????????????????????var mp3 = "/music/test.mp3";

????????????????????var mp3 = new Audio(mp3);

????????????????????mp3.play(); //播放音樂(lè)提醒有新訂單

????????????????}

????????????});

? ? ? ? ?}

?????}

}

function onclose(){}

function onerror(){}

?//心跳檢測(cè)

var heartCheck = {

????timeout: 300000,? ? ? ? //五分鐘發(fā)一次心跳

????timeoutObj: null,

????serverTimeoutObj: null,

????reset: function(){

????clearTimeout(this.timeoutObj);

????clearTimeout(this.serverTimeoutObj);

????return this;

start: function(){

????var self = this;

????this.timeoutObj = setTimeout(function(){

????//這里發(fā)送一個(gè)心跳纬霞，后端收到后驱显，返回一個(gè)心跳消息，

????//onmessage拿到返回的心跳就說(shuō)明連接正常

????ws.send("9999");

????self.serverTimeoutObj = setTimeout(function(){//如果超過(guò)一定時(shí)間還沒(méi)重置伏恐，說(shuō)明后端主動(dòng)斷開(kāi)了

????ws.close();? ? ?//如果onclose會(huì)執(zhí)行reconnect翠桦，我們執(zhí)行ws.close()就行了.如果直接執(zhí)行reconnect 會(huì)觸發(fā)onclose導(dǎo)致重連兩次

????}, self.timeout)

????}, this.timeout)

}

這樣客戶端接收到數(shù)據(jù)的時(shí)候就會(huì)播放指定提示音了~

客戶端的心跳檢測(cè)參考：http://www.reibang.com/p/1141dcf6de3e

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者

人面猴
序言：七十年代末销凑，一起剝皮案震驚了整個(gè)濱河市仅炊，隨后出現(xiàn)的幾起案子抚垄，更是在濱河造成了極大的恐慌，老刑警劉巖桐经，帶你破解...
沈念sama閱讀 212,718評(píng)論 6贊 492
死咒
序言：濱河連續(xù)發(fā)生了三起死亡事件阴挣，死亡現(xiàn)場(chǎng)離奇詭異畔咧，居然都是意外死亡摹菠，警方通過(guò)查閱死者的電腦和手機(jī)骗爆，發(fā)現(xiàn)死者居然都...
沈念sama閱讀 90,683評(píng)論 3贊 385
救了他兩次的神仙讓他今天三更去死
文/潘曉璐我一進(jìn)店門(mén)摘投，熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)，“玉大人幸撕，你說(shuō)我怎么就攤上這事坐儿。” “怎么了炭菌？”我有些...
開(kāi)封第一講書(shū)人閱讀 158,207評(píng)論 0贊 348
道士緝兇錄：失蹤的賣(mài)姜人
文/不壞的土叔我叫張陵黑低，是天一觀的道長(zhǎng)酌毡。經(jīng)常有香客問(wèn)我枷踏，道長(zhǎng)菩暗，這世上最難降的妖魔是什么？我笑而不...
開(kāi)封第一講書(shū)人閱讀 56,755評(píng)論 1贊 284
?港島之戀（遺憾婚禮）
正文為了忘掉前任旭蠕，我火速辦了婚禮勋眯，結(jié)果婚禮上，老公的妹妹穿的比我還像新娘下梢。我一直安慰自己客蹋，他們只是感情好，可當(dāng)我...
茶點(diǎn)故事閱讀 65,862評(píng)論 6贊 386
惡毒庶女頂嫁案：這布局不是一般人想出來(lái)的
文/花漫我一把揭開(kāi)白布孽江。她就那樣靜靜地躺著讶坯，像睡著了一般。火紅的嫁衣襯著肌膚如雪辆琅。梳的紋絲不亂的頭發(fā)上，一...
開(kāi)封第一講書(shū)人閱讀 50,050評(píng)論 1贊 291
城市分裂傳說(shuō)
那天这刷，我揣著相機(jī)與錄音婉烟，去河邊找鬼。笑死暇屋，一個(gè)胖子當(dāng)著我的面吹牛似袁，可吹牛的內(nèi)容都是我干的。我是一名探鬼主播，決...
沈念sama閱讀 39,136評(píng)論 3贊 410
雙鴛鴦連環(huán)套：你想象不到人心有多黑
文/蒼蘭香墨我猛地睜開(kāi)眼昙衅，長(zhǎng)吁一口氣：“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼扬霜！你這毒婦竟也來(lái)了？” 一聲冷哼從身側(cè)響起而涉，我...
開(kāi)封第一講書(shū)人閱讀 37,882評(píng)論 0贊 268
萬(wàn)榮殺人案實(shí)錄
序言：老撾萬(wàn)榮一對(duì)情侶失蹤著瓶，失蹤者是張志新（化名）和其女友劉穎，沒(méi)想到半個(gè)月后啼县，有當(dāng)?shù)厝嗽跇?shù)林里發(fā)現(xiàn)了一具尸體材原，經(jīng)...
沈念sama閱讀 44,330評(píng)論 1贊 303
?護(hù)林員之死
正文獨(dú)居荒郊野嶺守林人離奇死亡，尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛以下內(nèi)容為張勛視角年9月15日...
茶點(diǎn)故事閱讀 36,651評(píng)論 2贊 327
?白月光啟示錄
正文我和宋清朗相戀三年季眷，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了华糖。大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片。...
茶點(diǎn)故事閱讀 38,789評(píng)論 1贊 341
活死人
序言：一個(gè)原本活蹦亂跳的男人離奇死亡瘟裸，死狀恐怖客叉，靈堂內(nèi)的尸體忽然破棺而出，到底是詐尸還是另有隱情话告，我是刑警寧澤兼搏，帶...
沈念sama閱讀 34,477評(píng)論 4贊 333
?日本核電站爆炸內(nèi)幕
正文年R本政府宣布，位于F島的核電站沙郭，受9級(jí)特大地震影響佛呻，放射性物質(zhì)發(fā)生泄漏。R本人自食惡果不足惜病线，卻給世界環(huán)境...
茶點(diǎn)故事閱讀 40,135評(píng)論 3贊 317
男人毒藥：我在死后第九天來(lái)索命
文/蒙蒙一吓著、第九天我趴在偏房一處隱蔽的房頂上張望。院中可真熱鬧送挑，春花似錦绑莺、人聲如沸。這莊子的主人今日做“春日...
開(kāi)封第一講書(shū)人閱讀 30,864評(píng)論 0贊 21
一樁弒父案纺裁，背后竟有這般陰謀
文/蒼蘭香墨我抬頭看了看天上的太陽(yáng)。三九已至司澎，卻和暖如春欺缘，著一層夾襖步出監(jiān)牢的瞬間，已是汗流浹背挤安。一陣腳步聲響...
開(kāi)封第一講書(shū)人閱讀 32,099評(píng)論 1贊 267
情欲美人皮
我被黑心中介騙來(lái)泰國(guó)打工谚殊，沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留，地道東北人蛤铜。一個(gè)月前我還...
沈念sama閱讀 46,598評(píng)論 2贊 362
代替公主和親
正文我出身青樓嫩絮，卻偏偏與公主長(zhǎng)得像丛肢，于是被迫代替她去往敵國(guó)和親。傳聞我的和親對(duì)象是個(gè)殘疾皇子絮记，可洞房花燭夜當(dāng)晚...
茶點(diǎn)故事閱讀 43,697評(píng)論 2贊 351

laravel中使用workman進(jìn)行長(zhǎng)連接

推薦閱讀更多精彩內(nèi)容