AIO程式設計（NIO2.0）及程式碼實現

AIO程式設計

NIO 2.0引入了新的非同步通道的概念，並提供了非同步檔案通道和非同步套接字通道的實現。

非同步的套接字通道時真正的非同步非阻塞I/O，對應於UNIX網路程式設計中的事件驅動I/O（AIO）。他不需要過多的Selector對註冊的通道進行輪詢即可實現非同步讀寫，從而簡化了NIO的程式設計模型。

直接上程式碼吧。

3.1、Server端程式碼

Server：

print?

package com.anxpp.io.calculator.aio.server;
/**
* AIO服務端
* @author yangtao__anxpp.com
* @version 1.0
*/
publicclass Server {
privatestaticint DEFAULT_PORT = 12345;
privatestatic AsyncServerHandler serverHandle;
publicvolatilestaticlong clientCount = 0;
publicstaticvoid start(){
start(DEFAULT_PORT);
}
publicstaticsynchronizedvoid start(int port){
if(serverHandle!=

null)
return;
serverHandle = new AsyncServerHandler(port);
new Thread(serverHandle,"Server").start();
}
publicstaticvoid main(String[] args){
Server.start();
}
}

AsyncServerHandler：

print?

package com.anxpp.io.calculator.aio.server;
import

java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.channels.AsynchronousServerSocketChannel;
import java.util.concurrent.CountDownLatch;
publicclass AsyncServerHandler implements Runnable {
public CountDownLatch latch;
public AsynchronousServerSocketChannel channel;
public AsyncServerHandler(int port) {
try {
//建立服務端通道
channel = AsynchronousServerSocketChannel.open();
//繫結埠
channel.bind(new InetSocketAddress(port));
System.out.println("伺服器已啟動，埠號：" + port);
} catch (IOException e) {
e.printStackTrace();
}
}
@Override
publicvoid run() {
//CountDownLatch初始化
//它的作用：在完成一組正在執行的操作之前，允許當前的現場一直阻塞
//此處，讓現場在此阻塞，防止服務端執行完成後退出
//也可以使用while(true)+sleep
//生成環境就不需要擔心這個問題，以為服務端是不會退出的
latch = new CountDownLatch(1);
//用於接收客戶端的連線
channel.accept(this,new AcceptHandler());
try {
latch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}

AcceptHandler：

print?

package com.anxpp.io.calculator.aio.server;
import java.nio.ByteBuffer;
import java.nio.channels.AsynchronousSocketChannel;
import java.nio.channels.CompletionHandler;
//作為handler接收客戶端連線
publicclass AcceptHandler implements CompletionHandler<AsynchronousSocketChannel, AsyncServerHandler> {
@Override
publicvoid completed(AsynchronousSocketChannel channel,AsyncServerHandler serverHandler) {
//繼續接受其他客戶端的請求
Server.clientCount++;
System.out.println("連線的客戶端數：" + Server.clientCount);
serverHandler.channel.accept(serverHandler, this);
//建立新的Buffer
ByteBuffer buffer = ByteBuffer.allocate(1024);
//非同步讀第三個引數為接收訊息回撥的業務Handler
channel.read(buffer, buffer, new ReadHandler(channel));
}
@Override
publicvoid failed(Throwable exc, AsyncServerHandler serverHandler) {
exc.printStackTrace();
serverHandler.latch.countDown();
}
}

ReadHandler：

print?

package com.anxpp.io.calculator.aio.server;
import java.io.IOException;
import java.io.UnsupportedEncodingException;
import java.nio.ByteBuffer;
import java.nio.channels.AsynchronousSocketChannel;
import java.nio.channels.CompletionHandler;
import com.anxpp.io.utils.Calculator;
publicclass ReadHandler implements CompletionHandler<Integer, ByteBuffer> {
//用於讀取半包訊息和傳送應答
private AsynchronousSocketChannel channel;
public ReadHandler(AsynchronousSocketChannel channel) {
this.channel = channel;
}
//讀取到訊息後的處理
@Override
publicvoid completed(Integer result, ByteBuffer attachment) {
//flip操作
attachment.flip();
//根據
byte[] message = newbyte[attachment.remaining()];
attachment.get(message);
try {
String expression = new String(message, "UTF-8");
System.out.println("伺服器收到訊息: " + expression);
String calrResult = null;
try{
calrResult = Calculator.cal(expression).toString();
}catch(Exception e){
calrResult = "計算錯誤：" + e.getMessage();
}
相關推薦

AIO程式設計（NIO2.0）及程式碼實現

AIO程式設計 NIO 2.0引入了新的非同步通道的概念，並提供了非同步檔案通道和非同步套接字通道的實現。非同步的套接字通道時真正的非同步非阻塞I/O，對應於UNIX網路程式設計中的事件驅

安全程式設計（十五）- finally程式碼塊和Exception物件

1.異常處理的時候，finally程式碼塊的作用是什麼？無論是否丟擲異常，fianlly程式碼塊總會被執行！就算沒有catch的情況下丟擲異常，finally任會被執行。finally程式碼塊的作用是釋放資源，比如I/O緩衝區，資料庫的連

矩陣乘法（行邏輯連結的順序表）及程式碼實現

矩陣相乘的前提條件是：乘號前的矩陣的列數要和乘號後的矩陣的行數相等。且矩陣的乘法運算沒有交換律，即 A*B 和 B*A 是不一樣的。例如，矩陣A：矩陣B：由於矩陣 A 的列數和矩陣 B 的行數相等，可以進行 A*B 運算（不能進行 B*A 運算）。計算方法是：用矩陣A的第 i 行和矩陣B中的每

react生命週期API（3.0）及生命週期與定時器的用法；

react的定時器的呼叫必須採用元件生命週期函式去呼叫：有關元件的生命週期，見菜鳥教程： http://www.runoob.com/react/react-component-life-cycle

《大話資料結構4》—— 佇列的順序儲存結構（迴圈佇列）—— C++程式碼實現

佇列 ● 佇列的概念：　　佇列（簡稱作隊，Queue）也是一種特殊的線性表，佇列的資料元素以及資料元素間的邏輯關係和線性表完全相同，其差別是線性表允許在任意位置插入和刪除，而佇列只允許在其一端進行插入操作在其另一端進行刪除操作。佇

光流法（Optical Flow）及OpenCV實現

Optical Flow Optical flow 有兩個假設：亮度恆定：在相鄰連續兩幀中一個目標的畫素強度不會變化。空間一致性：周圍畫素有類似執行。時間規律：相鄰幀時間足夠短，以至於在考慮執行變化時可以忽略它們之間的差異。假設在第一幀中畫素

選擇問題（selection problem）的程式碼實現

問題來源於《資料結構與演算法分析-C語言描述》的課後題。問題描述：設有一組N個數而要確定其中第k個最大者。解題思路：第一種演算法：將N個數讀入一個數組中，在通過某種簡單的演算法，比如氣泡排序法，以遞減順序將陣列排序，然後返回位置k上的元素。第二種演算法：把k個元素讀入

邏輯式程式語言極簡實現（使用C#） - 4. 程式碼實現（完結）

本文是本系列的完結篇。本系列前面的文章： * [邏輯式程式語言極簡實現（使用C#） - 1. 邏輯式程式語言介紹](https://www.cnblogs.com/skabyy/p/13199800.html) * [邏輯式程式語言極簡實現（使用C#） - 2. 一道邏輯題：誰是凶手](https://ww

OpenCV（一）——高斯卷積核原理及程式碼實現

貼出getGaussianKernel原始碼在smooth.cpp中提示：Gaussian核基於正態分佈函式設計 μ是均值，σ^2是方差正態函式（即一維Gaussian卷積核）如下二維卷積核通過對一維積分得到，並且μ = 0 根據如下原始碼可知

Python核心程式設計（第二版）第六章部分習題程式碼

6-2字串識別符號.修改例 6-1 的 idcheck.py 指令碼,使之可以檢測長度為一的識別符號,並且可以識別 Python 關鍵字,對後一個要求,你可以使用 keyword 模組(特別是 keyword.kelist)來輔助 #!/usr/bin/env python

大資料教程（8.2）wordcount程式原理及程式碼實現/執行

      上一篇部落格分享了mapreduce的程式設計思想，本節博主將帶小夥伴們瞭解wordcount程式的原理和程式碼實現/執行細節。通過本節可以對mapreduce程式有一個大概的認識，其實hadoop中的map、reduce程

大資料教程（8.8）MR內部的shuffle過程詳解&combiner的執行機制及程式碼實現

        之前的文章已經簡單介紹過mapreduce的運作流程，不過其內部的shuffle過程並未深入講解；本篇部落格將分享shuffle的全過程。

大資料教程（8.8）MR內部的shuffle過程詳解&combiner的執行機制及程式碼實現

        之前的文章已經簡單介紹過mapreduce的運作流程，不過其內部的shuffle過程並未深入講解；本篇部落格將分享shuffle的全過程。

【機器學習】Apriori演算法——原理及程式碼實現（Python版）

Apriopri演算法 Apriori演算法在資料探勘中應用較為廣泛，常用來挖掘屬性與結果之間的相關程度。對於這種尋找資料內部關聯關係的做法，我們稱之為：關聯分析或者關聯規則學習。而Apriori演算法就是其中非常著名的演算法之一。關聯分析，主要是通過演算法在大規模資料集中尋找頻繁項集和關聯規則。

稀疏矩陣的儲存方法（3種）及C語言程式碼實現

稀疏矩陣，即含有少量非 0 元素的矩陣，如圖 1 所示：圖 1 稀疏矩陣該矩陣中非 0 元素的數量比較少，與其使用普通方式將矩陣中的所有資料元素一一儲存，不如只儲存非 0 元素更節省記憶體空間，拿圖 1 中矩陣來說，只需儲存元素 3、4、5 即可（此類儲存方式被稱為稀疏矩陣的壓縮儲存）。

（四）DFS檔案操作的原理及程式碼實現

1、檔案操作原理 1.1、下載過程 Client向namenode發起Open file 請求。目的是獲取指定檔案的輸入流 namenode收到請求之後，會檢查路徑的合法性，客戶端的操作許可權。如果檢測未通過，則直接報錯返回 Client也會向namenode發起Get

矩陣轉置演算法及程式碼實現（三元組順序表）

矩陣的轉置實際上就是將資料元素的行標和列標互換，即 T(i,j) = M(j,i) 。例如：圖1 矩陣的轉置相應地，三元組錶轉變為：圖2 三元組表矩陣的轉置，經歷了三個步驟：矩陣的行數 n 和列數 m 的值交換；將三元組中的i和j調換；轉換之後的表同樣按照行序（置換前的列序

Java-十種內部排序實現（選擇，冒泡，插入，希爾，堆，歸併，快速，基數，計數，桶）及程式碼下載

選擇排序氣泡排序插入排序希爾排序堆排序歸併排序快速排序基數排序計數排序桶排序 1. 選擇排序這個排序方法最簡單，廢話不多說，直接上程式碼： public class SelectSort { /** * 選擇排

Java程式設計（Java9版）：第8章程式碼塊與內部類

類的成員，除了屬性與方法（包含構造器），還有程式碼塊和內部類 8.1 程式碼塊 jshell> class CodeBlock{ ...> { ...> System.out.println("構造程式碼塊"); ...&g

k-中心點演算法（k-medoids）及Matlab程式碼實現

k-中心點演算法（k-medoids）及Matlab程式碼 1. 提出： k-means演算法是每次選擇簇的均值作為新的中心點，迭代直到簇中心不再變化（趨於穩定）。其缺點是對離群點特別敏感，因為一個很大的極端值物件會扭曲資料分佈，使簇均值嚴重偏離；於是我

AIO程式設計（NIO2.0）及程式碼實現

AIO程式設計

3.1、Server端程式碼

相關推薦