在laravel5.8中集成swoole组件----用协程实现的服务端和客户端(nginx配置篇章)

  • laravel项目中的配置  原文出处:https://laravelacademy.org/post/19700.html,感谢原文作者让laravel这款可爱的php框架,进入了高并发的殿堂
如果你已经成功安装了laravelS组件,并用他接管了你的laravel项目,那么接下来就是实现一个websocket服务器的类,
类声明在项目app目录下的Services(没有就自己建一个)目录,

也许这些命名空间已经多的把你吓了一跳,但其实他们都源自你安装的laravelS组件,类的实现部分你也许并不感到陌生,没错,
他们就是按照swoole websocket原生类进行了封装
Hhxsv5类空间的源码可以参照 项目空间下的vendor/hhxsv5/laravel-s/src/Swoole/Coroutine
<?php
namespace App\Services;

use Hhxsv5\LaravelS\Swoole\WebSocketHandlerInterface;
use Illuminate\Support\Facades\Log;
use Swoole\Http\Request;
use Swoole\WebSocket\Frame;
use Swoole\WebSocket\Server;
class mywebsocket implements WebSocketHandlerInterface
{

public function __construct()
{
Log::info('launching laravel-swoole websocket');
}

public function onOpen(Server $server, Request $request)
{
Log::info('launching swoole websocket');
$server->push($request->fd,'欢迎使用,基于swoole的laravel websocket');
}

public function onMessage(Server $server, Frame $frame)
{
$server->push($frame->fd,date('Y-m-dH:i:s').'服务器响应你的请求');
}

public function onClose(Server $server, $fd, $reactorId)
{
Log::info('websocket服务器关闭');
}
}

然后,你就要到config目录下找到laravels.php,进行一番配置。

找到下列关联数组的键名,并作配置

'websocket'                => ['enable' => true,'handler'=>\App\Services\mywebsocket::class,#这个就是上述声明的类//'handler' => XxxWebSocketHandler::class,],
'swoole' => [...// 每隔 60s 检测一次所有连接,如果某个连接在 600s 内都没有发送任何数据,则关闭该连接'heartbeat_idle_time'      => 600,'heartbeat_check_interval' => 60,...
],
  • nginx配置部分(分站点配置)
如果你对nginx多站点配置还感到陌生,可以随便搜罗一篇博文来看,这里的配置是在分站点目录vhosts下的,针对目标站点的 
.conf文件进行配置的,如果你急于上机,不妨全部拷贝,把域名
更改过来
map $http_upgrade $connection_upgrade #这行代码的目的是把http协议 “提升”到websocket协议的标准
{
default upgrade;'' close; } upstream laravels {#server后面是需要监听的ip地址,如果你使用了docker容器部署你的项目,那server后面跟的是容器名# Connect IP:Portserver yinti.com:5200 weight=5 max_fails=3 fail_timeout=30s;keepalive 16; }server {listen 88;#端口可以根据项目实际需要进行调整server_name yinti.com;root /dingshub2/yinti/public;index index.html index.htm index.php;location / {# WordPress固定链接URL重写try_files $uri @laravels;}# PHP配置location ~ \.php$ {fastcgi_pass 127.0.0.1:9000;fastcgi_index index.php;fastcgi_param SCRIPT_FILENAME $document_root$fastcgi_script_name;include fastcgi_params;}#下面这段是websocket服务器的具体部署实现location =/ws {# proxy_connect_timeout 60s;# proxy_send_timeout 60s;# proxy_read_timeout: Nginx will close the connection if
the proxied server does not send data to Nginx in 60 seconds; # At the same time, this close behavior is also affected by heartbeat setting of Swoole.# proxy_read_timeout 60s;proxy_http_version 1.1;proxy_set_header X-Real-IP $remote_addr;proxy_set_header X-Real-PORT $remote_port;proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;proxy_set_header Host $http_host;proxy_set_header Scheme $scheme;proxy_set_header Server-Protocol $server_protocol;proxy_set_header Server-Name $server_name;proxy_set_header Server-Addr $server_addr;proxy_set_header Server-Port $server_port;proxy_set_header Upgrade $http_upgrade;proxy_set_header Connection $connection_upgrade;proxy_pass http://laravels; }#我只知道下面的配置必须有location @laravels {# proxy_connect_timeout 60s;# proxy_send_timeout 60s;# proxy_read_timeout 60s;proxy_http_version 1.1;proxy_set_header Connection "";proxy_set_header X-Real-IP $remote_addr;proxy_set_header X-Real-PORT $remote_port;proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;proxy_set_header Host $http_host;proxy_set_header Scheme $scheme;proxy_set_header Server-Protocol $server_protocol;proxy_set_header Server-Name $server_name;proxy_set_header Server-Addr $server_addr;proxy_set_header Server-Port $server_port;proxy_pass http://laravels; }#我部署的静态资源服务器,你的项目可有可无location ~ .*\.(gif|jpg|jpeg|png|js|css)$ {expires 24h;root /dingshub2/yinti/public/static;proxy_store on;proxy_store_access user:rw group:rw all:rw;proxy_temp_path /dingshub2/yinti/public/static;#图片访问路径proxy_redirect off;proxy_set_header Host 127.0.0.1;client_max_body_size 10m;client_body_buffer_size 1280k;proxy_connect_timeout 900;proxy_send_timeout 900;proxy_read_timeout 900;proxy_buffer_size 40k;proxy_buffers 40 320k;proxy_busy_buffers_size 640k;proxy_temp_file_write_size 640k;if ( !-e $request_filename){proxy_pass http://127.0.0.1;#默认80端口 }} }
  • html实现部分(blade模版,继承了母版页)
@extends('masterpage.chatroom')@section('passage')<div class="pricing-header px-3 py-3 pt-md-5 pb-md-4 mx-auto text-center"><h1 class="display-4">帅哥聊天室</h1><p class="lead">四海之内皆兄弟,请文明交流</p></div>
@endsection@section('pad')<div class="card-deck mb-3"><div class="card mb-10 box-shadow"><div class="card-header"><h4 class="my-0 font-weight-normal  text-center">交流板</h4></div><div class="card-body"><h1 class="card-title pricing-card-title"> <small class="text-muted"></small></h1><textarea id="chatpad" class='form-control' cols="90" rows="20"></textarea><p style="margin-left: 2px" class="my-0 font-weight-normal">消息输入框</p><textarea class='form-control'  cols="90" rows="8"></textarea><br><button id="joinin" type="button" class="btn btn-lg btn-block btn-outline-primary">进入聊天室</button></div></div></div>
@endsection@section('tailscript')<script src="{{asset(config('mystatic._js_').'/jquery-3.3.1.min.js')}}" ></script><script src="{{asset(config('mystatic._myjs_').'/joinintalk.js')}}"></script>
@endsection
  • js具体实现----点击按钮即实现websocket服务器的连接
$("#joinin").click(function()
{var mysocket = new WebSocket('ws://yinti.com:5200/ws');mysocket.onopen=function (event) {$("#chatpad").val("");$("#chatpad").val("大家好!音提来了\n");};});

 

(未完待续)

 

转载于:https://www.cnblogs.com/saintdingspage/p/11272418.html

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/410350.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

编程之美-2.17-数组循环移位

1. 简述 设计一个算法&#xff0c;把一个含有N个元素的数组循环右移K位&#xff0c;要求时间复杂度为O(N)&#xff0c;且只允许使用两个附加变量。 2. 思路 其实看到题目中只允许两个附加变量应该也能想到&#xff0c;就是两个变量倒来倒去就行了。如果熟悉希尔排序的话&#x…

Rails 3:提高Ajax应用速度

Rails 3&#xff1a;提高Ajax应用速度 http://developer.51cto.com 2011-05-18 09:45 Stefan Siebel 51CTO 我要评论(0)我建立了一个列表网站&#xff0c;ListKungFo&#xff0c;其中大量使用了Ajax&#xff0c;目前为止网站运行非常良好。而过去两周里&#xff0c;我一直在…

opencv支持python3吗_Python3.4+opencv3

1、安装Python 3.4 for Windows 好的这好像没有什么可以说的 2、下载OpenCV 3和Numpy(OpenCV依赖Numpy库) 大家在这里就出了问题。如果使用直接使用pip install pyopencv安装一定会出错。这里使用了Python界活雷锋封装的安装包&#xff0c;大家根据自己的系统下载&#xff1a; …

cacti安装配置详解_MySQL实战001:8.0免安装版服务配置详解

首先我们需要先下载MySQL的安装包&#xff0c;MYSQL官方下载地址&#xff1a;https://dev.mysql.com/downloads/mysql/&#xff0c;这里我下载的是MySQL Community Server 8.0.15版本&#xff0c;以前MySQL还有安装版&#xff0c;现在都是压缩版&#xff0c;解压之后将环境配置…

laydate时间控件有时候无效_新角度,如何无效没用地听课

嗨喽&#xff0c;大家好。这一期我想向大家展示一下如何无效地听课。1.上课的时候&#xff0c;全程集中注意力&#xff0c;每一秒都不能放松&#xff0c;使自己的大脑保持高度紧张中。我们这么年轻&#xff0c;精神充沛得很&#xff0c;只要累不死就往死里学。 2.下课的时候也不…

anaconda python删除pyltp_Anaconda使用

Anaconda 是什么&#xff1f;Anaconda 是一个可用于科学计算的 Python 发行版&#xff0c;支持 Linux、Mac、 Windows系统&#xff0c;内置了常用的科学计算包。它解决了官方 Python 的两大痛点。第一&#xff1a;提供了包管理功能&#xff0c;Windows 平台安装第三方包经常失败…

gc日志怎么看_你应该怎么监控Kafka?

监控 Kafka&#xff0c;历来都是个老大难的问题。无论是在我维护的微信公众号&#xff0c;还是 Kafka QQ群里面&#xff0c;大家问得最多的问题&#xff0c;一定是 Kafka 的监控。大家提问的内容看似五花八门&#xff0c;但真正想了解的&#xff0c;其实都是监控这点事&#xf…

c语言 二进制输出_收藏!C语言入门基础知识大全

C语言中的逻辑值只有两个&#xff1a;真(true)和假(flase)。用非零代表真&#xff0c;用零代表假。因此&#xff0c;对于任意一个表达式&#xff0c;如果它的值为零&#xff0c;就代表一个假值&#xff0c;如果它的值为非零&#xff0c;就代表一个真值。只要值不是零&#xff0…

机器学习算法与Python实践之(七)逻辑回归(Logistic Regression)

http://blog.csdn.net/zouxy09/article/details/20319673 机器学习算法与Python实践之&#xff08;七&#xff09;逻辑回归&#xff08;Logistic Regression&#xff09; zouxy09qq.com http://blog.csdn.net/zouxy09 机器学习算法与Python实践这个系列主要是参考《机器学习实战…

protected访问权限_复习封装与访问控制

java 中的封装性是通过对成员变量和方法进行访问控制实现的&#xff0c;访问控制分为个等级 &#xff1a;私有 private &#xff1b;默认 &#xff1b;保护 protected &#xff1b;公有 public &#xff1b;访问权限表控制等级 同一个类 同一个包 不同包的子包 不同包非子类 私…

html日期选择框_第十课 日期选择框(datepicker)的操作

有客户问&#xff1a;datepicker是怎么操作的&#xff1f;我答&#xff1a;datepicker可以直接用"输入文本"组件。客户说&#xff1a;不是&#xff0c;现在我操作的这个网页上datepicker是不能直接输入的&#xff0c;否则就直接用“输入文本”组件搞定&#xff0c;很…

E-triples II_2019牛客暑期多校训练营(第四场)

求用n个3的倍数的数按位或出数字a的方案数有多少种&#xff08;0也算3的倍数&#xff09; 题解 若数b的每个二进制位上的1&#xff0c;在a中也为1&#xff0c;则称b为a的子集容易知道任意个a的子集按位或出来的结果还是a的子集若问题改为按位或出来的结果是a的子集的方案数&…

SRTE测试

网络拓扑&#xff1a; XRV1 hostname XRV1explicit-path name SRTE index 10 next-address strict ipv4 unicast 10.10.2.2 index 20 next-address strict ipv4 unicast 10.10.3.2 index 30 next-address strict ipv4 unicast 10.10.4.1 index 40 next-address strict ipv4 un…

java笔记:自己动手写javaEE框架(七)--使用JSON和Ajax技术

今天我要将json和ajax引入到我所写的框架&#xff0c;不过今天用到的技术有部分不是我框架最终使用到的技术&#xff0c;比如ajax技术&#xff0c;我用到的是最为原始的ajax技术&#xff0c;这次算是对老技术的回顾&#xff0c;不过不管技术如何演进&#xff0c;对技术的本质的…

系统分析师成长之路

去年拿到软件设计师证书后&#xff0c;查了下高级认证中系统分析师&#xff0c;原来发现自己目前工作内容更像系统分析师&#xff08;与用户调研、明确需求内容、熟悉企业数据模型、安排开发人员设计程序、牵头日常维护工作、团队人员管理&#xff09;。去年底马上下决定趁热打…

python 收发邮件_python发送各类邮件的主要基本方法

利用python实现基本的邮件发送。 感谢以下博客的整理&#xff0c;本人在学习的同时也做了一些整理 一、相关模块介绍 发送邮件主要用到了smtplib和email两个模块&#xff0c;这里首先就两个模块进行一下简单的介绍&#xff1a; 1、smtplib模块 smtplib.SMTP([host[, port[, loc…

区分Activity的四种加载模式

在多Activity开发中&#xff0c;有可能是自己应用之间的Activity跳转&#xff0c;或者夹带其他应用的可复用Activity。可能会希望跳转到原来某个Activity实例&#xff0c;而不是产生大量重复的Activity。 这需要为Activity配置特定的加载模式&#xff0c;而不是使用默认的加载模…

laravel常用响应操作

转载于:https://www.cnblogs.com/saintdingspage/p/11298246.html

python中mat函数_python matplotlib中的subplot函数使用详解

python里面的matplotlib.pylot是大家比较常用的&#xff0c;功能也还不错的一个包。基本框架比较简单&#xff0c;但是做一个功能完善且比较好看整洁的图&#xff0c;免不了要网上查找一些函数。于是&#xff0c;为了节省时间&#xff0c;可以一劳永逸。我把常用函数作了一个总…

if else if else语句格式_你还在用if/else吗?

你还在用if/else吗&#xff1f;前提我们在日常开发当中经常会遇到复杂的条件判断&#xff0c;一般的做法是用if/else&#xff0c;或者优雅一点的写法是用switch语句来实现多个条件的判断&#xff0c;这样的话会有很多问题&#xff0c;随着判断条件的增加&#xff0c;代码中if/e…