漫谈socket-io的基本原理

package org.luanlouis.socket.noblocking;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.Random;

/**
 * 服务员抽象
 */
public abstract class AbstractWaiter {


    /**
     * 服务的餐桌列表
     */
    private List<Table> servedTableList = new ArrayList<>();

    /**
     * 前台接待顾客
     * 如果返回为空，表示 没有接待到
     * 此方法不阻塞
     * @return 顾客
     */
    public abstract Customer accept();


    /**
     * 取某个餐桌上的下单列表
     * 如果用户没有点好，或者没有加菜，则返回为空。
     * 此方法不阻塞
     *
     * @param table 餐桌
     * @return 下单列表
     */
    public abstract OrderList fetchOrderList(Table table);

    /**
     * 上菜
     * 此方法不阻塞，如果餐桌上有空余位置，则上菜，否则不上菜
     *
     * @param table 餐桌
     */
    public abstract Boolean serveDishes(Table table);


    /**
     * 服务入口
     * 主要工作项：
     >  1. 去前台接待顾客；
     >  2. 如果接待到顾客，则安排顾客就坐；
     >  3. 去每个就餐的餐桌上，看是否需要服务，服务内容有两项：
     >  3.1. 查看顾客是否已经下好单；如果已下单，则交给后厨`tony` 准备；
     >  3.2. 如果有菜已经准备好，并且餐桌还放得下，则给顾客上菜；
     >  4. 重复1、2、3
     */
    public void serve(){
        while(true){
            //前台接待顾客
            Customer customer = accept();
            if(null != customer){
                Table table = assignAvailableTable(customer);
                servedTableList.add(table);
                System.out.println("前台 接到顾客: " + customer.customerNo + "，分配到餐桌: "+table.getNumber());
            }else{
                System.out.println("前台尚未接待到顾客...");
            }
            //依次遍历服务的餐桌
            servedTableList.forEach(table-> {
                // 查看是否餐桌是否点好餐
                OrderList orderList = fetchOrderList(table);
                if(null == orderList || orderList.isEmpty()){
                    System.out.println("餐桌 " + table.getNumber() +" 顾客还没点好餐... ");
                }else{
                    System.out.println("餐桌 "+ table.getNumber() +" 已经点好餐:" + orderList +"，交给后厨... ");
                }
                // 上菜
                serveDishes(table);
            });
        }
    }

    /**
     * 给用户分配餐桌
     * @param customer
     * @return
     */
    private Table assignAvailableTable(Customer customer) {
        String number = "A"+System.currentTimeMillis();
        return new Table(number,customer);
    }
}

package org.luanlouis.socket.noblocking;

/**
 * 服务入口
 */
public class Boostrap {
    public static void main(String[] args) {
        AbstractWaiter waiter = new Waiter();
        waiter.serve();
    }
}

/**
 * 前台服务员
 */
public class Receptionist extends AbstractWaiter {

    ExecutorService tableWaiterPool = Executors.newFixedThreadPool(20);

    /**
     * 前台接待顾客
     * 如果返回为空，表示 没有接待到
     * 此方法不阻塞
     * @return 顾客
     */
    public Customer accept(){
        //模拟没有接待到的场景
        if( new Random(10).nextInt(3) ==2){
            return null;
        }
        return new Customer("Customer_"+System.currentTimeMillis());
    }
    
    @Override
    public Table assignAvailableTable(Customer customer) {
        return null;
    }

    /**
     * 服务内容：
     * 1. 前台接待
     * 2. 给接待的顾客安排座位并且指定服务员
     */
    @Override
    public void serve() {
        while(true){
            //前台接待顾客,可能阻塞
            Customer customer = accept();
            if(null != customer){
                final Table table = assignAvailableTable(customer);
                servedTableList.add(table);
                System.out.println("前台 接到顾客: " + customer.customerNo + "，分配到餐桌: "+table.getNumber());

                //分配服务员
                tableWaiterPool.submit(new Runnable() {
                    public void run() {
                        new TableWaiter(table).serve();
                    }
                });
            }else{
                System.out.println("前台尚未接待到顾客...");
            }
        }
    }
}

/**
 * 餐桌服务员
 */
public class TableWaiter extends Waiter {

    public Table table;
    public TableWaiter(Table table) {
        this.table = table;
    }

    /**
     * 主要做两件事：
     * 1. 等待顾客下单(如果顾客迟迟没有下单，在一直等待)
     * 2. 上菜，如果餐桌已满，则可能阻塞等待
     */
    @Override
    public void serve() {
        while(true){
            // 查看是否餐桌是否点好餐，可能阻塞
            OrderList orderList = fetchOrderList(table);
            if(null == orderList || orderList.isEmpty()){
                System.out.println("餐桌 " + table.getNumber() +" 顾客还没点好餐... ");
            }else{
                System.out.println("餐桌 "+ table.getNumber() +" 已经点好餐:" + orderList +"，交给后厨... ");
            }
            // 上菜,可能阻塞
            serveDishes(table);
        }

    }
}

/**
 * 基于闹铃通知工作模式的服务员
 */
public abstract class MultiWaiter extends AbstractWaiter {


    /**
     * 如果没有触发，则一直等待
     * @return true
     */
    public abstract boolean alarmTriggered();

    /**
     * 是否 下好单
     * @return
     */
    public abstract boolean isOrderListReady(Table table);

    /**
     * 餐桌上是否有空余空间
     * @return
     */
    public abstract boolean isTableAvailable(Table table);

    /**
     * 服务入口
     */
    public void serve(){
        //等待闹铃触发，如果没有，则一直等待
        while(alarmTriggered()){
            servedTableList.forEach(item->{
                //判断是否已经下好单，非阻塞
                if(isOrderListReady(item)){
                    //TODO:  菜单列表交给后厨做菜
                }
                //判断是否有空余空间，非阻塞
                if(isTableAvailable(item)){
                    //TODO:  上菜
                }
            });
        }
    }
}