1，背景
隨著互聯網的發展，網站應用的規模不斷擴大，常規的垂直應用架構已無法應對，分佈式服務架構以及流動運算架構勢在必行，亟需一個治理系統確保架構有條不紊的演進
單一應用架構
##當網站流量很小時，只需一個應用，將所有功能都部署在一起，以減少部署節點和成本
此時，用於簡化增刪改查工作量的 資料訪問框架(ORM) 是關鍵
垂直應用架構
當訪問量逐漸增加，單一應用增加機器帶來的加速度越來越小，將應用程式拆成互不相干的幾個應用，以提升效率
此時，用於加速前端頁面開發的 Web框架(MVC) 是關鍵
分散式服務架構
以業務線分割
#停止RPC濫用，垂直業務內優先透過本地jar調用，跨業務才採用RPC調用
正確的識別業務邏輯的歸屬，讓各個模組最大化內聚，從性能，可用性和維護性上減少耦合
每次發佈只部署部分伺服器
每個節點可依不同需求伸縮擴充
# #每個應用程式之間更新，部署，運行不影響
部署分離
團隊分離
資料分離
當垂直應用越來越多，應用程式之間互動不可避免，將核心業務抽取出來，作為獨立的服務，逐漸形成穩定的服務中心，使前端應用能更快速的響應多變的市場需求
此時，用於提高業務復用及整合的 分散式服務框架(RPC) 是關鍵
分散式服務RPC框架
流動運算架構
當服務越來越多，容量的評估，小服務資源的浪費等問題逐漸顯現，此時需增加一個調度中心基於訪問壓力實時管理叢集容量，提高叢集利用率
此時，用於提高機器利用率的資源調度和治理中心(SOA)是關鍵
Netty 線程模型Netty的執行緒模型主要是基於React,因為考慮到應用場景的不同所以演化出多種版本。 單執行緒模式即接收服務請求以及執行IO操作都由一個執行緒來完成，由於採用的是IO多路復用這類無阻塞IO操作，所以在請求量不大的情況下單執行緒模式也是可以解決一部分場景問題的。
接收請求執行緒與工作執行緒分工
接收請求執行緒主要負責建立鏈路，然後將請求委派給工作執行緒
工作執行緒負責編碼解碼讀取IO等操作
目前我實作的RPC是採用多接收多工作執行緒模式，在服務端是這樣綁定連接埠的：
public void bind(ServiceConfig serviceConfig) {EventLoopGroup bossGroup = new NioEventLoopGroup();EventLoopGroup workerGroup = new NioEventLoopGroup();try {ServerBootstrap bootstrap = new ServerBootstrap();
bootstrap.group(bossGroup, workerGroup)
.channel(NioServerSocketChannel.class)
.childHandler(this.rpcServerInitializer)
.childOption(ChannelOption.SO_KEEPALIVE,true)
;try {ChannelFuture channelFuture = bootstrap.bind(serviceConfig.getHost(),serviceConfig.getPort()).sync();//...channelFuture.channel().closeFuture().sync();
} catch (InterruptedException e) {throw new RpcException(e);
}
}finally {
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}boosGroup就是一組用來接收服務請求的
workerGroup就是一組具體負責IO操作的
增加業務執行緒只需要將handle的操作進一步委派給執行緒池即可，這裡為了擴充所以需要定義介面：
public interface RpcThreadPool {Executor getExecutor(int threadSize,int queues);
}參考了dubbo執行緒池
@Qualifier("fixedRpcThreadPool")@Componentpublic class FixedRpcThreadPool implements RpcThreadPool {private Executor executor;@Overridepublic Executor getExecutor(int threadSize,int queues) {if(null==executor) {synchronized (this) {if(null==executor) {
executor= new ThreadPoolExecutor(threadSize, threadSize, 0L, TimeUnit.MILLISECONDS,
queues == 0 ? new SynchronousQueue<Runnable>() :(queues < 0 ? new LinkedBlockingQueue<Runnable>(): new LinkedBlockingQueue<Runnable>(queues)),new RejectedExecutionHandler() {@Overridepublic void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { //...}
});
}
}
}return executor;
}
}##小插曲：執行緒池工廠當有多個執行緒池實作時，透過執行緒池名稱來動態選擇執行緒池。記的有一次一朋友突然問java 線程池中的那個coreSize是什麼意思？我頓時短路了，因為平常也不怎麼寫多線程，想到平常用的比較多的資料庫線程池，裡面的參數倒是印像比較深，但就是想不起來有個coreSize。後來才又仔細看了下線程池的一些參數。現在藉這個機會又可以多再看看，以免再短路。
@Componentpublic class RpcThreadPoolFactory {@Autowiredprivate Map<String,RpcThreadPool> rpcThreadPoolMap;public RpcThreadPool getThreadPool(String threadPoolName){return this.rpcThreadPoolMap.get(threadPoolName);
}
}@Overrideprotected void channelRead0(ChannelHandlerContext channelHandlerContext, RpcRequest rpcRequest) {this.executor.execute(new Runnable() {@Overridepublic void run() {RpcInvoker rpcInvoker=RpcServerInvoker.this.buildInvokerChain(RpcServerInvoker.this);RpcResponse response=(RpcResponse) rpcInvoker.invoke(RpcServerInvoker.this.buildRpcInvocation(rpcRequest));
channelHandlerContext.writeAndFlush(response);
}
});
}以上是RPC框架的實例詳解的詳細內容。更多資訊請關注PHP中文網其他相關文章！
