使用aio，實現客戶端和服務器 對一個數進行輪流累加

//服務器端

public class Server {

private static ExecutorService executorService = Executors.newFixedThreadPool(4);

public static void main(String[] args) {

try {

AsynchronousChannelGroup group=AsynchronousChannelGroup.withThreadPool(executorService);

AsynchronousServerSocketChannel server=AsynchronousServerSocketChannel.open(group);

server.bind(new InetSocketAddress(8881));

server.accept(null, new CompletionHandler() {

@Override

public void completed(AsynchronousSocketChannel client, Object attachment) {

server.accept(null, this);

try {

System.out.println("服務器收到客戶端"+client.getRemoteAddress().toString());

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

ByteBuffer buffer=ByteBuffer.allocate(1024);

client.read(buffer, buffer, new CompletionHandler() {

@Override

public void completed(Integer index, ByteBuffer buffer) {

try {

buffer.flip();

int i=buffer.getInt(0);

System.out.println(Thread.currentThread().getName()+" 服務器收到客戶端消息"+client.getRemoteAddress().toString()+ " "+i);

buffer.putInt(0, i+1);

client.write(buffer).get();//這個是異步的，一定要用get 確保執行結束 才能clear

buffer.clear();

client.read(buffer,buffer,this);

}catch (Exception e) {

e.printStackTrace();

}

}

@Override

public void failed(Throwable exc, ByteBuffer attachment) {

throw new RuntimeException(exc.getMessage());

}

});

}

@Override

public void failed(Throwable exc, Object attachment) {

throw new RuntimeException(exc.getMessage());

}

});

while(true) {

Thread.sleep(2000);

}

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (InterruptedException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

//客戶端

public class Client {

public static void main(String[] args) {

try {

AsynchronousSocketChannel client=AsynchronousSocketChannel.open();

client.connect(new InetSocketAddress("127.0.0.1", 8881), null, new CompletionHandler() {

@Override

public void completed(Void result, Object attachment) {

System.out.println("連接服務器成功");

ByteBuffer buffer=ByteBuffer.allocate(1024);

buffer.putInt(0,1);

try {

client.write(buffer).get();

} catch (InterruptedException e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

} catch (ExecutionException e1) {

// TODO Auto-generated catch block

e1.printStackTrace();

}

buffer.clear();

client.read(buffer, buffer, new CompletionHandler() {

@Override

public void completed(Integer result, ByteBuffer buffer) {

try {

//System.out.println("result="+result+" postition="+buffer.position()+" limit="+buffer.limit());

buffer.flip();

int i=buffer.getInt(0);

System.out.println("客戶端收到服務器返回的消息"+client.getRemoteAddress().toString()+" "+i);

buffer.putInt(0, i+1);

Thread.sleep(2000);

client.write(buffer).get();

buffer.clear();

client.read(buffer, buffer, this);

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (InterruptedException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (ExecutionException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

@Override

public void failed(Throwable exc, ByteBuffer attachment) {

throw new RuntimeException(exc.getMessage());

}

});

}

@Override

public void failed(Throwable exc, Object attachment) {

throw new RuntimeException(exc.getMessage());

}

});

while(true) {

Thread.sleep(2000);

}

} catch (IOException e) {

// TODO Auto-generated catch block

e.printStackTrace();

} catch (InterruptedException e) {

// TODO Auto-generated catch block

e.printStackTrace();

}

}

}

總結

以上是生活随笔為你收集整理的java aio聊天_JAVA aio简单使用的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。