用NIO实现的简单的网络服务器端

下面是我的一个简单的网络服务器端的程序，程序的流程是监听ACCEPT事件，然后往客户端输出一串字符串。是不是很简单。

package sample.nio;

import java.io.*;

import java.net.*;

import java.nio.channels.*;

import java.util.*;

/**

* Title:

* Description:

* Company:

* @author George Hill

* @version 1.0

public class Server {

private int port;

public Server(int port) {

this.port = port;

}

public void startServer() throws IOException {

// 创建ServerSocketChannel并且绑定到指定的端口

ServerSocketChannel ssc = ServerSocketChannel.open();

InetSocketAddress address = new InetSocketAddress(InetAddress.getLocalHost(), port);

ssc.socket().bind(address);

ssc.configureBlocking(false);

// 创建Selector，并且注册ACCEPT事件

Selector selector = Selector.open();

SelectionKey skey = ssc.register(selector, SelectionKey.OP_ACCEPT);

boolean stop = false;

int n = 0;

System.out.println("Server Start");

// 轮询

while (!stop) {

// 获取Selector返回的时间值

n = selector.select();

// 当传回的值大于0事，读时间发生了

if (n > 0) {

Set set = selector.selectedKeys();

Iterator it = set.iterator();

while (it.hasNext()) {

skey = (SelectionKey) it.next();

it.remove();

if (skey.isAcceptable()) {

// 从channel()中取得刚刚注册的Channel

Socket socket = ((ServerSocketChannel) skey.channel()).accept().socket();

PrintWriter writer = new PrintWriter(socket.getOutputStream(), true);

// 将"Hello, World"写入

writer.write("Hello, World!\n");

// 睡眠3秒

try {

Thread.sleep(3000);

} catch (InterruptedException ie) {

}

// 将"EXIT"写入Buffer

writer.write("EXIT");

// 退出程序

writer.close();

// stop = true;

}

ssc.close();

System.out.println("Server Stop");

}

public static void main(String[] args) throws Exception {

Server server = new Server(5000);

server.startServer();

}

posted on 2005-05-18 12:21 小米阅读(474) 评论(0) 编辑收藏所属分类: Java

常用链接

留言簿(21)

随笔分类

随笔档案

文章分类

文章档案

我的朋友们

我的链接

搜索

积分与排名

最新评论

阅读排行榜

评论排行榜