수다닷컴

이해도 잘 안가고..ㅜㅜ
특히 selector 와 SelectionKey 가 돌아가는 원리가 참...이해가 안되네요
그래서 책의 예제를 좀더 간추려서 .. 이해하기 쉽게 만들어 봤는데요
이놈이 안돌아가네요..
단순히 서버에서 클라이언트의 접속을 받아들이는건데요
java.net.ConnectException : Connection refused : connect

생략
이렇게 나오네요
분명히 책의 예제에서 서버가 클라이언트 접속처리 하는부분만 가져온거 같은데...
아래는 소스입니다.
서버
import java.nio.*;
import java.net.*;
import java.io.*;
import java.nio.channels.*;
import java.nio.channels.spi.*;
import java.nio.charset.*;
import java.util.*;class SimpleChatServer extends Thread{
private ServerSocketChannel Server;
private Selector acceptSelector;
private static final int PORT = 30000;

public SimpleChatServer(){
try{

acceptSelector = Selector.open();
Server = ServerSocketChannel.open();
Server.configureBlocking(false);
InetSocketAddress address = new InetSocketAddress(192.168.1.3,PORT);
System.out.println(서버열림: + address);

Server.register(acceptSelector,SelectionKey.OP_ACCEPT);
}catch(Exception e){ e.printStackTrace();}
}
public void run(){
while(true){
try{
acceptSelector.select();
Set readyKeys = acceptSelector.selectedKeys();
for(Iterator i = readyKeys.iterator();i.hasNext();){
SelectionKey key = (SelectionKey)i.next();
i.remove();
ServerSocketChannel acceptChannel = (ServerSocketChannel)key.channel();

SocketChannel incomingChannel = acceptChannel.accept();
System.out.println(접속처리);
}
}catch(Exception e){
e.printStackTrace();
}
}
}

public static void main(String[] args){
SimpleChatServer sev = new SimpleChatServer();
sev.start();
}}
클라이언트import java.io.*;
import java.net.*;
import java.nio.*;
import java.nio.channels.*;

class SimpleChatClient extends Thread{
private ByteBuffer buffer;
private InetSocketAddress address;
private SocketChannel socketChannel;
private static final int PORT = 30000;
private static final String host =192.168.1.3;
public SimpleChatClient(){
try{
buffer = ByteBuffer.allocateDirect(2048);
address = new InetSocketAddress(InetAddress.getByName(host),PORT);
socketChannel = SocketChannel.open();
socketChannel.connect(address);
}catch(Exception e) { e.printStackTrace();}
}
public void run(){
int chars_read;
try{
while(socketChannel.isConnected()){
socketChannel.read(buffer);
buffer.flip();
System.out.println(buffer.toString());
buffer.clear();
}
}catch(Exception e){
e.printStackTrace();
}
}
public static void main(String[] args){
SimpleChatClient client = new SimpleChatClient();
client.start();
}
}

신청하기