单Reactor多线程 _Reactor

public class SReactorSThread {private Selector selector;private ServerSocketChannel serverSocketChannel;private int PORT = 6666;public SReactorSThread() {try {selector = Selector.open();serverSocketChannel = ServerSocketChannel.open();serverSocketChannel.bind(new InetSocketAddress(PORT));serverSocketChannel.configureBlocking(false);serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);} catch (IOException e) {e.printStackTrace();}}//对客户端进行监听public void listen() {try {while (true) {int count = selector.select();//表示有客户端产生事件if (count > 0) {Set<SelectionKey> selectionKeys = selector.selectedKeys();Iterator<SelectionKey> iterator = selectionKeys.iterator();while (iterator.hasNext()) {SelectionKey key = iterator.next();dispatch(key);iterator.remove();}}}} catch (Exception e) {e.printStackTrace();}}private void dispatch(SelectionKey key) {if (key.isAcceptable()){accept(key);}else {handler(key);}}//建立新的连接private void accept(SelectionKey key) {try {SocketChannel socketChannel = serverSocketChannel.accept();socketChannel.configureBlocking(false);socketChannel.register(selector, SelectionKey.OP_READ);} catch (IOException e) {e.printStackTrace();}}//对请求进行处理，接收消息---业务处理---返回消息private void handler(SelectionKey key) {SocketChannel channel = null;try {channel = (SocketChannel) key.channel();ByteBuffer buffer = ByteBuffer.allocate(3);StringBuilder msg = new StringBuilder();while (channel.read(buffer) > 0) {msg.Append(new String(buffer.array()));buffer.clear();}System.out.println("接收到消息：" + msg.toString());String ok = "OK";buffer.put(ok.getBytes());buffer.flip();channel.write(buffer);buffer.clear();} catch (IOException e) {try {System.out.println(channel.getRemoteAddress() + "离线了");key.cancel();channel.close();} catch (IOException ex) {ex.printStackTrace();}}}}public static void main(String[] args) {SReactorSThread sReactorSThread = new SReactorSThread();sReactorSThread.listen();}
【单Reactor多线程】

单Reactor多线程

推荐阅读

你还在找那个“时代”吗

范-迪塞尔|外媒称巨石强森出演了《速度与激情10》与范·迪塞尔和好了？

熬夜失眠第二天精力充沛，规律作息却老打瞌睡

月经期间是否可以做瑜伽？

仓央嘉措：忍住了看你，却忍不住想你仓央嘉措问佛

『』房子装修，有6点必须要做到，否则等到入住会后悔，越早知道越好

新桥|近600岁的北京八里桥要退休了接替它的新桥长这样

电竞小肥仔|LGD十五分钟经济领先名列首位，小花生状态成关键问题！

潘汉典：书生报国尺幅间

星座听语|红鸾入命，情缘再起，3星座破冰复合，余生风雨同行，7月中旬

数码小妖精不送耳机和充电器，果粉必须自己买，廉价iPhone12暗藏猫腻

豪情NBA■一档太强，美媒评NBAFMVP金字塔：库里未上榜！詹姆斯邓肯二档

小诺诺带你看情感世界|邀请成龙代言结婚用18辆奔驰，后来怎样，27岁维修工10年赚到27亿

[刘国梁]刘国梁待人不公？20岁小将2次夺冠遭冷藏，郭跃式悲剧再上演

人民网|托举民族的未来

海尔冷柜份额第一，是什么比日本品牌还好

中年《北斗导航》霸榜苹果 App Store ，众多网友被误导打五星评价

『小黑不露面』有死无生——Mlxg，电竞百科：陷阵之志

「曹操」曹操7位美若天仙的女儿，为何都嫁了一人，他有何非凡之处？

紧急备降！上海飞重庆航班一乘客突发重病