第24章 Thread-Per-Message设计模式

1.什么是Thread-Per-Message

Thread-Per-Message的意思是为每一个消息的处理开辟一个线程使得消息能够以并发的方式进行处理，从而提高系统整体的吞吐能力。这就好比电话接线员一样，收到的每一个电话投诉或者业务处理请求，都会提交对应的工单，然后交由对应的工作人员来处理。

2.每个任务一个线程

在本节中，我们首先实现一个简单的Thread-Per-Message， 但是在开发中不建议采用这种方式，在后文中笔者会对此进行详细解释。

public class Request {
    private final String business;
    public Request(String business) {
        this.business = business;
    }
    @Override
    public String toString() {
        return "Request{" +
                "business='" + business + '\'' +
                '}';
    }
}

客户提交的任何业务受理请求都会被封装成Request对象。
TaskHandler代码如所示。

import java.util.concurrent.TimeUnit;
public class TaskHandler implements Runnable{
    // 需要处理的Request请求
    private final Request request;
    public TaskHandler(Request request) {
        this.request = request;
    }
    @Override
    public void run() {
        System.out.println("Begin handle " + request);
        slowly();
        System.out.println("End handle " + request);
    }
    // 模式处理
    private void slowly() {
        try {
            TimeUnit.SECONDS.sleep(1);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

Task Handler代表了每一个工作人员接收到任务后的处理逻辑。
Operator代码如所示。

public class Operator {
    public void call(String business) {
        // 为每个请求创建一个线程去处理
        TaskHandler taskHandler = new TaskHandler(new Request(business));
        new Thread(taskHandler).start();
    }
}

3.多用户的网络聊天

3.1服务端程序