高并发大流量专题---八、动态语言的并发处理
1、总结
一句话总结:
和本科毕业论文连起来了:基于消息中间件Rocket MQ的研究;用于并发处理的消息队列
一、什么是进程、线程、协程?
进程(Process)是计算机中的【程序关于某数据集合上的一次运行活动】,是系统进行资源分配和调度的基本单位,是操做系统结构的基础
线程,有时被称为【轻量级进程】(Lightweight Process,LWP),是程序执行流的最小单元。
协程是一种【用户态的轻量级线程】,协程的调度彻底由用户控制。协程拥有本身的寄存器上下文和栈。协程调度切换时,将寄存器上下文和栈保存到其余地方,在切回来的时候,恢复先前保存的寄存器上下文和栈,直接操做栈则基本没有内核切换的开销,能够不加锁的访问全局变量,因此上下文的切换很是快。
二、进程的三态模型(多道程序系统中,进程在处理器上交替运行,状态不断地发生变化)?
运行、就绪、阻塞
运行:当一个进程在处理机上运行时,则称该进程处于运行状态。处于此状态的进程的数目小于等于处理器的数目,对于单处理机系统,处于运行状态的进程只有一个。在没有其余进程能够执行时(如全部进程都在阻塞状态),一般会自动执行系统的空闲进程。
就绪:当一个进程得到了除处理机之外的一切所需资源,一旦获得处理机便可运行,则称此进程处于就绪状态。就绪进程能够按多个优先级来划分队列。例如,当一个进程因为时间片用完而进入就绪状态时,排入低优先级队列;当进程由I/O操做完成而进入就绪状态时,排入高优先级队列。
阻塞:也称为等待或睡眠状态,一个进程正在等待某一事件发生(例如请求I/O而等待I/O完成等)而暂时中止运行,这时即便把处理机分配给进程也没法运行,故称该进程处于阻塞状态。php
三、进程的五态模型(对于一个实际的系统,进程的状态及其转换更为复杂)?
新建态、活跃就绪/静止就绪、运行、活跃阻塞/静止阻塞、终止态
新建态:对应于进程刚刚被建立时没有被提交的状态,并等待系统完成建立进程的全部必要信息。
终止态:进程已结束运行,回收除进程控制块以外的其余资源,并让其余进程从进程控制块中收集有关信息。
活跃就绪:是指进程在主存而且可被调度的状态。
静止就绪(挂起就绪):是指进程被对换到辅存时的就绪状态,是不能被直接调度的状态,只有当主存中没有活跃就绪态进程,或者是挂起就绪态进程具备更高的优先级,系统将把挂起就绪态进程调回主存并转换为活跃就绪。
活跃阻塞:是指进程已在主存,一旦等待的事件产生便进入活跃就绪状态。
静止阻塞:进程对换到辅存时的阻塞状态,一旦等待的事件产生便进入静止就绪状态。react
四、操做系统中线程的概念为何被引进?
因为用户的并发请求,为每个请求都建立一个进程显然是行不通的,从系统资源开销方面或是响应用户请求的效率方面来看。所以操做系统中线程的概念便被引进了。
五、线程的特色?
线程是进程中的一个实体:是被系统独立调度和分派的基本单位,线程本身不拥有系统资源,只拥有一点儿在运行中必不可少的资源但它可与同属一个进程的其它线程共享进程所拥有的所有资源。
一个线程能够建立和撤消另外一个线程:同一进程中的多个线程之间能够并发执行。
线程是程序中一个单一的顺序控制流程:进程内一个相对独立的、可调度的执行单元,是系统独立调度和分派CPU的基本单位指运行中的程序的调度单位。
六、多线程是什么?
在单个程序中同时运行多个线程完成不一样的工做,称为多线程。
七、线程和进程的数量关系?
每个程序都至少有一个线程,若程序只有一个线程,那就是程序自己。
八、线程的状态?
就绪、阻塞、运行
就绪状态:线程具有运行的全部条件,逻辑上能够运行,在等待处理机。
运行状态:线程占有处理机正在运行。
阻塞状态:线程在等待一个事件(如某个信号量),逻辑上不可执行。web
九、线程与进程的区别?
1.线程是进程内的一个执行单元,进程内至少有一个线程,它们共享进程的地址空间,而进程有本身独立的地址空间
2.进程是资源分配和拥有的单位,同一个进程内的线程共享进程的资源
3.线程是处理器调度的基本单位,但进程不是
4.每一个独立的线程有一个程序运行的入口、顺序执行序列和程序的出口,可是线程不可以独立执行,必须依存在应用程序中,由应用程序提供多个线程执行控制
1.线程是进程内的一个执行单元,进程内至少有一个线程,它们共享进程的地址空间,而进程有本身独立的地址空间
2.进程是资源分配和拥有的单位,同一个进程内的线程共享进程的资源
3.线程是处理器调度的基本单位,但进程不是
4.两者都可并发执行
5.每一个独立的线程有一个程序运行的入口、顺序执行序列和程序的出口,可是线程不可以独立执行,必须依存在应用程序中,由应用程序提供多个线程执行控制数据库
十、线程与协程的区别?
1.一个线程能够多个协程,一个进程也能够单独拥有多个协程
2.线程进程都是同步机制,而协程则是异步
3.协程能保留上一次调用时的状态,每次过程重入时,就至关于进入上一次调用的状态
十一、什么是多进程、多线程?
多进程:同一个时间里,同一个计算机系统中若是容许两个或两个以上的进程处于运行状态,这就是多进程。边看慕课网视频,边使用WebIDE;多开一个进程,多分配一份资源,进程间通信不方便
多线程:线程就是把一个进程分为不少片,每一片均可以是一个独立的流程。与多进程的区别是只会使用一个进程的资源,线程间能够直接通讯
十二、进程线程组合例子?
单进程单线程:一我的在一个桌子上吃菜
单进程多线程:多我的在同一个桌子上一块儿吃菜
多进程单线程:多我的每一个人在本身的桌子上吃菜
1三、同步阻塞中的多进程、多线程?
最先的服务器端程序都是经过多进程、多线程来解决并发IO的问题
多进程:一个请求建立一个进程,而后子进程进入循环同步堵塞地与客户端链接进行交互,收发处理数据
多线程:用多线程模式实现很是简单,线程中能够直接向某一个客户端链接发送数据
1四、同步阻塞中 多线程 步骤 总结?
|||-begin编程
建立一个socket
进入while循环,阻塞在进程accept操做上,等待客户端链接进入
主进程在多进程模型下经过fork建立子进程
多线程模型下能够建立子线程
子进程/线程建立成功后进入while循环,阻塞在recv调用上,等待客户端向服务器发送数据
收到数据后服务器程序进行处理而后使用send向客户端发送响应
当客户端链接关闭时,子进程/线程退出并销毁全部资源。主进程/线程会回收掉此子进程/线程。
|||-endjson
socket和多线程的结合
1五、同步阻塞模型的缺点?
这种模型 【严重依赖进程的数量】 解决并发问题
启动大量进程会带来额外的【进程调度消耗】
1六、php 异步非阻塞 实现?
epoll:如今各类高并发异步IO的服务器程序都是基于epoll实现的
Reactor模型:IO复用异步非阻塞程序使用经典的Reactor模型,Reactor顾名思义就是反应堆的意思,它自己不处理任何数据收发。只是能够监视一个socket句柄的事件变化
1七、异步非阻塞 Reactor有4个核心的操做?
1.add添加socket监听到reactor
2.set修改事件监听,能够设置监听的类型,如可读、可写
3.del从reactor中移除,再也不监听事件
4.callback,事件发生后对应的处理逻辑,通常在add/set时制定
Reactor模型
Add:添加一个SOCKET到Reactor
Set:修改SOCKET对应的事件,如可读可写
Del:从Reactor中移除
Callback:事件发生后回调指定的函数服务器
1八、异步非阻塞模型实例?
Nginx:多线程Reactor
Swoole:多线程Reactor+多进程Worker
1九、PHP并发编程实践?
PHP的Swoole扩展
消息队列
接口的并发请求
20、PHP的Swoole扩展 介绍?
异步、并行、高性能网络通讯引擎:PHP的异步、并行、高性能网络通讯引擎,使用纯C语言编写,提供了PHP语言的异步多线程服务器,异步TCP/UDP网络客户端,异步MySQL,异步Redis,数据库链接池,AsyncTask,消息队列,毫秒定时器,异步文件读写,异步DNS查询
多个并发数据结构和IPC通讯机制:除了异步IO的支持以外,Swoole为PHP多进程的模式设计了多个并发数据结构和IPC通讯机制,能够大大简化多进程并发编程的工做。
协程:Swoole2.0支持了相似Go语言的协程,可使用彻底同步的代码实现异步程序
2一、swoole WebSocket Server 实例?
|||-beginwebsocket
WebSocket Server
<?php
$server = new swoole_websocket_server("127.0.0.1", 9502);
$server->on('open', function($server, $req) {
echo "connection open: {$req->fd}\n";
});
$server->on('message', function($server, $frame) {
echo "received message: {$frame->data}\n";
$server->push($frame->fd, json_encode(["hello", "world"]));
});
$server->on('close', function($server, $fd) {
echo "connection close: {$fd}\n";
});
$server->start();
|||-endswoole
官网有实例代码,比较好上手
2二、消息队列应用场景?
二、应用解耦:用户下单后,订单系统须要通知库存系统
三、流量削锋:秒杀活动,流量瞬时激增,服务器压力大
四、日志处理:解决大量日志的传输
五、消息通讯:多个客户端订阅同一主题,进行消息发布和接收
一、用户注册后,须要发注册邮件和注册短信
网络
2三、超级大量 用户注册后,须要发注册邮件和注册短信,如何解决(用消息队列)?
串行方式:将注册信息写入数据库成功后,发送注册邮件,再发送注册短信
并行方式:将注册信息写入数据库成功后,发送注册邮件的同时,发送注册短信
消息队列方式:将注册信息写入数据库成功后,将成功信息写入队列,此时直接返回成功给用户,写入队列的时间很是短,能够忽略不计,而后异步发送邮件和短信
2四、超级大量 用户下单后,订单系统须要通知库存系统,如何解决(用消息队列作 应用解耦)?
一、消息队列:用户下单后,订单系统完成持久化处理,将消息写入消息队列,返回用户订单下单成功
二、发布订阅:订阅下单的消息,采用拉/推的方式,获取下单信息,库存系统根据下单信息,进行库存操做
消息队列 的另外一种应用:应用解耦
场景说明:用户下单后,订单系统须要通知库存系统。
假如库存系统没法访问,则订单减库存将失败,从而致使订单失败
订单系统与库存系统解耦
引用队列
用户下单后,订单系统完成持久化处理,将消息写入消息队列,返回用户订单下单成功
订阅下单的消息,采用拉/推的方式,获取下单信息,库存系统根据下单信息,进行库存操做
2五、秒杀活动,流量瞬时激增,服务器压力大,如何解决(用消息队列作 流量削锋)?
发起请求,服务器接收后,先写入消息队列。假如消息队列长度超过最大值,则直接报错或提示用户。后续程序读取消息队列再作处理
消息队列 的另外一种应用:流量削锋
应用场景:秒杀活动,流量瞬时激增,服务器压力大。
发起请求,服务器接收后,先写入消息队列。假如消息队列长度超过最大值,则直接报错或提示用户。后续程序读取消息队列再作处理
2六、消息队列 用于 流量削锋的好处?
控制请求量
缓解高流量
2七、解决大量日志的传输,如何解决(用消息队列 作 日志处理)?
日志采集程序将程序写入消息队列,而后经过日志处理程序的订阅消费日志
消息队列 的另外一种应用:日志处理
应用场景:解决大量日志的传输
日志采集程序将程序写入消息队列,而后经过日志处理程序的订阅消费日志
2八、聊天室中,消息队列如何解决消息通信?
多个客户端订阅同一主题,进行消息发布和接收
消息队列 的另外一种应用:消息通信
应用场景:聊天室
多个客户端订阅同一主题,进行消息发布和接收
2九、常见消息队列产品?
Kafka、ActiveMQ、ZeroMQ、RabbitMQ、Redis等
30、php如何作接口的并发请求?
php的curl_multi_init函数 系列
2、内容在总结中