java高並發socket

㈠ java的多線程是交替佔用CPU，不是真正的並行這個和單線程不是一樣的嗎為什麼會效率會更高

比如某線程需要延時等待某操作完成,這時就可以用線程調度執行其他等待執行的線程,這樣更完全地利用了cpu的性能,因此效率高

㈡ 同等條件高並發壓力測試，tomcat請求正常，nginx負載均衡Connection refused

如下：java.net.ConnectException: Connection refused: connectat java.net.DualStackPlainSocketImpl.connect0(Native Method)at java.net.DualStackPlainSocketImpl.socketConnect(Unknown Source)at java.net.AbstractPlainSocketImpl.doConnect(Unknown Source)at java.net.AbstractPlainSocketImpl.connectToAddress(Unknown Source)at java.net.AbstractPlainSocketImpl.connect(Unknown Source)at java.net.PlainSocketImpl.connect(Unknown Source)at java.net.SocksSocketImpl.connect(Unknown Source)at java.net.Socket.connect(Unknown Source)at org.apache.http.conn.scheme.PlainSocketFactory.connectSocket(PlainSocketFactory.java:121)at org.apache.http.impl.conn..openConnection(.java:180)at org.apache.jmeter.protocol.http.sampler.hc.ManagedClientConnectionImpl.open(ManagedClientConnectionImpl.java:318)at org.apache.jmeter.protocol.http.sampler.MeasuringConnectionManager$MeasuredConnection.open(MeasuringConnectionManager.java:114)at org.apache.http.impl.client.DefaultRequestDirector.tryConnect(DefaultRequestDirector.java:610)at org.apache.http.impl.client.DefaultRequestDirector.execute(DefaultRequestDirector.java:445)at org.apache.http.impl.client.AbstractHttpClient.doExecute(AbstractHttpClient.java:835)at org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:83)at org.apache.jmeter.protocol.http.sampler.HTTPHC4Impl.executeRequest(HTTPHC4Impl.java:697)at org.apache.jmeter.protocol.http.sampler.HTTPHC4Impl.sample(HTTPHC4Impl.java:455)at org.apache.jmeter.protocol.http.sampler.HTTPSamplerProxy.sample(HTTPSamplerProxy.java:74)at org.apache.jmeter.protocol.http.sampler.HTTPSamplerBase.sample(HTTPSamplerBase.java:1189)at org.apache.jmeter.protocol.http.sampler.HTTPSamplerBase.sample(HTTPSamplerBase.java:1178)at org.apache.jmeter.threads.JMeterThread.executeSamplePackage(JMeterThread.java:490)at org.apache.jmeter.threads.JMeterThread.processSampler(JMeterThread.java:416)at org.apache.jmeter.threads.JMeterThread.run(JMeterThread.java:250)at java.lang.Thread.run(Unknown Source)

㈢ 如何利用Java開發高性能高並發Web應用.ppt

1、提供HTML靜態訪問

web界面上最快的訪問速度是什麼？當然是最原始的HTML文件訪問,對於其他語言 比如 jsp ,asp,php等等,他們首先要通過伺服器解析成html之後在返回給訪問者，如果我們能提供全部是htm來的頁面，那麼就能大大的降低伺服器和資料庫資源的利用和提高網站的並發，所以我們盡可能使我們的網站上的頁面採用靜態頁面來實現，這個最簡單的方法其實也是最有效的方法。當然實現這種方式大家比較了解的就是信息發布系統CMS,信息發布系統可以實現最簡單的信息錄入自動生成靜態頁面，還能具備頻道管理、許可權管理、自動抓取等功能，對於一個大型網站來說，擁有一套高效、可管理的CMS是必不可少的。
在後續的文章中我們會單獨的使用jsp + servlet實現一個簡單的信息發布系統.
2、使用獨立的圖片伺服器

為什麼要把圖片單獨設置一個伺服器？對於Web伺服器來說，圖片消耗的伺服器資源是最多的，如果能把所有的圖片資源放到一個單獨的圖片伺服器中進行處理的話，可以降低提供頁面訪問請求的伺服器系統壓力，從而能進一步的提高web程序的並發.所以在有條件的情況下最好能把圖片放置到一個單獨的伺服器中.
3、配置多台資料庫伺服器，多個資料庫集群
集群（Cluster）技術是使用特定的連接方式，將價格相對較低的硬體設備結合起來，同時也能提供高性能相當的任務處理能力。
越是大型高並發的應用，資料庫的壓力就會越大，如果資料庫操作很頻繁，資料庫的瓶頸很快就能顯現出來，這時一台資料庫將很快無法滿足應用，於是我們需要使用資料庫集群。
資料庫集群就是使用多個資料庫伺服器分擔請求的壓力，達到快速響應的目的.
4、使用緩存
所謂的緩存就是把數據咱是放置到內存中，前台在請求的時候直接從內存中讀取數據，而不需要去查詢資料庫或者讀取文件等，這樣就能做到最快的響應。網站架構和網站開發中的緩存是非常重要的。
目前有很多開源的緩沖實現方案，APC，File，SQLite，Memcache等等各種類庫實現著不同的緩存方式，只有通過了解他們的實現方式，根據具體應用具體選擇，才會使緩存系統發揮出最大的性能。
對於java開發來說，大名頂頂的 分布式緩存系統Memcache 可能是最好的選擇，他提供一個基於Socket的訪問方式，使得該緩存系統支持遠程讀寫訪問。盡管這個緩存的內容可能是存在內存中，也可能是存在文件內。

㈣ java並發常識

1.java並發編程是什麼
1， 保證線程安全的三種方法： a， 不要跨線程訪問共享變數b， 使共享變數是final類型的c， 將共享變數的操作加上同步 2， 一開始就將類設計成線程安全的， 比在後期重新修復它，更容易。

3， 編寫多線程程序， 首先保證它是正確的， 其次再考慮性能。 4， 無狀態或只讀對象永遠是線程安全的。

5， 不要將一個共享變數 *** 在多線程環境下（無同步或不可變性保護） 6， 多線程環境下的延遲載入需要同步的保護， 因為延遲載入會造成對象重復實例化 7， 對於volatile聲明的數值類型變數進行運算， 往往是不安全的（volatile只能保證可見性，不能保證原子性）。 詳見volatile原理與技巧中， 臟數據問題討論。

8， 當一個線程請求獲得它自己佔有的鎖時（同一把鎖的嵌套使用）， 我們稱該鎖為可重入鎖。在jdk1。

5並發包中， 提供了可重入鎖的java實現-ReentrantLock。 9， 每個共享變數，都應該由一個唯一確定的鎖保護。

創建與變數相同數目的ReentrantLock， 使他們負責每個變數的線程安全。 10，雖然縮小同步塊的范圍， 可以提升系統性能。

但在保證原子性的情況下， 不可將原子操作分解成多個synchronized塊。 11， 在沒有同步的情況下， 編譯器與處理器運行時的指令執行順序可能完全出乎意料。

原因是， 編譯器或處理器為了優化自身執行效率， 而對指令進行了的重排序（reordering）。 12， 當一個線程在沒有同步的情況下讀取變數， 它可能會得到一個過期值， 但是至少它可以看到那個線程在當時設定的一個真實數值。

而不是憑空而來的值。 這種安全保證， 稱之為最低限的安全性（out-of-thin-air safety） 在開發並發應用程序時， 有時為了大幅度提高系統的吞吐量與性能， 會採用這種無保障的做法。

但是針對， 數值的運算， 仍舊是被否決的。 13, volatile變數，只能保證可見性， 無法保證原子性。

14， 某些耗時較長的網路操作或IO， 確保執行時， 不要佔有鎖。 15， 發布（publish）對象， 指的是使它能夠被當前范圍之外的代碼所使用。

（引用傳遞）對象逸出（escape）， 指的是一個對象在尚未准備好時將它發布。 原則： 為防止逸出， 對象必須要被完全構造完後， 才可以被發布（最好的解決方式是採用同步） this關鍵字引用對象逸出 例子： 在構造函數中， 開啟線程， 並將自身對象this傳入線程， 造成引用傳遞。

而此時， 構造函數尚未執行完， 就會發生對象逸出了。 16， 必要時， 使用ThreadLocal變數確保線程封閉性（封閉線程往往是比較安全的， 但一定程度上會造成性能損耗）封閉對象的例子在實際使用過程中， 比較常見， 例如 hibernate openSessionInView機制， jdbc的connection機制。

17， 單一不可變對象往往是線程安全的（復雜不可變對象需要保證其內部成員變數也是不可變的）良好的多線程編程習慣是： 將所有的域都聲明為final， 除非它們是可變的。
2.Java線程並發協作是什麼
線程發生死鎖可能性很小，即使看似可能發生死鎖的代碼，在運行時發生死鎖的可能性也是小之又小。

發生死鎖的原因一般是兩個對象的鎖相互等待造成的。 在《Java線程：線程的同步與鎖》一文中，簡述死鎖的概念與簡單例子，但是所給的例子是不完整的，這里給出一個完整的例子。

/** * Java線程：並發協作-死鎖 * * @author Administrator 2009-11-4 22:06:13 */ public class Test { public static void main(String[] args) { DeadlockRisk dead = new DeadlockRisk(); MyThread t1 = new MyThread(dead, 1, 2); MyThread t2 = new MyThread(dead, 3, 4); MyThread t3 = new MyThread(dead, 5, 6); MyThread t4 = new MyThread(dead, 7, 8); t1。 start(); t2。

start(); t3。start(); t4。

start(); } } class MyThread extends Thread { private DeadlockRisk dead; private int a, b; MyThread(DeadlockRisk dead, int a, int b) { this。 dead = dead; this。

a = a; this。b = b; } @Override public void run() { dead。

read(); dead。write(a, b); } } class DeadlockRisk { private static class Resource { public int value; }。
3.如何學習Java高並發
1.學習 *** 並發框架的使用，如ConcurrentHashMAP,CopyOnWriteArrayList/Set等2.幾種並發鎖的使用以及線程同步與互斥，如ReentainLock,synchronized,Lock,CountDownLatch,Semaphore等3.線程池如Executors,ThreadPoolExecutor等4.Runable,Callable,RescureTask,Future,FutureTask等5.Fork-Join框架以上基本包含完了，如有缺漏請原諒。
4.並發編程的Java抽象有哪些呢
一、機器和OS級別抽象 （1）馮諾伊曼模型 經典的順序化計算模型，貌似可以保證順序化一致性，但是沒有哪個現代的多處理架構會提供順序一致性，馮氏模型只是現代多處理器行為的模糊近似。

這個計算模型，指令或者命令列表改變內存變數直接契合命令編程泛型，它以顯式的演算法為中心，這和聲明式編程泛型有區別。 就並發編程來說，會顯著的引入時間概念和狀態依賴 所以所謂的函數式編程可以解決其中的部分問題。

（2）進程和線程 進程抽象運行的程序，是操作系統資源分配的基本單位，是資源cpu，內存，IO的綜合抽象。 線程是進程式控制制流的多重分支，它存在於進程里，是操作系統調度的基本單位，線程之間同步或者非同步執行，共享進程的內存地址空間。

（3）並發與並行 並發，英文單詞是concurrent，是指邏輯上同時發生，有人做過比喻，要完成吃完三個饅頭的任務，一個人可以這個饅頭咬一口，那個饅頭咬一口，這樣交替進行，最後吃完三個饅頭，這就是並發，因為在三個饅頭上同時發生了吃的行為，如果只是吃完一個接著吃另一個，這就不是並發了，是排隊，三個饅頭如果分給三個人吃，這樣的任務完成形式叫並行，英文單詞是parallel。 回到計算機概念，並發應該是單CPU時代或者單核時代的說法，這個時候CPU要同時完成多任務，只能用時間片輪轉，在邏輯上同時發生，但在物理上是串列的。

現在大多數計算機都是多核或者多CPU，那麼現在的多任務執行方式就是物理上並行的。 為了從物理上支持並發編程，CPU提供了相應的特殊指令，比如原子化的讀改寫，比較並交換。

（4）平台內存模型 在可共享內存的多處理器體系結構中，每個處理器都有它自己的緩存，並且周期性的與主存同步，為什麼呢？因為處理器通過降低一致性來換取性能，這和CAP原理通過降低一致性來獲取伸縮性有點類似，所以大量的數據在CPU的寄存器中被計算，另外CPU和編譯器為了性能還會亂序執行，但是CPU會提供存儲關卡指令來保證存儲的同步，各種平台的內存模型或者同步指令可能不同，所以這里必須介入對內存模型的抽象，JMM就是其中之一。 二、編程模型抽象 （1）基於線程模型 （2）基於Actor模型 （3）基於STM軟體事務內存 …… Java體系是一個基於線程模型的本質編程平台，所以我們主要討論線程模型。

三、並發單元抽象 大多數並發應用程序都是圍繞執行任務進行管理的，任務是抽象，離散的工作單元，所以編寫並發程序，首要工作就是提取和分解並行任務。 一旦任務被抽象出來，他們就可以交給並發編程平台去執行，同時在任務抽象還有另一個重要抽象，那就是生命周期，一個任務的開始，結束，返回結果，都是生命周期中重要的階段。

那麼編程平台必須提供有效安全的管理任務生命周期的API。 四、線程模型 線程模型是Java的本質模型，它無所不在，所以Java開發必須搞清楚底層線程調度細節，不搞清楚當然就會有struts1,struts2的原理搞不清楚的基本災難（比如在struts2的action中塞入狀態，把struts2的action配成單例）。

用線程來抽象並發編程，是比較低級別的抽象，所以難度就大一些，難度級別會根據我們的任務特點有以下幾個類別 （1）任務非常獨立，不共享，這是最理想的情況，編程壓力為0。 (2)共享數據，壓力開始增大，必須引入鎖，Volatile變數，問題有活躍度和性能危險。

（3）狀態依賴，壓力再度增大，這時候我們基本上都是求助jdk 提供的同步工具。 五、任務執行 任務是一個抽象體，如果被抽象了出來，下一步就是交給編程平台去執行，在Java中，描述任務的一個基本介面是Runnable，可是這個抽象太有限了，它不能返回值和拋受檢查異常，所以Jdk5。

0有另外一個高級抽象Callable。 任務的執行在Jdk中也是一個底級別的Thread，線程有好處，但是大量線程就有大大的壞處，所以如果任務量很多我們並不能就創建大量的線程去服務這些任務，那麼Jdk5。

0在任務執行上做了抽象，將任務和任務執行隔離在介面背後，這樣我們就可以引入比如線程池的技術來優化執行，優化線程的創建。 任務是有生命周期的，所以Jdk5。

0提供了Future這個對象來描述對象的生命周期，通過這個future可以取到任務的結果甚至取消任務。 六、鎖 當然任務之間共享了數據，那麼要保證數據的安全，必須提供一個鎖機制來協調狀態，鎖讓數據訪問原子，但是引入了串列化，降低了並發度，鎖是降低程序伸縮性的原罪，鎖是引入上下文切換的主要原罪，鎖是引入死鎖，活鎖，優先順序倒置的絕對原罪，但是又不能沒有鎖，在Java中，鎖是一個對象，鎖提供原子和內存可見性，Volatile變數提供內存可見性不提供原子，原子變數提供可見性和原子，通過原子變數可以構建無鎖演算法和無鎖數據結構，但是這需要高高手才可以辦到。
5.Java高並發入門要怎麼學習
1、如果不使用框架，純原生Java編寫，是需要了解Java並發編程的，主要就是學習Doug Lea開發的那個java.util.concurrent包下面的API;2、如果使用框架，那麼我的理解，在代碼層面確實不會需要太多的去關注並發問題，反而是由於高並發會給系統造成很大壓力，要在緩存、資料庫操作上要多加考慮。

3、但是即使是使用框架，在工作中還是會用到多線程，就拿常見的CRUD介面來說，比如一個非常耗時的save介面，有多耗時呢？我們假設整個save執行完要10分鍾，所以，在save的時候，就需要採用非同步的方式，也就是單獨用一個線程去save，然後直接給前端返回200。
6.Java如何進行並發多連接socket編程呢
Java多個客戶端同時連接服務端，在現實生活中用得比較多。

同時執行多項任務，第一想到的當然是多線程了。下面用多線程來實現並發多連接。

import java。。

*; import java。io。

*; public class ThreadServer extends Thread { private Socket client; public ThreadServer(Socket c) { this。 client=c; } public void run() { try { BufferedReader in=new BufferedReader(new InputStreamReader(client。

getInputStream())); PrintWriter out=new PrintWriter(client。 getOutputStream()); Mutil User but can't parallel while (true) { String str=in。

readLine(); System。out。

println(str); out。 println("has receive。

"); out。

flush(); if (str。equals("end")) break; } client。

close(); } catch (IOException ex) { } finally { } } public static void main(String[] args)throws IOException { ServerSocket server=new ServerSocket(8000); while (true) { transfer location change Single User or Multi User ThreadServer mu=new ThreadServer(server。 accept()); mu。

start(); } } }J。
7.如何掌握java多線程,高並發,大數據方面的技能
線程：同一類線程共享代碼和數據空間，每個線程有獨立的運行棧和程序計數器（PC），線程切換開銷小。

（線程是cpu調度的最小單位）線程和進程一樣分為五個階段：創建、就緒、運行、阻塞、終止。多進程是指操作系統能同時運行多個任務（程序）。

多線程是指在同一程序中有多個順序流在執行。在java中要想實現多線程，有兩種手段，一種是繼續Thread類，另外一種是實現Runable介面.（其實准確來講，應該有三種，還有一種是實現Callable介面，並與Future、線程池結合使用。
8.java工程師需要掌握哪些知識
1.Core Java，就是Java基礎、JDK的類庫，很多童鞋都會說，JDK我懂，但是懂還不足夠，知其然還要知其所以然，JDK的源代碼寫的非常好，要經常查看，對使用頻繁的類，比如String， *** 類（List,Map,Set）等數據結構要知道它們的實現，不同的 *** 類有什麼區別，然後才能知道在一個具體的場合下使用哪個 *** 類更適合、更高效，這些內容直接看源代碼就OK了2.多線程並發編程，現在並發幾乎是寫服務端程序必須的技術，那對Java中的多線程就要有足夠的熟悉，包括對象鎖機制、synchronized關鍵字，concurrent包都要非常熟悉，這部分推薦你看看《Java並發編程實踐》這本書，講解的很詳細3.I/O,Socket編程，首先要熟悉Java中Socket編程，以及I/O包，再深入下去就是Java NIO，再深入下去是操作系統底層的Socket實現，了解Windows和Linux中是怎麼實現socket的4.JVM的一些知識，不需要熟悉，但是需要了解，這是Java的本質，可以說是Java的母體， 了解之後眼界會更寬闊，比如Java內存模型（會對理解Java鎖、多線程有幫助）、位元組碼、JVM的模型、各種垃圾收集器以及選擇、JVM的執行參數（優化JVM）等等，這些知識在《深入Java虛擬機》這本書中都有詳盡的解釋，或者去oracle網站上查看具體版本的JVM規范.5.一些常用的設計模式，比如單例、模板方法、代理、適配器等等，以及在Core Java和一些Java框架里的具體場景的實現，這個可能需要慢慢積累，先了解有哪些使用場景，見得多了，自己就自然而然會去用。

6.常用資料庫（Oracle、MySQL等）、SQL語句以及一般的優化7.JavaWeb開發的框架，比如Spring、iBatis等框架，同樣他們的原理才是最重要的，至少要知道他們的大致原理。8.其他一些有名的用的比較多的開源框架和包，ty網路框架，Apache mon的N多包，Google的Guava等等，也可以經常去Github上找一些代碼看看。

暫時想到的就這么多吧，1-4條是Java基礎，全部的這些知識沒有一定的時間積累是很難搞懂的，但是了解了之後會對Java有個徹底的了解，5和6是需要學習的額外技術，7-8是都是基於1-4條的，正所謂萬變不離其宗，前4條就是Java的靈魂所在，希望能對你有所幫助9.（補充）學會使用Git。如果你還在用SVN的話，趕緊投入Git的懷抱吧。
9.java 多線程的並發到底是什麼意思
一、多線程1、操作系統有兩個容易混淆的概念，進程和線程。

進程：一個計算機程序的運行實例，包含了需要執行的指令；有自己的獨立地址空間，包含程序內容和數據；不同進程的地址空間是互相隔離的；進程擁有各種資源和狀態信息，包括打開的文件、子進程和信號處理。線程：表示程序的執行流程，是CPU調度執行的基本單位；線程有自己的程序計數器、寄存器、堆棧和幀。

同一進程中的線程共用相同的地址空間，同時共享進進程鎖擁有的內存和其他資源。2、Java標准庫提供了進程和線程相關的API，進程主要包括表示進程的java.lang.Process類和創建進程的java.lang.ProcessBuilder類；表示線程的是java.lang.Thread類，在虛擬機啟動之後，通常只有Java類的main方法這個普通線程運行，運行時可以創建和啟動新的線程；還有一類守護線程（damon thread），守護線程在後台運行，提供程序運行時所需的服務。

當虛擬機中運行的所有線程都是守護線程時，虛擬機終止運行。3、線程間的可見性：一個線程對進程 *** 享的數據的修改，是否對另一個線程可見可見性問題：a、CPU採用時間片輪轉等不同演算法來對線程進行調度[java] view plainpublic class IdGenerator{ private int value = 0; public int getNext(){ return value++； } } 對於IdGenerator的getNext（)方法，在多線程下不能保證返回值是不重復的：各個線程之間相互競爭CPU時間來獲取運行機會，CPU切換可能發生在執行間隙。

以上代碼getNext（)的指令序列：CPU切換可能發生在7條指令之間，多個getNext的指令交織在一起。

㈤ socket高並發網路編程服務端有什麼框架

netty;
PayServer.java
package com.miri.pay.scoket;
import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.ChannelFuture;
import io.netty.channel.ChannelInitializer;
import io.netty.channel.ChannelOption;
import io.netty.channel.ChannelPipeline;
import io.netty.channel.EventLoopGroup;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class PayServer implements Runnable
{
private static final Logger DLOG = LoggerFactory.getLogger(PayServer.class);
private final int port;
public PayServer(int port)
{
this.port = port;
}

/**
* 為ServerBootstrap綁定指定埠
*/
public void run()
{
// 用於接收發來的連接請求
final EventLoopGroup bossGroup = new NioEventLoopGroup();
// 用於處理boss接受並且注冊給worker的連接中的信息
final EventLoopGroup workerGroup = new NioEventLoopGroup();

try
{
// 配置伺服器
final ServerBootstrap bootstrap = new ServerBootstrap();
bootstrap.group(bossGroup, workerGroup);
bootstrap.channel(NioServerSocketChannel.class);
bootstrap.option(ChannelOption.SO_BACKLOG, 128);

// 通過NoDelay禁用Nagle,使消息立即發出去，不用等待到一定的數據量才發出去
bootstrap.option(ChannelOption.TCP_NODELAY, true);

// 保持長連接狀態
bootstrap.childOption(ChannelOption.SO_KEEPALIVE, true);

// CustomChannelInitializer是一個特殊的handler，用於方便的配置用戶自定義的handler實現
bootstrap.childHandler(new CustomChannelInitializer());

// 綁定並開始接受傳入的連接
final ChannelFuture future = bootstrap.bind(this.port).sync();
if (future.isSuccess())
{
PayServer.DLOG.info("Start the socket server {} success", this.port);
}
else
{
PayServer.DLOG.info("Start the socket server {} failure,System exit!", this.port);
throw new RuntimeException("Socket服務端啟動失敗");
}
// 等待伺服器套接字關閉
// 關閉伺服器
future.channel().closeFuture().sync();
}
catch (final InterruptedException e)
{
PayServer.DLOG.error("Close the socket server exception occurs,System exit!", e);
throw new RuntimeException("關閉Socket服務端失敗");
}
finally
{
// 關閉所有事件循環終止線程
bossGroup.shutdownGracefully();
workerGroup.shutdownGracefully();
}
}

/**
* 特殊的內部類
* <p>
* 是一個特殊的handler，用於方便的配置用戶自定義的handler實現
* @author xulonghui
*/
static class CustomChannelInitializer extends ChannelInitializer<SocketChannel>
{
@Override
protected void initChannel(SocketChannel ch) throws Exception
{
final ChannelPipeline p = ch.pipeline();
p.addLast(new PayMessageEncoder());
p.addLast(new PayMessageDecoder());
p.addLast(new PayServerHandler());
}
}
}

PayMessageEncoder.java
package com.miri.pay.scoket;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToByteEncoder;
import io.netty.util.CharsetUtil;
import com.miri.pay.model.CommonResponse;
import com.miri.pay.utils.JsonUtil;
/**
*消息編碼器
* <p>
* 編碼從服務端發送出的消息
*/
public class PayMessageEncoder extends MessageToByteEncoder<CommonResponse>
{

@Override
protected void encode(ChannelHandlerContext ctx, CommonResponse rsp, ByteBuf out) throws Exception
{
if (rsp != null)
{
final Object msgContent = rsp.getMsgContent();
// 消息ID,sequenceId和entityId三個加起來是12個長度
int msgLen = 12;
byte[] contentbs = new byte[] {};
if (msgContent != null)
{
final String content = JsonUtil.bean2json(msgContent);
contentbs = content.getBytes(CharsetUtil.UTF_8);
final int cl = contentbs.length;
msgLen += cl;
}
out.writeInt(msgLen);// 寫入當前消息的總長度
out.writeInt(rsp.getMsgId());// 寫入當前消息的消息ID
out.writeInt(rsp.getSequenceId());// 寫入當前消息的SequenceId
out.writeInt(rsp.getEntityId());// 寫入當前消息的EntityId

// 寫入消息主體內容
if (contentbs.length > 0)
{
out.writeBytes(contentbs);
}
}
}
}

PayMessageDecoder.java
package com.miri.pay.scoket;
import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ByteToMessageDecoder;
import io.netty.util.CharsetUtil;
import java.util.List;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.miri.pay.constants.Constants;
import com.miri.pay.model.CommonRequest;
import com.miri.pay.utils.ByteUtil;
/**
* 消息解碼器
* <p>
* 解碼從客戶端請求的消息
*/
public class PayMessageDecoder extends ByteToMessageDecoder
{
private static final Logger DLOG = LoggerFactory.getLogger(PayMessageDecoder.class);
/**
* 表示頭長度的位元組數
*/
private static final int HEAD_LENGTH = 4;
/**
* 所有ID串所屬的位元組數
*/
private static final int ID_STR_LENGTH = 12;
/**
* 單個ID所屬的位元組數
*/
private static final int SINGLE_ID_LENGTH = 4;
@Override
protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception
{
int readable = in.readableBytes();
if (readable < PayMessageDecoder.HEAD_LENGTH)
{
return;
}
in.markReaderIndex(); // 我們標記一下當前的readIndex的位置
final int dataLength = in.readInt(); // 讀取傳送過來的消息的長度。ByteBuf 的readInt()方法會讓他的readIndex增加4
if (dataLength < 0)
{
// 我們讀到的消息體長度為0，這是不應該出現的情況，這里出現這情況，關閉連接。
ctx.close();
}

readable = in.readableBytes();
if (readable < dataLength)
{
// 讀到的消息體長度如果小於我們傳送過來的消息長度，則resetReaderIndex. 這個配合markReaderIndex使用的。把readIndex重置到mark的地方
in.resetReaderIndex();
return;
}
final byte[] body = new byte[dataLength];
in.readBytes(body);
// 判斷是否讀取到內容
final int length = body.length;
if (length == 0)
{
return;// 若未讀出任何內容，則忽略
}

out.add(this.byte2req(body));
}
/**
* 將讀取到的byte數據轉換為請求對象
* @param body
* @return
* @throws Exception
*/
private CommonRequest byte2req(byte[] body) throws Exception
{
final CommonRequest req = new CommonRequest(Constants.INVALID_MSGID);
final int length = body.length;

// 若內容數組的長度小於或等於12，則表示消息主體內容為空，直接返回一個無效的消息出去
if (length < PayMessageDecoder.ID_STR_LENGTH)
{
PayMessageDecoder.DLOG
.info("The client sends the message length is: {}, is invalid message, directly returns a msgId = {} request entity",
length, Constants.INVALID_MSGID);
return req;
}

// 獲取消息ID
final byte[] mbs = new byte[PayMessageDecoder.SINGLE_ID_LENGTH];
System.array(body, 0, mbs, 0, PayMessageDecoder.SINGLE_ID_LENGTH);
final int msgId = ByteUtil.byte4toint(mbs);
req.setMsgId(msgId);
// 獲取sequenceId
final byte[] sbs = new byte[PayMessageDecoder.SINGLE_ID_LENGTH];
System.array(body, 4, sbs, 0, PayMessageDecoder.SINGLE_ID_LENGTH);
final int sequenceId = ByteUtil.byte4toint(sbs);
req.setSequenceId(sequenceId);
// 獲取entityId
final byte[] ebs = new byte[PayMessageDecoder.SINGLE_ID_LENGTH];
System.array(body, 8, ebs, 0, PayMessageDecoder.SINGLE_ID_LENGTH);
final int entityId = ByteUtil.byte4toint(ebs);
req.setEntityId(entityId);

// 獲取消息主體內容
if (length > PayMessageDecoder.ID_STR_LENGTH)
{
final int contentLen = length - PayMessageDecoder.ID_STR_LENGTH;
final byte[] contentbs = new byte[contentLen];
System.array(body, 12, contentbs, 0, contentLen);
final String content = new String(contentbs, CharsetUtil.UTF_8);
req.setMsgContent(content);
}

return req;
}
}

PayServerHandler.java
package com.miri.pay.scoket;
import io.netty.channel.Channel;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelInboundHandlerAdapter;
import io.netty.util.ReferenceCountUtil;
import java.util.HashMap;
import java.util.Map;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.miri.pay.MessageQueue;
import com.miri.pay.model.CommonRequest;
import com.miri.pay.model.PendingBean;
/**
* Socket服務端處理器
*/
public class PayServerHandler extends ChannelInboundHandlerAdapter
{
private static final Logger DLOG = LoggerFactory.getLogger(PayServerHandler.class);
/**
* 外部訂單號-頻道
*/
public static final Map<String, Channel> CHANNELS = new HashMap<String, Channel>();
@Override
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception
{
try
{
PayServerHandler.DLOG.info("Client send to msg is: {}", msg);
final CommonRequest request = (CommonRequest) msg;
final PendingBean bean = new PendingBean(ctx.channel(), request);
MessageQueue.offer(bean);
}
finally
{
ReferenceCountUtil.release(msg);
}
}

@Override
public void channelReadComplete(ChannelHandlerContext ctx) throws Exception
{
ctx.flush();
}
@Override
public void channelActive(ChannelHandlerContext ctx) throws Exception
{
super.channelActive(ctx);
final Channel channel = ctx.channel();
PayServerHandler.DLOG.info("Client active form {}", channel.remoteAddress());
}
@Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception
{
super.channelInactive(ctx);
final Channel channel = ctx.channel();
PayServerHandler.DLOG.info("Client inactive form {}", channel.remoteAddress());
}
@Override
public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception
{
PayServerHandler.DLOG.error("System exception", cause);
ctx.close();
}
}

㈥ socket write error怎麼解決

socket write error，是設置錯誤造成的，解決方法如下：

1、首先打開電腦，來到桌面右下角通知欄，滑鼠移至程序圖標。

㈦ 什麼是Java多線程

多線程的概念？
說起多線程，那麼就不得不說什麼是線程，而說起線程，又不得不說什麼是進程。
進程（Process）是計算機中的程序關於某數據集合上的一次運行活動，是系統進行資源分配和調度的基本單位，是操作系統結構的基礎。在早期面向進程設計的計算機結構中，進程是程序的基本執行實體；在當代面向線程設計的計算機結構中，進程是線程的容器。程序是指令、數據及其組織形式的描述，進程是程序的實體。
進程可以簡單的理解為一個可以獨立運行的程序單位。它是線程的集合，進程就是有一個或多個線程構成的，每一個線程都是進程中的一條執行路徑。
那麼多線程就很容易理解：多線程就是指一個進程中同時有多個執行路徑（線程）正在執行。
為什麼要使用多線程？
1.在一個程序中，有很多的操作是非常耗時的，如資料庫讀寫操作，IO操作等，如果使用單線程，那麼程序就必須等待這些操作執行完成之後才能執行其他操作。使用多線程，可以在將耗時任務放在後台繼續執行的同時，同時執行其他操作。
2.可以提高程序的效率。
3.在一些等待的任務上，如用戶輸入，文件讀取等，多線程就非常有用了。
缺點：
1.使用太多線程，是很耗系統資源，因為線程需要開辟內存。更多線程需要更多內存。
2.影響系統性能，因為操作系統需要在線程之間來回切換。
3.需要考慮線程操作對程序的影響，如線程掛起，中止等操作對程序的影響。
4.線程使用不當會發生很多問題。
總結：多線程是非同步的，但這不代表多線程真的是幾個線程是在同時進行，實際上是系統不斷地在各個線程之間來回的切換（因為系統切換的速度非常的快，所以給我們在同時運行的錯覺）。
2.多線程與高並發的聯系。
高並發：高並發指的是一種系統運行過程中遇到的一種「短時間內遇到大量操作請求」的情況，主要發生在web系統集中大量訪問或者socket埠集中性收到大量請求（例如：12306的搶票情況；天貓雙十一活動）。該情況的發生會導致系統在這段時間內執行大量操作，例如對資源的請求，資料庫的操作等。如果高並發處理不好，不僅僅降低了用戶的體驗度（請求響應時間過長），同時可能導致系統宕機，嚴重的甚至導致OOM異常，系統停止工作等。如果要想系統能夠適應高並發狀態，則需要從各個方面進行系統優化，包括，硬體、網路、系統架構、開發語言的選取、數據結構的運用、演算法優化、資料庫優化……。
而多線程只是在同/非同步角度上解決高並發問題的其中的一個方法手段，是在同一時刻利用計算機閑置資源的一種方式。
多線程在高並發問題中的作用就是充分利用計算機資源，使計算機的資源在每一時刻都能達到最大的利用率，不至於浪費計算機資源使其閑置。
3.線程的創建，停止，常用方法介紹。
1.線程的創建：
線程創建主要有2種方式，一種是繼承Thread類，重寫run方法即可；（Thread類實現了Runable介面）
另一種則是實現Runable介面，也需要重寫run方法。
線程的啟動，調用start（）方法即可。 我們也可以直接使用線程對象的run方法，不過直接使用，run方法就只是一個普通的方法了。

其他的還有： 通過匿名內部類的方法創建；實現Callable介面。。。。。

2.線程常用方法：
currentThread()方法：該方法返回當前線程的信息 .getName（）可以返回線程名稱。

isAlive()方法：該方法判斷當前線程是否處於活動狀態。
sleep()方法：該方法是讓「當前正在執行的線程「休眠指定的時間，正在執行的線程是指this.currentThread()返回的線程。
getId()方法：該方法是獲取線程的唯一標識。
3.線程的停止：
在java中，停止線程並不簡單，不想for。。break那樣說停就停，需要一定的技巧。

線程的停止有3種方法：
1.線程正常終止，即run()方法運行結束正常停止。
2.使用interrupt方法中斷線程。
3.使用stop方法暴力停止線程。
interrupt方法中斷線程介紹：
interrupt方法其實並不是直接中斷線程，只是給線程添加一個中斷標志。
判斷線程是否是停止狀態：
this.interrupted(); 判斷當前線程是否已經中斷。（判斷的是這個方法所在的代碼對應的線程，而不是調用對象對應的線程）

this.isInterrupted(); 判斷線程是否已經中斷。（誰調用，判斷誰）

註：.interrupted()與isInterrupted()的區別：
interrupted()方法判斷的是所在代碼對應的線程是否中斷，而後者判斷的是調用對象對應的線程是否停止
前者執行後有清除狀態的功能（如連續調用兩次時，第一次返回true，則第二次會返回false）
後者沒有清除狀態的功能（兩次返回都為true）
真正停止線程的方法：
異常法：
在run方法中 使用 this.interrupted();判斷線程終止狀態，如果為true則 throw new interruptedException()然後捕獲該異常即可停止線程。

return停止線程：
在run方法中 使用 this.interrupted();判斷線程終止狀態，如果為true則return停止線程。 （建議使用異常法停止線程，因為還可以在catch中使線程向上拋，讓線程停止的事件得以傳播）。

暴力法：
使用stop()方法強行停止線程（強烈不建議使用，會造成很多不可預估的後果，已經被標記為過時）
（使用stop方法會拋出 java.lang.ThreadDeath 異常，並且stop方法會釋放鎖，很容易造成數據不一致）
註：在休眠中停止線程：
在sleep狀態下停止線程 會報異常，並且會清除線程狀態值為false；
先停止後sleep，同樣會報異常 sleep interrupted；

4.守護線程。
希望對您有所幫助！~

㈧ java分布式伺服器之間怎麼調用

基本原理 要實現網路機器間的通訊，首先得來看看計算機系統網路通信的基本原理，在底層層面去看，網路通信需要做的就是將流從一台計算機傳輸到另外一台計算機，基於傳輸協議和網路 IO 來實現，其中傳輸協議比較出名的有 http、tcp、 udp 等等，http、tcp、udp 都是在基於Socket 概念上為某類應用場景而擴展出的傳輸協議，網路IO，主要有bio、nio、aio 三種方式，所有的分布式應用通訊都基於這個原理而實現，只是為了應用的易用，各種語言通常都會提供一些更為貼近應用易用的應用層協議。 應用級協議 遠程服務通訊，需要達到的目標是在一台計算機發起請求，另外一台機器在接收到請求後進行相應的處理並將結果返回給請求端，這其中又會有諸如 onewayrequest、同步請求、非同步請求等等請求方式，按照網路通信原理，需要實現這個需要做的就是將請求轉換成流，通過傳輸協議傳輸至遠端，遠端計算機在接收到請求的流後進行處理，處理完畢後將結果轉化為流，並通過傳輸協議返回給調用端。原理是這樣的，但為了應用的方便，業界推出了很多基於此原理之上的應用級的協議，使得大家可以不用去直接操作這么底層的東西，通常應用級的遠程通信協議會提供: 1.為了避免直接做流操作這么麻煩，提供一種更加易用或貼合語言的標准傳輸格式;2.網路通信機制的實現，就是替你完成了將傳輸格式轉化為流，通過某種傳輸協議傳輸至遠端計算機，遠端計算機在接收到流後轉化為傳輸格式，並進行存儲或以某種方式通知遠端計算機。 所以在學習應用級的遠程通信協議時，我們可以帶著這幾個問題進行學習: 1.傳輸的標准格式是什麼?2.怎麼樣將請求轉化為傳輸的流?3.怎麼接收和處理流?4.傳輸協議是? 不過應用級的遠程通信協議並不會在傳輸協議上做什麼多大的改進，主要是在流操作方面，讓應用層生成流和處理流的這個過程更加的貼合所使用的語言或標准，至於傳輸協議則通常都是可選的，在java 領域中知名的有:RMI、 XML-RPC、Binary-RPC、SOAP、CORBA、JMS，來具體的看看這些遠程通信的應用級協議: RMIRMI 是個典型的為java 定製的遠程通信協議，我們都知道，在 singlevm 中，我們可以通過直接調用javaobjectinstance 來實現通信，那麼在遠程通信時，如果也能按照這種方式當然是最好了，這種遠程通信的機製成為RPC(RemoteProcereCall)，RMI 正是朝著這個目標而誕生的。 來看下基於RMI 的一次完整的遠程通信過程的原理: 1.客戶端發起請求，請求轉交至RMI 客戶端的stub 類;2.stub 類將請求的介面、方法、參數等信息進行序列化;3.基於socket 將序列化後的流傳輸至伺服器端;4.伺服器端接收到流後轉發至相應的skelton 類;5.skelton 類將請求的信息反序列化後調用實際的處理類;6.處理類處理完畢後將結果返回給 skelton 類;7.Skelton 類將結果序列化，通過socket 將流傳送給客戶端的 stub;8.stub 在接收到流後反序列化，將反序列化後的JavaObject 返回給調用者。 根據原理來回答下之前學習應用級協議帶著的幾個問題: 1.傳輸的標准格式是什麼?是JavaObjectStream。2.怎麼樣將請求轉化為傳輸的流?基於Java 串列化機制將請求的javaobject 信息轉化為流。3.怎麼接收和處理流?根據採用的協議啟動相應的監聽埠，當有流進入後基於Java 串列化機制將流進行反序列化，並根據RMI 協議獲取到相應的處理對象信息，進行調用並處理，處理完畢後的結果同樣基於java 串列化機制進行返回。4.傳輸協議是?Socket。 XML-RPCXML-RPC 也是一種和RMI 類似的遠程調用的協議，它和RMI 的不同之處在於它以標準的 xml 格式來定義請求的信息(請求的對象、方法、參數等)，這樣的好處是什麼呢，就是在跨語言通訊的時候也可以使用。 來看下XML-RPC 協議的一次遠程通信過程: 1.客戶端發起請求，按照XML-RPC 協議將請求信息進行填充;2.填充完畢後將xml 轉化為流，通過傳輸協議進行傳輸;3.接收到在接收到流後轉換為xml，按照XML-RPC 協議獲取請求的信息並進行處理;4.處理完畢後將結果按照XML- RPC 協議寫入xml 中並返回。 同樣來回答問題: 1.傳輸的標准格式是?標准格式的XML。2.怎麼樣將請求轉化為傳輸的流? 將XML 轉化為流。3.怎麼接收和處理流?通過監聽的埠獲取到請求的流，轉化為XML，並根據協議獲取請求的信息，進行處理並將結果寫入XML 中返回。4. 傳輸協議是?Http。 Binary-RPCBinary-RPC 看名字就知道和XML-RPC 是差不多的了，不同之處僅在於傳輸的標准格式由XML 轉為了二進制的格式。 同樣來回答問題: 1.傳輸的標准格式是?標准格式的二進制文件。2.怎麼樣將請求轉化為傳輸的流?將二進制格式文件轉化為流。3.怎麼接收和處理流?通過監聽的埠獲取到請求的流，轉化為二進制文件，根據協議獲取請求的信息，進行處理並將結果寫入XML 中返回。4.傳輸協議是?Http。 SOAPSOAP 原意為SimpleObjectAccessProtocol，是一個用於分布式環境的、輕量級的、基於XML 進行信息交換的通信協議，可以認為SOAP 是XMLRPC 的高級版，兩者的原理完全相同，都是http+XML，不同的僅在於兩者定義的XML 規范不同，SOAP 也是Webservice 採用的服務調用協議標准，因此在此就不多加闡述了。 (公用對象請求代理[調度]程序體系結構)，是一組用來定義"分布式對象系統"的標准，由 OMG(ObjectMenagementGroup)作為發起和標准制定單位。CORBA 的目的是定義一套協議，符合這個協議的對象可以互相交互，不論它們是用什麼樣的語言寫的，不論它們運行於什麼樣的機器和操作系統。CORBA 在我看來是個類似於SOA 的體系架構，涵蓋可選的遠程通信協議，但其本身不能列入通信協議這里來講，而且CORBA 基本淘汰，再加上對CORBA 也不怎麼懂，在此就不進行闡述了。 JMSJMS 呢，是實現java 領域遠程通信的一種手段和方法，基於JMS 實現遠程通信時和RPC 是不同的，雖然可以做到RPC 的效果，但因為不是從協議級別定義的，因此我們不認為JMS 是個RPC 協議，但它確實是個遠程通信協議，在其他的語言體系中也存在著類似JMS 的東西，可以統一的將這類機制稱為消息機制，而消息機制呢，通常是高並發、分布式領域推薦的一種通信機制，這里的主要一個問題是容錯(詳細見ErLang 論文)。 來看JMS 中的一次遠程通信的過程: 1.客戶端將請求轉化為符合JMS 規定的Message;2.通過JMSAPI 將Message 放入JMSQueue 或Topic 中;3.如為JMSQueue，則發送中相應的目標Queue 中，如為Topic，則發送給訂閱了此Topic 的JMSQueue。4.處理端則通過輪訓 JMSQueue，來獲取消息，接收到消息後根據JMS 協議來解析Message 並處理。 回答問題: 1.傳輸的標准格式是?JMS 規定的Message。2.怎麼樣將請求轉化為傳輸的流?將參數信息放入Message 中即可。3.怎麼接收和處理流?輪訓JMSQueue 來接收Message，接收到後進行處理，處理完畢後仍然是以Message 的方式放入 Queue 中發送或Multicast。4.傳輸協議是?不限。 基於JMS 也是常用的實現遠程非同步調用的方法之一。

㈨ JAVA高並發問題,大數據，頻繁I/O操作。

建議採用緩存處理，按照你說的這種數據量，基於redis的緩存完全可以滿足，存取速度可以10W+的，另外，擬採用的hashMap 是ConcurrentHashMap還是其他，頁面展示是增量查詢還是直接所有的再查詢一次，socket數據接收你是用的netty還是mina，這都需要經過仔細的斟酌考慮設計的。有這么大的並發的需求，完全可以考慮做分布式集群的，估計這只是領導想要的目標吧

㈩ 多線程是什麼

多線程（multithreading），是指從軟體或者硬體上實現多個線程並發執行的技術。具有多線程能力的計算機因有硬體支持而能夠在同一時間執行多於一個線程，進而提升整體處理性能。具有這種能力的系統包括對稱多處理機、多核心處理器以及晶元級多處理或同時多線程處理器。在一個程序中，這些獨立運行的程序片段叫作「線程」（Thread），利用它編程的概念就叫作「多線程處理」。
在計算機編程中，一個基本的概念就是同時對多個任務加以控制。許多程序設計問題都要求程序能夠停下手頭的工作，改為處理其他一些問題，再返回主進程。可以通過多種途徑達到這個目的。最開始的時候，那些掌握機器低級語言的程序員編寫一些「中斷服務常式」，主進程的暫停是通過硬體級的中斷實現的。盡管這是一種有用的方法，但編出的程序很難移植，由此造成了另一類的代價高昂問題。中斷對那些實時性很強的任務來說是很有必要的。但對於其他許多問題，只要求將問題劃分進入獨立運行的程序片斷中，使整個程序能更迅速地響應用戶的請求 。
最開始，線程只是用於分配單個處理器的處理時間的一種工具。但假如操作系統本身支持多個處理器，那麼每個線程都可分配給一個不同的處理器，真正進入「並行運算」狀態。從程序設計語言的角度看，多線程操作最有價值的特性之一就是程序員不必關心到底使用了多少個處理器。程序在邏輯意義上被分割為數個線程；假如機器本身安裝了多個處理器，那麼程序會運行得更快，毋需作出任何特殊的調校。根據前面的論述，大家可能感覺線程處理非常簡單。但必須注意一個問題：共享資源！如果有多個線程同時運行，而且它們試圖訪問相同的資源，就會遇到一個問題。舉個例子來說，兩個線程不能將信息同時發送給一台列印機。為解決這個問題，對那些可共享的資源來說（比如列印機），它們在使用期間必須進入鎖定狀態。所以一個線程可將資源鎖定，在完成了它的任務後，再解開（釋放）這個鎖，使其他線程可以接著使用同樣的資源。