美文网首页
网络编程之NIO聊天室

网络编程之NIO聊天室

作者: 帅气的名称被占用 | 来源:发表于2020-03-04 15:55 被阅读0次

1.创建Nio服务端

package nio.study;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;
import java.nio.channels.Channel;
import java.nio.channels.SelectableChannel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.nio.charset.Charset;
import java.util.Iterator;
import java.util.Set;

import javax.xml.ws.handler.MessageContext.Scope;

/**
 *创建Nio服务端 
 */
public class NIOServer {
    /**
     *启动 
     * @throws IOException 
     */
    public void start() throws IOException {
        /**
         * 1、 创建selector
         */
        Selector selector = Selector.open();
        
        /**
         * 2、通过ServerScoketChannel创建channel通过 
         */
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        
        /**
         * 3、为channel通道绑定监听端口 
         */
        serverSocketChannel.bind(new InetSocketAddress(8000));
        /**
         * 4、**设置channel为非阻塞状态 
         */
        serverSocketChannel.configureBlocking(false);
        
        
        /**
         * 5、将channel注册到selector上 监听连接事件
         */
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
        System.out.println("服务器启动成功！");
        /**
         * 6、循环等待新接入的连接 
         */
        for(;;) {
            /**
             * TODO 获取可用channel数量
             */
            int readyChannels = selector.select();
            /**
             * TODO 为什么这样？
             */
            if(readyChannels == 0) continue;
            /**
             *获取channel可用集合 
             */
            Set<SelectionKey> selectedKeys = selector.selectedKeys();
            Iterator<SelectionKey> iterator = selectedKeys.iterator();
            while(iterator.hasNext()) {
                /**
                 *selectrionKey实例 
                 */
                SelectionKey selectionKey = iterator.next();
                /**
                 *移除Set中的当前selectionKey 
                 */
                iterator.remove();
                /**
                 * 7、根据就绪状态，调用对应方法处理业务逻辑 
                 */
                /**
                 *如果是接入事件 
                 */
                if(selectionKey.isAcceptable()) {
                    acceptHandler(serverSocketChannel, selector);
                }
                /**
                 *如果是可读事件 
                 */
                if(selectionKey.isReadable()) {
                    readHandler(selectionKey, selector);
                }
            }
            
        }
    }
    /**
     *接入事件处理 
     * @throws IOException 
     */
    private void acceptHandler(ServerSocketChannel serverSocketChannel,Selector selector) 
            throws IOException {
        /**
         *如果是接入事件，创建socketChannel 
         */
        SocketChannel socketChannel = serverSocketChannel.accept();
        /**
         *将socketChannel设置为非阻塞工作模式 
         */
        socketChannel.configureBlocking(false);
        /**
         *将channel注册到selector上，监听可读事件 
         */
        socketChannel.register(selector, SelectionKey.OP_READ);
        /**
         * 回写客户端提示信息
         */
        socketChannel.write(Charset.forName("UTF-8").
                encode("你与聊天室的其他人都不是朋友关系，请注意隐私安全"));
    }
    /**
     *可读事件处理 
     * @throws IOException 
     */
    private void readHandler(SelectionKey selectionKey,Selector selector) throws IOException {
        /**
         *要从 selectionKey中获取已经就绪的channe 
         *SocketChannel socketChannel = (SocketChannel)selectionKey.channel();
         */
        SocketChannel socketChannel = (SocketChannel)selectionKey.channel();
         /**
          * 创建Buffer
          */
         ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
         /**
          *循环读取客户端信息 
          */
         String request = "";
         while(socketChannel.read(byteBuffer)>0) {
             /**
              *切换buffer为读模式 
              */
             byteBuffer.flip();
             /**
              *读取buffer中的内容 
              */
             request += Charset.forName("UTF-8").decode(byteBuffer);
         }
         /**
          * 再次将socketChannel注册到selector上
          */
         socketChannel.register(selector, SelectionKey.OP_READ);
         /**
          * 将客户端发送的请求信息，广播给其他客户端
          */
         if(request.length() > 0) {
             broadCast(selector, socketChannel, request);
         }
    }
    
    private void broadCast(Selector selector,SocketChannel sourceChannel,String request) {
        /**
         *获取到所有已接入的客户端channel 
         */
        Set<SelectionKey> selectionKeySet = selector.keys();
        /**
         *循环向所有channel广播 
         */
        selectionKeySet.forEach(selectionKey->{
            Channel targetchannel = selectionKey.channel();
            //剔除发消息的客户端
            if(targetchannel instanceof SocketChannel
                    && targetchannel != sourceChannel) {
                try {
                    ((SocketChannel)targetchannel).
                    write(Charset.forName("UTF-8").encode(request));
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        });
    }
    /**
     *主方法 
     * @throws IOException 
     */
    public static void main(String[] args) throws IOException {
        NIOServer server = new NIOServer();
        server.start();
    }
}

2、创建NIO客户端

package nio.study;

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.nio.charset.Charset;
import java.util.Scanner;

public class NioClient {
    /**
     *启动 
     * @throws IOException 
     */
    public void start(String nickName) throws IOException {
        /**
         *连接服务器端 
         */
        SocketChannel socketChannel = SocketChannel.open(new InetSocketAddress("127.0.0.1", 8000));
        /**
         *接收服务端的响应 
         */
        //新开线程专门接收服务器端的响应数据
        Selector selector = Selector.open();
        socketChannel.configureBlocking(false);
        socketChannel.register(selector, SelectionKey.OP_READ);
        new Thread(new NioClientThreadHandler(selector)).start();;
        
        /**
         *向服务器发送数据
         */
        System.out.println("客户端：");
        Scanner scanner = new Scanner(System.in);
        while(scanner.hasNextLine()) {
            String request = scanner.nextLine();
            if(request != null && request.length() > 0) {
                socketChannel.write(Charset.forName("UTF-8").encode(nickName+":"+request));
            }
        }
        
    }
    /**
     *主方法 
     * @throws IOException 
     */
    public static void main(String[] args) throws IOException {
//      new NioClient().start();
    }
}

3、NIO客户端线程处理类

package nio.study;

import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.nio.charset.Charset;
import java.util.Iterator;
import java.util.Set;

public class NioClientThreadHandler implements Runnable {
    private Selector selector;
    
    public NioClientThreadHandler(Selector selector) {
        super();
        this.selector = selector;
    }

    @Override
    public void run() {
         for(;;) {
             try {
                int readyChannels = selector.select();
            
                if(readyChannels == 0) continue;
                /**
                 *获取channel可用集合 
                 */
                Set<SelectionKey> selectedKeys = selector.selectedKeys();
                Iterator<SelectionKey> iterator = selectedKeys.iterator();
                while(iterator.hasNext()) {
                    /**
                     *selectrionKey实例 
                     */
                    SelectionKey selectionKey = iterator.next();
                    /**
                     *移除Set中的当前selectionKey 
                     */
                    iterator.remove();
                     
                    /**
                     *如果是接入事件 
                     */
                    if(selectionKey.isReadable()) {
                        readHandler(selectionKey, selector);
                    }
                    
                }
            } catch (IOException e) {
                e.printStackTrace();
            }
         }
        
    }
    private void readHandler(SelectionKey selectionKey,Selector selector) throws IOException {
        /**
         *要从 selectionKey中获取已经就绪的channe 
         *SocketChannel socketChannel = (SocketChannel)selectionKey.channel();
         */
        SocketChannel socketChannel = (SocketChannel)selectionKey.channel();
         /**
          * 创建Buffer
          */
         ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
         /**
          *循环读取客户端信息 
          */
         String response = "";
         while(socketChannel.read(byteBuffer)>0) {
             /**
              *切换buffer为读模式 
              */
             byteBuffer.flip();
             /**
              *读取buffer中的内容 
              */
             response += Charset.forName("UTF-8").decode(byteBuffer);
         }
         /**
          * 再次将socketChannel注册到selector上
          */
         socketChannel.register(selector, SelectionKey.OP_READ);
         /**
          * 将服务的信息
          */
         if(response.length() > 0) {
             System.out.println(response);
         }
    }

}

4、创建NioClient多个客户端实现聊天

package nio.study;

import java.io.IOException;

public class AClient {
    public static void main(String[] args) throws IOException {
        new NioClient().start("AClient");
    }
}
package nio.study;

import java.io.IOException;

public class BClient {
    public static void main(String[] args) throws IOException {
        new NioClient().start("BClient");
    }
}
package nio.study;

import java.io.IOException;

public class CClient {
    public static void main(String[] args) throws IOException {
        new NioClient().start("CClient");
    }
}

相关文章

  • 网络编程之NIO聊天室

    1.创建Nio服务端 2、创建NIO客户端 3、NIO客户端线程处理类 4、创建NioClient多个客户端实现聊天

  • Java NIO三组件——Selecotr/Channel实现原

    一、NIO聊天室入门案例 在学习原理之前，先来了解一个Java NIO实现聊天室的小案例，该案例只有三个类：Nio...

  • 网络编程之SocketIO基础

    继上一篇文章《网络编程之IO与NIO阻塞分析》的讲解，已经知道了网络编程的基本方式，今天将继续进行网络编程相关概念...

  • 网络编程之IO、NIO和Netty

    一、基本概述 IO 一直是编程学习中的核心部分，在这里所说的IO 不仅仅是对文件的操作，还常常应用在网络编程中，比...

  • Java网络编程之NIO-Buffer

    1. 前言 上一篇文章中，粗略的介绍了BIO，有兴趣的可以去看一看。 Java NIO部分，我大致会写4篇文章，前...

  • Go网络编程之并发聊天室

    并发聊天室 并发编程和网络编程是现今行业开发中常用的技术。Go语言强大的语法设定使得并发和网络编程都变的简洁而高效...

  • Java NIO学习笔记 - NIO编程知识

    NIO编程 在介绍NIO编程之前，我们首先需要澄清一个概念：NIO到底是什么的简称？有人称之为New I/O，因为...

  • Netty NioSocketChannel写数据源码分析

    介绍 本编文章我们深入探究下使用netty通信的双方是如何写数据到网络 说明 我们基于NIO进行分析 写数据到网络...

  • 【NIO】NIO版本的鸿儒聊天室

    # 需求 基于NIO实现 支持同时多个客户端接入 支持客户端发送文本消息到服务器 支持客户端自定义群聊名称 接收到...

  • 网络编程之IO与NIO阻塞分析

    1. 阻塞与非阻塞是什么？ 程序在等待调用结果（消息，返回值等）时的状态（具体的技术，接收数据的方式、状态），它是...

网友评论

      本文标题：网络编程之NIO聊天室

      本文链接：https://www.haomeiwen.com/subject/efxblhtx.html

      延伸阅读

      深度阅读

      • 您也可以注册成为美文阅读网的作者，发表您的原创作品、分享您的心情！

      栏目导航

      热点阅读

      关于我们|服务条款|联系我们|网络编程之NIO聊天室|投稿指南|网站地图|RSS订阅|排版工具|手机版

      提供经典美文摘抄,优美散文欣赏,现代诗歌精选,短篇小说,心情随笔,表白情书范文,故事会在线阅读欣赏

      Copyright © 2014-2023 Haomeiwen.com All Rights Reserved. 好美文阅读网 版权所有

      备案信息：桂公网安备 45052102000051号 · 桂ICP备13007215号-3

      本站所收录作品、热点评论等信息部分来源互联网，目的只是为了系统归纳学习和传递资讯

      所有作品版权归原创作者所有，与本站立场无关，如不慎侵犯了你的权益，请联系我们告知，我们将做删除处理！