Java IO示例代码-阿里云开发者社区

开发者社区> 刘俊杰liujj> 正文

Java IO示例代码

简介: public class BIOServer { public static void main(String[] args) { try { ServerSocket serverSocket = new ServerSocket(); InetSocketAddress address = new InetSocketAddress("127.
+关注继续查看

//BIO服务端
public class BIOServer {

public static void main(String[] args) {
    try {
        ServerSocket serverSocket = new ServerSocket();
        InetSocketAddress address = new InetSocketAddress("127.0.0.1", 9001);
        serverSocket.bind(address);
        while (true) {
            Socket socket = serverSocket.accept();
            new Thread(new Runnable() {
                @Override
                public void run() {
                    System.out.println(socket.getLocalAddress().getHostAddress() + "连接了");
                    InputStream inputStream = null;
                    try {
                        inputStream = socket.getInputStream();
                        InputStreamReader inputStreamReader = new InputStreamReader(inputStream);
                        BufferedReader reader = new BufferedReader(inputStreamReader);
                        String str = null;
                        str = reader.readLine();
                        System.out.println(str);
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }).start();
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
}

}

//BIO客户端
public class BIOClient {

public static void main(String[] args) {
    try {
        Socket socket = new Socket("127.0.0.1", 9001);
        OutputStream outputStream = socket.getOutputStream();
        OutputStreamWriter outputStreamWriter = new OutputStreamWriter(outputStream);
        BufferedWriter writer = new BufferedWriter(outputStreamWriter);
        String str = "你好";
        writer.write(str);
        //刷新输入流
        writer.flush();
        //关闭socket的输出流
        socket.shutdownOutput();
    } catch (Exception e) {
        e.printStackTrace();
    }
}

}

//NIO服务端
public class NIOServer {

/**
 * 选择器
 */
private Selector selector;

/**
 * 通道
 */
ServerSocketChannel serverSocketChannel;

public void initServer(int port) throws IOException
{
    //打开一个通道
    serverSocketChannel = ServerSocketChannel.open();

    //通道设置非阻塞
    serverSocketChannel.configureBlocking(false);

    //绑定端口号
    serverSocketChannel.socket().bind(new InetSocketAddress("0.0.0.0", port));

    //注册
    this.selector = Selector.open();
    //先注册事件
    serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
}

public void listen() throws IOException
{
    System.out.println("server started succeed!");

    while (true)
    {
        //阻塞到至少有一个就绪通道
        selector.select();
        Iterator<SelectionKey> ite = selector.selectedKeys().iterator();
        while (ite.hasNext())
        {
            SelectionKey key = ite.next();
            if (key.isAcceptable())
            {
                //接收新请求,并创建新通道
                SocketChannel channel = serverSocketChannel.accept();
                channel.configureBlocking(false);
                //通道注册可读事件
                channel.register(selector, SelectionKey.OP_READ);
            }
            else if (key.isReadable())
            {
                recvAndReply(key);
            }
            ite.remove();
        }
    }
}

public void recvAndReply(SelectionKey key)
{
    SocketChannel channel = (SocketChannel) key.channel();
    try {
        ByteBuffer buffer = ByteBuffer.allocate(256);
        int i = channel.read(buffer);
        if (i != -1) {
            String msg = new String(buffer.array()).trim();
            System.out.println(new Date() + ",NIO server received message =  " + msg);
            System.out.println(new Date() + ",NIO server reply =  " + msg);
            //通道写入数据
            channel.write(ByteBuffer.wrap(msg.getBytes()));
        } else {
            //多线程处理业务
            channel.close();
        }
    }catch (IOException e) {
        e.printStackTrace();
        try {
            channel.close();
        } catch (IOException ex) {
            ex.printStackTrace();
        }
    }
}

public static void main(String[] args) throws IOException
{
    NIOServer server = new NIOServer();
    server.initServer(8001);
    server.listen();
}

}

//NIO客户端
public class NIOClient {

/**
 * 通道
 */
SocketChannel channel;

public void initClient(String host, int port) throws IOException
{
    //构造socket连接
    InetSocketAddress servAddr = new InetSocketAddress(host, port);

    //通过通道,打开连接
    this.channel = SocketChannel.open(servAddr);
}

public void sendAndRecv(String words) throws IOException {
    byte[] msg = new String(words).getBytes();
    ByteBuffer buffer = ByteBuffer.wrap(msg);
    System.out.println(new Date() + ",Client sending: " + words);
    //通道写数据
    channel.write(buffer);
    buffer.clear();
    //阻塞,通道读数据
    channel.read(buffer);
    System.out.println(new Date() + ",Client received: " + new String(buffer.array()).trim());
}

public void close() throws IOException {
    channel.close();
}

public static void main(String[] args) throws IOException {
    NIOClient client = new NIOClient();
    try {
        client.initClient("localhost", 8001);
        Random random = new Random(10000000);
        while (true) {
            client.sendAndRecv(random.nextInt() + ",I am a client");
        }
    } catch (Exception e) {
        e.printStackTrace();
        client.close();
    }
}

}

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
Clean Code之JavaScript代码示例
译者按: 简洁的代码可以避免写出过多的BUG。 原文: JavaScript Clean Code - Best Practices 译者: Fundebug 本文采用意译,版权归原作者所有 引文 作为一个开发者,如果你关心代码质量,除了需要认真测试代码能否正确执行以外,还要注重代码的整洁(clean code)。
594 0
25个JavaScript数组方法代码示例
摘要: 通过代码掌握数组方法。 原文:通过实现25个数组方法来理解及高效使用数组方法(长文,建议收藏) 译者:前端小智 Fundebug经授权转载,版权归原作者所有。 要在给定数组上使用方法,只需要通过[].方法名即可,这些方法都定义在 Array.prototype 对象上。
3416 0
《Java遗传算法编程》—— 2.3 关于本书的代码示例
本书中的每一章都作为一个包,放在附带的Eclipse项目中。每个包都至少有4个类。 GeneticAlgorithm类,它抽象了遗传算法本身,为接口方法提供了针对问题的实现,如交叉、变异、适应度评估和终止条件检查。
1420 0
阿里云服务器端口号设置
阿里云服务器初级使用者可能面临的问题之一. 使用tomcat或者其他服务器软件设置端口号后,比如 一些不是默认的, mysql的 3306, mssql的1433,有时候打不开网页, 原因是没有在ecs安全组去设置这个端口号. 解决: 点击ecs下网络和安全下的安全组 在弹出的安全组中,如果没有就新建安全组,然后点击配置规则 最后如上图点击添加...或快速创建.   have fun!  将编程看作是一门艺术,而不单单是个技术。
10313 0
Java内部类超详细总结(含代码示例)
Java内部类超详细总结(含代码示例)什么是内部类什么是内部类?顾名思义,就是将一个类的定义放在另一个类的内部。概念很清楚,感觉很简单,其实关键在于这个内部类放置的位置,可以是一个类的作用域范围、一个方法的或是一个代码块的作用域范围。
605 0
Java三大器之拦截器(Interceptor)的实现原理及代码示例
前言:前面2篇博客,我们分析了Java中过滤器和监听器的实现原理,今天我们来看看拦截器。 1,拦截器的概念    java里的拦截器是动态拦截Action调用的对象,它提供了一种机制可以使开发者在一个Action执行的前后执行一段代码,也可以在一个Action执行前阻止其执行,同时也提供了一种可以提取Action中可重用部分代码的方式。
3270 0
【Java学习笔记之十七】Java中普通代码块,构造代码块,静态代码块区别及代码示例分析
//执行顺序:(优先级从高到低。)静态代码块>mian方法>构造代码块>构造方法。 其中静态代码块只执行一次。构造代码块在每次创建对象是都会执行。 1 普通代码块 1 //普通代码块:在方法或语句中出现的{}就称为普通代码块。
1132 0
22
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
《2021云上架构与运维峰会演讲合集》
立即下载
《零基础CSS入门教程》
立即下载
《零基础HTML入门教程》
立即下载