swoole服务怎么开启
发布时间 - 2019-12-09 00:00:00 点击率:次服务启动依赖于进程,在进程中用swoole_server来创建,源码中的别名函数为swoole_server_create,默认的sock_type是tcp,服务模式serv_mode为进程模式。
long sock_type = SW_SOCK_TCP; long serv_port; long serv_mode = SW_MODE_PROCESS;
分配swServer内存并初始化
swServer_init(serv);
主要是factory_mode,反应器个数 reactor_num,分发模式dispatch_mode,环形缓冲区大小ringbuffer_size,超时时间(由timeout_sec和timeout_usec),工作进程数workker_num,最大连接数max_connection,最大请求数max_request,http_server服务配置信息,心跳空闲时间heartbeat_idel_time和检查时间间隔heartbeat_check_interval,缓冲区的输入输出大小buffer_input_size和buffer_output_size及管道缓存大小。
swoole_init();
bzero(serv, sizeof(swServer));
serv->factory_mode = SW_MODE_BASE;
serv->reactor_num = SW_REACTOR_NUM > SW_REACTOR_MAX_THREAD ? SW_REACTOR_MAX_THREAD : SW_REACTOR_NUM;
serv->dispatch_mode = SW_DISPATCH_FDMOD;
serv->ringbuffer_size = SW_QUEUE_SIZE;
serv->timeout_sec = SW_REACTOR_TIMEO_SEC;
serv->timeout_usec = SW_REACTOR_TIMEO_USEC; //300ms;
serv->worker_num = SW_CPU_NUM;
serv->max_connection = SwooleG.max_sockets;
serv->max_request = 0;
//http server
serv->http_parse_post = 1;
serv->upload_tmp_dir = "/tmp";
//heartbeat check
serv->heartbeat_idle_time = SW_HEARTBEAT_IDLE;
serv->heartbeat_check_interval = SW_HEARTBEAT_CHECK;
serv->buffer_input_size = SW_BUFFER_INPUT_SIZE;
serv->buffer_output_size = SW_BUFFER_OUTPUT_SIZE;
serv->pipe_buffer_size = SW_PIPE_BUFFER_SIZE;
SwooleG.serv = serv;同时解析服务主机ip,端口号,服务模式及sock_type,将服务器监听端口信息加入listen_list列表中swServer_add_port。
//create server socket int sock = swSocket_create(ls->type); if (sock < 0) { swSysError("create socket failed."); return NULL; } //bind address and port if (swSocket_bind(sock, ls->type, ls->host, ls->port) < 0) { return NULL; } //dgram socket, setting socket buffer size if (swSocket_is_dgram(ls->type)) { setsockopt(sock, SOL_SOCKET, SO_SNDBUF, &ls->socket_buffer_size, sizeof(int)); setsockopt(sock, SOL_SOCKET, SO_RCVBUF, &ls->socket_buffer_size, sizeof(int)); } //O_NONBLOCK & O_CLOEXEC swoole_fcntl_set_option(sock, 1, 1); ls->sock = sock; if (swSocket_is_dgram(ls->type)) { serv->have_udp_sock = 1; serv->dgram_port_num++; if (ls->type == SW_SOCK_UDP) { serv->udp_socket_ipv4 = sock; } else if (ls->type == SW_SOCK_UDP6) { serv->udp_socket_ipv6 = sock; } } else { serv->have_tcp_sock = 1; } LL_APPEND(serv->listen_list, ls); serv->listen_port_num++;
用swoole_server->start来启动(swoole_server_start),注册一些默认及自定义回调,日志初始化,根据服务模式实现工厂的初始化(php_swoole_server_before_start)。
工厂的启动函数会根据服务模式是创建多进程 还是单进程,线程还是线程(swServer_create)。
根据是否使用openssl来读取证书文件 ,是否开启守护模式来做日志初始化和开启守护。swServer_start_proxy创建main_reactor,负责处理监听套接字,同时创建reactor线程。
(推荐学习: swoole视频教程)
# swoole
# 线程
# 自定义
# 来做
# 回调
# 主要是
# 连接数
# 端口号
# 列表中
# 依赖于
# SW_DISPATCH_FDMOD
# SW_REACTOR_MAX_THREAD
相关栏目:
【
网站优化151355 】
【
网络推广146373 】
【
网络技术251813 】
【
AI营销90571 】
相关推荐:
Laravel怎么使用artisan命令缓存配置和视图
安克发布新款氮化镓充电宝:体积缩小 30%,支持 200W 输出
,交易猫的商品怎么发布到网站上去?
黑客如何通过漏洞一步步攻陷网站服务器?
如何确保西部建站助手FTP传输的安全性?
Laravel如何使用Sanctum进行API认证?(SPA实战)
简单实现Android验证码
高防服务器租用首荐平台,企业级优惠套餐快速部署
昵图网官网入口 昵图网素材平台官方入口
Laravel队列任务超时怎么办_Laravel Queue Timeout设置详解
消息称 OpenAI 正研发的神秘硬件设备或为智能笔,富士康代工
深圳网站制作公司好吗,在深圳找工作哪个网站最好啊?
如何登录建站主机?访问步骤全解析
Python企业级消息系统教程_KafkaRabbitMQ高并发应用
Laravel怎么实现支付功能_Laravel集成支付宝微信支付
如何打造高效商业网站?建站目的决定转化率
文字头像制作网站推荐软件,醒图能自动配文字吗?
Laravel怎么为数据库表字段添加索引以优化查询
Laravel任务队列怎么用_Laravel Queues异步处理任务提升应用性能
清除minerd进程的简单方法
html5audio标签播放结束怎么触发事件_onended回调方法【教程】
Laravel中间件如何使用_Laravel自定义中间件实现权限控制
如何有效防御Web建站篡改攻击?
Python文件流缓冲机制_IO性能解析【教程】
Laravel怎么配置S3云存储驱动_Laravel集成阿里云OSS或AWS S3存储桶【教程】
网站制作大概要多少钱一个,做一个平台网站大概多少钱?
Laravel如何使用Vite进行前端资源打包?(配置示例)
手机钓鱼网站怎么制作视频,怎样拦截钓鱼网站。怎么办?
Laravel事件监听器怎么写_Laravel Event和Listener使用教程
如何在VPS电脑上快速搭建网站?
Laravel中的Facade(门面)到底是什么原理
如何在景安服务器上快速搭建个人网站?
zabbix利用python脚本发送报警邮件的方法
晋江文学城电脑版官网 晋江文学城网页版直接进入
详解Huffman编码算法之Java实现
购物网站制作费用多少,开办网上购物网站,需要办理哪些手续?
Laravel如何创建自定义Artisan命令?(代码示例)
如何实现javascript表单验证_正则表达式有哪些实用技巧
胶州企业网站制作公司,青岛石头网络科技有限公司怎么样?
如何挑选优质建站一级代理提升网站排名?
Laravel如何编写单元测试和功能测试?(PHPUnit示例)
PHP怎么接收前端传的文件路径_处理文件路径参数接收方法【汇总】
标题:Vue + Vuex + JWT 身份认证的正确实践与常见误区解析
想要更高端的建设网站,这些原则一定要坚持!
Laravel如何使用查询构建器?(Query Builder高级用法)
如何快速搭建高效可靠的建站解决方案?
EditPlus中的正则表达式实战(6)
独立制作一个网站多少钱,建立网站需要花多少钱?
在线教育网站制作平台,山西立德教育官网?
Thinkphp 中 distinct 的用法解析


ocket
int sock = swSocket_create(ls->type);
if (sock < 0)
{
swSysError("create socket failed.");
return NULL;
}
//bind address and port
if (swSocket_bind(sock, ls->type, ls->host, ls->port) < 0)
{
return NULL;
}
//dgram socket, setting socket buffer size
if (swSocket_is_dgram(ls->type))
{
setsockopt(sock, SOL_SOCKET, SO_SNDBUF, &ls->socket_buffer_size, sizeof(int));
setsockopt(sock, SOL_SOCKET, SO_RCVBUF, &ls->socket_buffer_size, sizeof(int));
}
//O_NONBLOCK & O_CLOEXEC
swoole_fcntl_set_option(sock, 1, 1);
ls->sock = sock;
if (swSocket_is_dgram(ls->type))
{
serv->have_udp_sock = 1;
serv->dgram_port_num++;
if (ls->type == SW_SOCK_UDP)
{
serv->udp_socket_ipv4 = sock;
}
else if (ls->type == SW_SOCK_UDP6)
{
serv->udp_socket_ipv6 = sock;
}
}
else
{
serv->have_tcp_sock = 1;
}
LL_APPEND(serv->listen_list, ls);
serv->listen_port_num++;