以下方法為阻塞模式（單線程）
只能干一件事。

import lombok.extern.slf4j.Slf4j;import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.ServerSocketChannel; import java.nio.channels.SocketChannel; import java.util.ArrayList; import java.util.List;import static com.netty.c1.ByteBufferUtil.debugRead;@Slf4j(topic = "c.Server") public class Server {public static void main(String[] args) throws IOException {ByteBuffer buffer = ByteBuffer.allocate(16);// 創建服務器ServerSocketChannel ssc = ServerSocketChannel.open();// 綁定監聽端口ssc.bind(new InetSocketAddress(8080));List<SocketChannel> channels = new ArrayList<>();while(true) {log.debug("connection...");// 建立與客戶端的連接SocketChannel sc = ssc.accept(); // 阻塞方法，線程停止運行log.debug("connected...{}",sc);channels.add(sc);// 接受客戶端發送的數據for (SocketChannel channel : channels) {log.debug("before read...{}",channel);channel.read(buffer); // 阻塞方法，線程停止運行buffer.flip();debugRead(buffer);buffer.clear();log.debug("after read...{}",channel);}}} }

以下方法為非阻塞模式（單線程）

import lombok.extern.slf4j.Slf4j;import java.io.IOException; import java.net.InetSocketAddress; import java.nio.ByteBuffer; import java.nio.channels.ServerSocketChannel; import java.nio.channels.SocketChannel; import java.util.ArrayList; import java.util.List;import static com.netty.c1.ByteBufferUtil.debugRead;@Slf4j(topic = "c.Server") public class Server {public static void main(String[] args) throws IOException {ByteBuffer buffer = ByteBuffer.allocate(16);// 創建服務器ServerSocketChannel ssc = ServerSocketChannel.open();// 非阻塞模式ssc.configureBlocking(false);// 綁定監聽端口ssc.bind(new InetSocketAddress(8080));List<SocketChannel> channels = new ArrayList<>();// 有一個缺點:沒有連接請求時，也會不斷循環。// 沒有數據可讀時，也會不斷循環。while(true) {//log.debug("connection...");// 建立與客戶端的連接SocketChannel sc = ssc.accept(); // 非阻塞，線程還會繼續運行。如果沒有建立連接，sc是nullif(sc != null){log.debug("connected...{}",sc);sc.configureBlocking(false);channels.add(sc);}// 接受客戶端發送的數據for (SocketChannel channel : channels) {//log.debug("before read...{}",channel);int read = channel.read(buffer); // 非阻塞，線程仍然繼續運行。如果沒有讀到數據，read返回0if(read > 0) {buffer.flip();debugRead(buffer);buffer.clear();log.debug("after read...{}", channel);}}}} }

總結

以上是生活随笔為你收集整理的netty-阻塞模式,非阻塞模式的全部內容，希望文章能夠幫你解決所遇到的問題。

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