老师有个疑问，帮忙解答下哦，在上面的那个流程图中，WriteThread是单线程从请求队列中获取到消息然后把消息放到journal Cache，开启ReplicationThread、FlushThread进行处理，能否把WriteThread做成分配器了，mq只要保证topic下的队列有序就可以，同一个队列的消息由WriteThread分配给同一个线程进行处理，线程池的形式，线程池中的每个工作线程内部都有个集合保存消息，如果前面没有同一个队列的消息，分配给最空闲的线程进行执行，那这样的话，WriteThread只要分配消息，比如可以对发送过来的消息中要保存的队列属性值进行hash，然后根据hash值判断线程池中的所有线程的消息集合是否有相同队列的消息，有的话分配给同一个线程执行，没有的话最空闲的线程执行，mysql的binlog同步也是有几种这种策略，并发的同步sql，刚开始是基于库，同一个库的sql分配到一个线程执行同步，不同库进行并发，后来是基于redo log的组提交形式，能组提交的sql可以并发的同步，再后来是WRITESET，根据库名、表名、索引（主键和唯一索引）计算hash进行分发策略。

刷了下评论，青舟写的最好，其次Martin
青舟
https://github.com/qingzhou413/geektime-mq-rpc.git
Martin
https://github.com/MartinDai/mq-in-action/blob/master/src/main/java/com/doodl6/mq/MeetInRpc.java

我用java实现了一版，老师帮忙看下哦，评论只能发2000字，其余在评论区补上
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import javax.annotation.Nonnull;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;
import java.util.concurrent.locks.ReentrantLock;

/**
 * @author linqw
 */
public class SocketExample {

    private static final Logger LOGGER = LoggerFactory.getLogger(SocketExample.class);

    private static final ReentrantLock LI_WRITE_REENTRANT_LOCK = new ReentrantLock();

    private static final ReentrantLock ZHANG_WRITE_REENTRANT_LOCK = new ReentrantLock();

    private static final int NCPU = Runtime.getRuntime().availableProcessors();

    private final ThreadPoolExecutor serverThreadPoolExecutor = new ThreadPoolExecutor(NCPU, NCPU, 5, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(200000), new ThreadFactoryImpl("server-"), new ThreadPoolExecutor.CallerRunsPolicy());

    private final ThreadPoolExecutor clientThreadPoolExecutor = new ThreadPoolExecutor(NCPU, NCPU, 5, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(200000), new ThreadFactoryImpl("client-"), new ThreadPoolExecutor.CallerRunsPolicy());

    private volatile boolean started = false;

    /**
     * 俩大爷已经遇见了多少次
     */
    private volatile AtomicInteger count = new AtomicInteger(0);

    /**
     * 总共需要遇见多少次
     */
    private static final int TOTAL = 1;

    private static final String Z0 = " 吃了没，您吶?";

    private static final String Z3 = " 嗨！吃饱了溜溜弯儿。";
    private static final String Z5 = " 回头去给老太太请安！";
    private static final String L1 = " 刚吃。";
    private static final String L2 = " 您这，嘛去？";
    private static final String L4 = " 有空家里坐坐啊。";

    今天老师重新梳理之后知道大致需要哪些知识了，借着之前老师的教诲做个总结：
    基础知识
    1.网络方面：消息队列所用的知识确实只是使用在应用层关于全双工这块知识，其它层次暂不涉及
    2.程序：我们只需要掌握常规的编程手法就行；至于我们去用何种语言实现不重要的，重要的是基于问题通过代码高效的解决就行
    3.操作系统：我们需要明白系统进程之间的调用，从而才能合理的去实现异步和并发
    课程的学习
    1.老师其实是最初在传授消息队列的由来、框架、不同消息队列的使用场景
    2.教授整个消息队列的生产者和消费者之间的关系和特性：让我们理解消息队列
    3.通过上述基础：后面的课程就是不断的通过真实现状理论+实际案例去操作动手；渔授予了，就要开始让我们捕鱼了，
    通过我们捕鱼的问题去修正我们的错误，提升我们捕鱼的能力。这是我学习到现在对于课程学习的感受。
    代码能力偏弱：不过后面会尽力去做；毕竟课程涉及的东西和知识，为了学习好课程一直在跟刘老师课并用刘老师的学习方式在补充学习中所不足；
    知识的课程是跟上了，代码的实践落下了；尽力去做尽力跟上老师的步伐吧，希望老师课程结课时能达到自己最初的学习目标。