从零开始实现mvc框架-http server实现
1. 前言
Boomvc完成已经有一段时间了，但拖延到如今才开始记录。写这篇文章主要是回忆和复盘一下思路。如题所讲，Boomvc是一个mvc框架，可是它自带http server功能，也就是说不须要tomcat之类的server，能够在一个jar包里启动而不须要其余的依赖，这就须要本身去写http server的实现，这一篇我就梳理一下实现。react
2. server接口
首先定义一个server接口git
public interface Server {
void init(Boom boom);
void start();
void stop();
}
这个接口能够有多种实现，能够从nio socket开始写，也能够用netty这样的很是好用的network层的框架实现。在这里我实现了一个简易版的TinyServer。github
public class TinyServer implements Server {
private static final Logger logger = LoggerFactory.getLogger(TinyServer.class);
private Boom boom;
private Ioc ioc;
private MvcDispatcher dispatcher;
private Environment environment;
private EventExecutorGroup boss;
private EventExecutorGroup workers;
private Thread cleanSession;
@Override
public void init(Boom boom) {
...
...
}
@Override
public void start() {
this.boss.start();
this.workers.start();
this.cleanSession.start();
}
@Override
public void stop() {
this.boss.stop();
this.workers.stop();
}
}
在这里要关注这个地方tomcat
private EventExecutorGroup boss; private EventExecutorGroup workers;
这是我抽象出来的表示线程组，一个EventExecuteGroup持有多个EventExecute，boss接受链接请求，workers执行业务逻辑。看一下EventExecuteGroup的实现。网络
public class EventExecutorGroup implements Task {
private int threadNum;
private List<EventExecutor> executorList;
private int index;
private ThreadFactory threadName;
private EventExecutorGroup childGroup;
private MvcDispatcher dispatcher;
public EventExecutorGroup(int threadNum, ThreadFactory threadName, EventExecutorGroup childGroup, MvcDispatcher dispatcher, SessionManager sessionManager) {
this.threadNum = threadNum;
this.threadName = threadName;
this.childGroup = childGroup;
this.dispatcher = dispatcher;
this.executorList = new ArrayList<>(this.threadNum);
IntStream.of(this.threadNum)
.forEach(i-> {
try {
this.executorList.add(new EventExecutor(this.threadName, this.childGroup, this.dispatcher, sessionManager));
} catch (IOException e) {
throw new RuntimeException(e);
}
});
this.index = 0;
}
public void register(SelectableChannel channel, int ops) throws ClosedChannelException {
int index1 = 0;
synchronized (this){
index1 = this.index%this.threadNum;
this.index++;
}
this.executorList.get(index1).register(channel, ops);
}
public void register(SelectableChannel channel, int ops, Object att) throws ClosedChannelException {
int index1 = 0;
synchronized (this){
index1 = this.index%this.threadNum;
this.index++;
}
this.executorList.get(index1).register(channel, ops, att);
}
@Override
public void start() {
this.executorList.forEach(e->e.start());
}
@Override
public void stop() {
this.executorList.forEach(e->e.stop());
}
}
3. EventExecutor
EventExecutor就是一个io线程，它持有一个selector，selector是Java NIO核心组件中的一个，用于检查一个或多个Channel（通道）的状态是否处于可读、可写。如此能够实现单线程管理多个channels,也就是能够管理多个网络连接。io线程就不断轮询这个selector，获取多个selector key，根据这个key的状态，好比accept，read，write执行不一样的逻辑。在这里EventExecutor是有多个的，也就是说selector有多个，boss EventExecutorGroup只有一个EventExecutor，它负责accept链接请求，并把接受的链接注册到workers EventExecutorGroup里，由worker线程处理read和write。session
public class EventExecutor {
private static final Logger logger = LoggerFactory.getLogger(EventExecutor.class);
private ThreadFactory threadName;
private EventExecutorGroup childGroup;
private Selector selector;
private Thread ioThread;
private MvcDispatcher dispatcher;
private Runnable task;
private Semaphore semaphore = new Semaphore(1);
public EventExecutor(ThreadFactory threadName, EventExecutorGroup childGroup, MvcDispatcher dispatcher, SessionManager sessionManager) throws IOException {
this.threadName = threadName;
this.childGroup = childGroup;
this.dispatcher = dispatcher;
this.selector = Selector.open();
this.task = new EventLoop(selector, this.childGroup, this.dispatcher, sessionManager, semaphore);
this.ioThread = threadName.newThread(this.task);
}
public void register(SelectableChannel channel, int ops) throws ClosedChannelException {
channel.register(this.selector, ops);
}
public void register(SelectableChannel channel, int ops, Object att) throws ClosedChannelException {
/* 将接收的链接注册到selector上
// 发现没法直接注册，一直获取不到锁
// 这是因为 io 线程正阻塞在 select() 方法上，直接注册会形成死锁
// 若是这时直接调用 wakeup，有可能尚未注册成功又阻塞了，可使用信号量从 select 返回后先阻塞，等注册完后在执行
*/
try {
this.semaphore.acquire();
this.selector.wakeup();
channel.register(this.selector, ops, att);
}catch (InterruptedException e){
logger.error("", e);
}finally {
this.semaphore.release();
}
}
public void start(){
((Task)this.task).start();
this.ioThread.start();
}
public void stop(){
((Task)this.task).stop();
}
}
selector轮询是在EventLoop这里实现的。并发
3. EventLoop
public class EventLoop implements Runnable, Task {
private static final Logger logger = LoggerFactory.getLogger(EventLoop.class);
private Selector selector;
private EventExecutorGroup childGroup;
private MvcDispatcher dispatcher;
private FilterMapping filterMapping;
private volatile boolean isStart = false;
private Semaphore semaphore;
private SessionManager sessionManager;
public EventLoop(Selector selector, EventExecutorGroup childGroup, MvcDispatcher dispatcher, SessionManager sessionManager, Semaphore semaphore) {
...
}
@Override
public void run() {
while(this.isStart){
try {
int n = -1;
try {
n = selector.select(1000);
semaphore.acquire();
} catch (InterruptedException e) {
logger.error("", e);
} finally {
semaphore.release();
}
if(n<=0)
continue;
} catch (IOException e) {
logger.error("", e);
continue;
}
Iterator<SelectionKey> iterator = selector.selectedKeys().iterator();
while(iterator.hasNext()){
SelectionKey key = iterator.next();
iterator.remove();
if(!key.isValid())
continue;
try {
if (key.isAcceptable()) {
accept(key);
}
if (key.isReadable()) {
read(key);
}
if (key.isWritable()) {
write(key);
}
}catch (Exception e){
if(key!=null&&key.isValid()){
try {
key.channel().close();
} catch (IOException e1) {
e1.printStackTrace();
}
}
logger.error("", e);
}
}
}
}
private void accept(SelectionKey key) throws IOException {
ServerSocketChannel serverSocketChannel = (ServerSocketChannel) key.channel();
SocketChannel socketChannel = serverSocketChannel.accept();
socketChannel.configureBlocking(false);
this.childGroup.register(socketChannel, SelectionKey.OP_READ, new HttpProtocolParser(socketChannel));
}
private void read(SelectionKey key) throws Exception{
...
}
private void write(SelectionKey key) throws IOException {
...
}
@Override
public void start() {
this.isStart = true;
}
@Override
public void stop() {
this.filterMapping.distory();
this.isStart = false;
}
public Semaphore semaphore(){
return this.semaphore;
}
}
这就是一个经典的nio程序模式，要注意这里mvc
this.childGroup.register(socketChannel, SelectionKey.OP_READ, new HttpProtocolParser(socketChannel));
这就把接受的链接注册到其余selector了。
这里我用了一个nio程序的多reactor模式，主线程中EventLoop对象经过 select监控链接创建事件，收到事件后经过 Acceptor接收，将新的链接分配给某个子EventLoop。
子线程中的EventLoop完成 read -> 业务处理 -> send 的完整流程。这种模式主线程和子线程的职责很是明确，主线程只负责接收新链接，子线程负责完成后续的业务处理，而且使用多个selector，read，业务处理，write不会影响accept，这对于大量并发链接能够提升accept的速度，不会因业务处理使大量链接堆积，这里其实参考了netty的思想。以下图
app
3. 遇到的坑
在写EventExecutor的register方法是，发现若是直接在selector上调用register的话，可能会形成死锁。由于selector被多个线程访问，当其中一个线程调用selector.select()方法时发生阻塞，这个线程会一直持有selector的锁，这时另外一个线程的register方法会被阻塞。若是这时直接调用 wakeup，有可能尚未注册成功又阻塞了，可使用信号量从 select 返回后先阻塞，等注册完后在执行。具体实现以下框架
try {
this.semaphore.acquire();
this.selector.wakeup();
channel.register(this.selector, ops, att);
}catch (InterruptedException e){
logger.error("", e);
}finally {
this.semaphore.release();
}
try {
n = selector.select(1000);
semaphore.acquire();
} catch (InterruptedException e) {
logger.error("", e);
} finally {
semaphore.release();
}
这里semaphore就起到一个阻塞EventLoop在被唤醒时继续执行的做用，当注册完成时才继续执行。好了，关于server的线程部分就写到这，下一篇写http协议解析部分。
相关文章
- 1. 从零开始实现mvc框架
- 2. 从零开始实现一个简易的Java MVC框架(七)--实现MVC
- 3. 从零开始实现一个简易的Java MVC框架
- 4. 从零开始实现一个简易的Java MVC框架(四)--实现AOP
- 5. 从零开始实现一个简易的Java MVC框架(三)--实现IOC
- 6. 从零开始实现RPC框架 - RPC原理及实现
- 7. 从零开始实现一个RPC框架（零）
- 8. MyBatis框架实现（01）从JDBC开始
- 9. 从零开始实现一个简易的Java MVC框架(八)--制做Starter
- 10. 从零开始实现一个RPC框架（一）
- 更多相关文章...
- • 现实生活中的 XML - XML 教程
- • Hibernate实现增删改查 - Hibernate教程
- • ☆基于Java Instrument的Agent实现
- • Spring Cloud 微服务实战(三) - 服务注册与发现
相关标签/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
最新文章
- 1. 跳槽面试的几个实用小技巧，不妨看看！
- 2. Mac实用技巧 |如何使用Mac系统中自带的预览工具将图片变成黑白色?
- 3. Mac实用技巧 |如何使用Mac系统中自带的预览工具将图片变成黑白色?
- 4. 如何使用Mac系统中自带的预览工具将图片变成黑白色?
- 5. Mac OS非兼容Windows软件运行解决方案——“以VMware & Microsoft Access为例“
- 6. 封装 pyinstaller -F -i b.ico excel.py
- 7. 数据库作业三ER图待完善
- 8. nvm安装使用低版本node.js(非命令安装)
- 9. 如何快速转换图片格式
- 10. 将表格内容分条转换为若干文档
欢迎关注本站公众号,获取更多信息
