java重試實現

Ⅰ 使用java 測試網路連通性的幾種方法

概述在網路編程中，有時我們需要判斷兩台機器之間的連通性，或者說是一台機器到另一台機器的網路可達性。在系統層面的測試中，我們常常用 Ping 命令來做驗證。盡管 Java 提供了比較豐富的網路編程類庫（包括在應用層的基於 URL 的網路資源讀取，基於 TCP/IP 層的 Socket 編程，以及一些輔助的類庫），但是沒有直接提供類似 Ping 命令來測試網路連通性的方法。本文將介紹如何通過 Java 已有的 API，編程實現各種場景下兩台機器之間的網路可達性判斷。在下面的章節中，我們會使用 Java 網路編程的一些類庫 java.net.InetAddress 和 java.net.Socket，通過例子解釋如何模擬 Ping 命令。回頁首簡單判斷兩台機器的可達性一般情況下，我們僅僅需要判斷從一台機器是否可以訪問（Ping）到另一台機器，此時，可以簡單的使用 Java 類庫中 java.net.InetAddress 類來實現，這個類提供了兩個方法探測遠程機器是否可達 �0�2boolean isReachable(int�0�2timeout) //�0�2測試地址是否可達�0�2boolean isReachable(NetworkInterface�0�2netif, int�0�2ttl, int�0�2timeout) //�0�2測試地址是否可達. 簡單說來，上述方法就是通過遠端機器的 IP 地址構造 InetAddress 對象，然後調用其 isReachable 方法，測試調用機器和遠端機器的網路可達性。注意到遠端機器可能有多個 IP 地址，因而可能要迭代的測試所有的情況。清單1：簡單判斷兩台機器的可達性 void isAddressAvailable(String ip){ try{ InetAddress address = InetAddress.getByName(ip);//ping this IP if(address instanceof java.net.Inet4Address){ System.out.println(ip + " is ipv4 address"); }else if(address instanceof java.net.Inet6Address){ System.out.println(ip + " is ipv6 address"); }else{ System.out.println(ip + " is unrecongized"); } if(address.isReachable(5000)){ System.out.println("SUCCESS - ping " + IP + " with no interface specified"); }else{ System.out.println("FAILURE - ping " + IP + " with no interface specified"); } System.out.println("
-------Trying different interfaces--------
"); Enumeration<NetworkInterface> netInterfaces = NetworkInterface.getNetworkInterfaces(); while(netInterfaces.hasMoreElements()) { NetworkInterface ni = netInterfaces.nextElement(); System.out.println( "Checking interface, DisplayName:" + ni.getDisplayName() + ", Name:" + ni.getName()); if(address.isReachable(ni, 0, 5000)){ System.out.println("SUCCESS - ping " + ip); }else{ System.out.println("FAILURE - ping " + ip); } Enumeration<InetAddress> ips = ni.getInetAddresses(); while(ips.hasMoreElements()) { System.out.println("IP: " + ips.nextElement().getHostAddress()); } System.out.println("-------------------------------------------"); } }catch(Exception e){ System.out.println("error occurs."); e.printStackTrace(); } } 程序輸出 --------------START-------------- 10.13.20.70 is ipv4 address SUCCESS - ping 10.13.20.70 with no interface specified -------Trying different interfaces-------- Checking interface, DisplayName:MS TCP Loopback interface, Name:lo FAILURE - ping 10.13.20.70 IP: 127.0.0.1 ------------------------------------------- Checking interface, DisplayName:Intel(R) Centrino(R) Advanced-N 6200 AGN - Teefer2 Miniport, Name:eth0 FAILURE - ping 10.13.20.70 IP: 9.123.231.40 ------------------------------------------- Checking interface, DisplayName:Intel(R) 82577LM Gigabit Network Connection - Teefer2 Miniport, Name:eth1 SUCCESS - ping 10.13.20.70 ------------------------------------------- Checking interface, DisplayName:WAN (PPP/SLIP) Interface, Name:ppp0 SUCCESS - ping 10.13.20.70 IP: 10.0.50.189 ------------------------------------------- --------------END-------------- 從上可以看出 isReachable 的用法，可以不指定任何介面來判斷遠端網路的可達性，但這不能區分出數據包是從那個網路介面發出去的 ( 如果本地有多個網路介面的話 )；而高級版本的 isReachable 則可以指定從本地的哪個網路介面測試，這樣可以准確的知道遠端網路可以連通本地的哪個網路介面。但是，Java 本身沒有提供任何方法來判斷本地的哪個 IP 地址可以連通遠端網路，Java 網路編程介面也沒有提供方法來訪問 ICMP 協議數據包，因而通過 ICMP 的網路不可達數據包實現這一點也是不可能的 ( 當然可以用 JNI 來實現，但就和系統平台相關了 ), 此時可以考慮本文下一節提出的方法。回頁首指定本地和遠程網路地址，判斷兩台機器之間的可達性在某些情況下，我們可能要確定本地的哪個網路地址可以連通遠程網路，以便遠程網路可以回連到本地使用某些服務或發出某些通知。一個典型的應用場景是，本地啟動了文件傳輸服務 ( 如 FTP)，需要將本地的某個 IP 地址發送到遠端機器，以便遠端機器可以通過該地址下載文件；或者遠端機器提供某些服務，在某些事件發生時通知注冊了獲取這些事件的機器 ( 常見於系統管理領域 )，因而在注冊時需要提供本地的某個可達 ( 從遠端 ) 地址。雖然我們可以用 InetAddress.isReachabl 方法判斷出本地的哪個網路介面可連通遠程玩過，但是由於單個網路介面是可以配置多個 IP 地址的，因而在此並不合適。我們可以使用 Socket 建立可能的 TCP 連接，進而判斷某個本地 IP 地址是否可達遠程網路。我們使用 java.net.Socket 類中的 connect 方法 void connect(SocketAddress�0�2endpoint, int�0�2timeout) �0�2//使用Socket連接伺服器，指定超時的時間 這種方法需要遠程的某個埠，該埠可以是任何基於 TCP 協議的開放服務的埠（如一般都會開放的 ECHO 服務埠 7, Linux 的 SSH 服務埠 22 等）。實際上，建立的 TCP 連接被協議棧放置在連接隊列，進而分發到真正處理數據的各個應用服務，由於 UDP 沒有連接的過程，因而基於 UDP 的服務（如 SNMP）無法在此方法中應用。具體過程是，枚舉本地的每個網路地址，建立本地 Socket，在某個埠上嘗試連接遠程地址，如果可以連接上，則說明該本地地址可達遠程網路。程序清單 2：指定本地地址和遠程地址，判斷兩台機器之間的可達性 void printReachableIP(InetAddress remoteAddr, int port){ String retIP = null; Enumeration<NetworkInterface> netInterfaces; try{ netInterfaces = NetworkInterface.getNetworkInterfaces(); while(netInterfaces.hasMoreElements()) { NetworkInterface ni = netInterfaces.nextElement(); Enumeration<InetAddress> localAddrs = ni.getInetAddresses(); while(localAddrs.hasMoreElements()){ InetAddress localAddr = localAddrs.nextElement(); if(isReachable(localAddr, remoteAddr, port, 5000)){ retIP = localAddr.getHostAddress(); break; } } } } catch(SocketException e) { System.out.println( "Error occurred while listing all the local network addresses."); } if(retIP == null){ System.out.println("NULL reachable local IP is found!"); }else{ System.out.println("Reachable local IP is found, it is " + retIP); } } boolean isReachable(InetAddress localInetAddr, InetAddress remoteInetAddr, int port, int timeout) { booleanisReachable = false; Socket socket = null; try{ socket = newSocket(); // 埠號設置為 0 表示在本地挑選一個可用埠進行連接 SocketAddress localSocketAddr = new InetSocketAddress(localInetAddr, 0); socket.bind(localSocketAddr); InetSocketAddress endpointSocketAddr = new InetSocketAddress(remoteInetAddr, port); socket.connect(endpointSocketAddr, timeout); System.out.println("SUCCESS - connection established! Local: " + localInetAddr.getHostAddress() + " remote: " + remoteInetAddr.getHostAddress() + " port" + port); isReachable = true; } catch(IOException e) { System.out.println("FAILRE - CAN not connect! Local: " + localInetAddr.getHostAddress() + " remote: " + remoteInetAddr.getHostAddress() + " port" + port); } finally{ if(socket != null) { try{ socket.close(); } catch(IOException e) { System.out.println("Error occurred while closing socket.."); } } } return isReachable; } 運行結果 --------------START-------------- FAILRE - CAN not connect! Local: 127.0.0.1 remote: 10.8.1.50 port22 FAILRE - CAN not connect! Local: 9.123.231.40 remote: 10.8.1.50 port22 SUCCESS - connection established! Local: 10.0.50.189 remote: 10.8.1.50 port22 Reachable local IP is found, it is 10.0.50.189 --------------END-------------- 回頁首IPv4 和 IPv6 混合網路下編程當網路環境中存在 IPv4 和 IPv6，即機器既有 IPv4 地址，又有 IPv6 地址的時候，我們可以對程序進行一些優化，比如 由於IPv4 和 IPv6 地址之間是無法互相訪問的，因此僅需要判斷 IPv4 地址之間和 IPv6 地址之間的可達性。 對於IPv4 的換回地址可以不做判斷，對於 IPv6 的 Linklocal 地址也可以跳過測試 根據實際的需要，我們可以優先考慮選擇使用 IPv4 或者 IPv6，提高判斷的效率程序清單 3: 判斷本地地址和遠程地址是否同為 IPv4 或者 IPv6 // 判斷是 IPv4 還是 IPv6 if(!((localInetAddr instanceofInet4Address) && (remoteInetAddr instanceofInet4Address) || (localInetAddr instanceofInet6Address) && (remoteInetAddr instanceofInet6Address))){ // 本地和遠程不是同時是 IPv4 或者 IPv6，跳過這種情況，不作檢測 break; } 程序清單 4：跳過本地地址和 LinkLocal 地址 if( localAddr.isLoopbackAddress() || localAddr.isAnyLocalAddress() || localAddr.isLinkLocalAddress() ){ // 地址為本地環回地址，跳過 break; } 回頁首總結和展望本文列舉集中典型的場景，介紹了通過 Java 網路編程介面判斷機器之間可達性的幾種方式。在實際應用中，可以根據不同的需要選擇相應的方法稍加修改即可。對於更加特殊的需求，還可以考慮通過 JNI 的方法直接調用系統 API 來實現，能提供更加強大和靈活的功能，這里就不再贅述了。參考資料 學習 參考developerWorks 的文章 Java 應用程序的網路運行環境編程，獲取更多網路編程相關的信息。
如果要通過 JNI 進行網路編程，可以參考 developerWorks 上的文章 用JNI 進行 Java 編程，了解更多 JNI 相關的信息和例子。
參考Javadoc 獲取更多關於 Java 網路編程的 API 的信息。
developerWorks Java 技術專區：這里有數百篇關於 Java 編程各個方面的文章。
討論加入developerWorks 中文社區。查看開發人員推動的博客、論壇、組和維基，並與其他 developerWorks 用戶交流。
作者簡介吳校軍，IBM CSTL 軟體工程師，長期從事 IBM 系統管理相關軟體的開發，目前負責 Director6.1 Update Manager 的開發。劉冠群現為 IBM 上海系統科技開發中心(CSTL)的軟體工程師，有多年的 Java 和 C++ 編程經驗，對於操作系統，網路和編程語言的內部實現有強烈興趣。關閉[x]關於報告濫用的幫助報告濫用謝謝! 此內容已經標識給管理員注意。關閉[x]關於報告濫用的幫助報告濫用報告濫用提交失敗。 請稍後重試。關閉[x]developerWorks：登錄IBM ID：需要一個 IBM ID？忘記IBM ID？密碼：忘記密碼？更改您的密碼 保持登錄。單擊提交則表示您同意developerWorks 的條款和條件。 使用條款 當您初次登錄到 developerWorks 時，將會為您創建一份概要信息。您在developerWorks 概要信息中選擇公開的信息將公開顯示給其他人，但您可以隨時修改這些信息的顯示狀態。您的姓名（除非選擇隱藏）和昵稱將和您在 developerWorks 發布的內容一同顯示。所有提交的信息確保安全。關閉[x]請選擇您的昵稱：當您初次登錄到 developerWorks 時，將會為您創建一份概要信息，您需要指定一個昵稱。您的昵稱將和您在 developerWorks 發布的內容顯示在一起。昵稱長度在 3 至 31 個字元之間。 您的昵稱在 developerWorks 社區中必須是唯一的，並且出於隱私保護的原因，不能是您的電子郵件地址。昵稱：（長度在 3 至 31 個字元之間）單擊提交則表示您同意developerWorks 的條款和條件。 使用條款. 所有提交的信息確保安全。

Ⅱ java如何實現使用HTTP POST 的方式調用webservice

packagecom.weixin.util;

importjava.io.BufferedReader;
importjava.io.IOException;
importjava.io.InputStream;
importjava.io.InputStreamReader;
importjava.io.StringWriter;
importjava.io.UnsupportedEncodingException;
importjava.util.ArrayList;
importjava.util.List;
importjava.util.Map;

importorg.apache.http.Header;
importorg.apache.http.HttpHost;
importorg.apache.http.HttpResponse;
importorg.apache.http.HttpStatus;
importorg.apache.http.HttpVersion;
importorg.apache.http.ParseException;
importorg.apache.http.client.ClientProtocolException;
importorg.apache.http.client.HttpClient;
importorg.apache.http.client.entity.UrlEncodedFormEntity;
importorg.apache.http.client.methods.HttpGet;
importorg.apache.http.client.methods.HttpPost;
importorg.apache.http.client.params.CookiePolicy;
importorg.apache.http.client.params.HttpClientParams;
importorg.apache.http.conn.params.ConnRoutePNames;
importorg.apache.http.impl.client.DefaultHttpClient;
importorg.apache.http.message.BasicNameValuePair;
importorg.apache.http.params.BasicHttpParams;
importorg.apache.http.params.HttpConnectionParams;
importorg.apache.http.params.HttpParams;
importorg.apache.http.params.HttpProtocolParams;
importorg.apache.http.protocol.HTTP;

//importbsh.ParseException;
importcom.google.gson.Gson;

/**
*TODO
*@Version1.0
*/
publicclassHttpClients{
	/**UTF-8*/
	privatestaticfinalStringUTF_8="UTF-8";
	/**日誌記錄tag*/
	privatestaticfinalStringTAG="HttpClients";

	/**用戶host*/
	privatestaticStringproxyHost="";
	/**用戶埠*/
	privatestaticintproxyPort=80;
	/**是否使用用戶埠*/
	privatestaticbooleanuseProxy=false;

	/**連接超時*/
	privatestaticfinalintTIMEOUT_CONNECTION=60000;
	/**讀取超時*/
	privatestaticfinalintTIMEOUT_SOCKET=60000;
	/**重試3次*/
	privatestaticfinalintRETRY_TIME=3;

	/**
	*@paramurl
	*@paramrequestData
	*@return
	*/
	publicStringdoHtmlPost(HttpClienthttpClient,HttpPosthttpPost)
	{
		StringresponseBody=null;

		intstatusCode=-1;

		try{
			
			HttpResponsehttpResponse=httpClient.execute(httpPost);
			HeaderlastHeader=httpResponse.getLastHeader("Set-Cookie");
			if(null!=lastHeader)
			{
				httpPost.setHeader("cookie",lastHeader.getValue());
			}
			statusCode=httpResponse.getStatusLine().getStatusCode();
			if(statusCode!=HttpStatus.SC_OK){
				System.out.println("HTTP"+""+"HttpMethodfailed:"+httpResponse.getStatusLine());
			}
			InputStreamis=httpResponse.getEntity().getContent();
			responseBody=getStreamAsString(is,HTTP.UTF_8);

		}catch(Exceptione){
			//發生網路異常
			e.printStackTrace();
		}finally{
//			httpClient.getConnectionManager().shutdown();
//			httpClient=null;
		}

		returnresponseBody;
	}
	
	
	/**
	*
	*發起網路請求
	*
	*@paramurl
	*URL
	*@paramrequestData
	*requestData
	*@returnINPUTSTREAM
	*@throwsAppException
	*/
	publicstaticStringdoPost(Stringurl,StringrequestData)throwsException{
		StringresponseBody=null;
		HttpPosthttpPost=null;
		HttpClienthttpClient=null;
		intstatusCode=-1;
		inttime=0;
		do{
			try{
				httpPost=newHttpPost(url);
				httpClient=getHttpClient();
				//設置HTTPPOST請求參數必須用NameValuePair對象
				List<BasicNameValuePair>params=newArrayList<BasicNameValuePair>();
				params.add(newBasicNameValuePair("param",requestData));
				UrlEncodedFormEntityentity=newUrlEncodedFormEntity(params,HTTP.UTF_8);
				//設置HTTPPOST請求參數
				httpPost.setEntity(entity);
				HttpResponsehttpResponse=httpClient.execute(httpPost);
				statusCode=httpResponse.getStatusLine().getStatusCode();
				if(statusCode!=HttpStatus.SC_OK){
					System.out.println("HTTP"+""+"HttpMethodfailed:"+httpResponse.getStatusLine());
				}
				InputStreamis=httpResponse.getEntity().getContent();
				responseBody=getStreamAsString(is,HTTP.UTF_8);
				break;
			}catch(UnsupportedEncodingExceptione){
				time++;
				if(time<RETRY_TIME){
					try{
						Thread.sleep(1000);
					}catch(InterruptedExceptione1){
					}
					continue;
				}
				//發生致命的異常，可能是協議不對或者返回的內容有問題
				e.printStackTrace();

			}catch(ClientProtocolExceptione){
				time++;
				if(time<RETRY_TIME){
					try{
						Thread.sleep(1000);
					}catch(InterruptedExceptione1){
					}
					continue;
				}
				//發生致命的異常，可能是協議不對或者返回的內容有問題
				e.printStackTrace();
			}catch(IOExceptione){
				time++;
				if(time<RETRY_TIME){
					try{
						Thread.sleep(1000);
					}catch(InterruptedExceptione1){
					}
					continue;
				}
				//發生網路異常
				e.printStackTrace();
			}catch(Exceptione){
				time++;
				if(time<RETRY_TIME){
					try{
						Thread.sleep(1000);
					}catch(InterruptedExceptione1){
					}
					continue;
				}
				//發生網路異常
				e.printStackTrace();
			}finally{
				httpClient.getConnectionManager().shutdown();
				httpClient=null;
			}
		}while(time<RETRY_TIME);
		returnresponseBody;
	}

	/**
	*
	*將InputStream轉化為String
	*
	*@paramstream
	*inputstream
	*@paramcharset
	*字元集
	*@return
	*@throwsIOException
	*/
	(InputStreamstream,Stringcharset)throwsIOException{
		try{
			BufferedReaderreader=newBufferedReader(newInputStreamReader(stream,charset),8192);
			StringWriterwriter=newStringWriter();

			char[]chars=newchar[8192];
			intcount=0;
			while((count=reader.read(chars))>0){
				writer.write(chars,0,count);
			}

			returnwriter.toString();
		}finally{
			if(stream!=null){
				stream.close();
			}
		}
	}
	
	/**
	*得到httpClient
	*
	*@return
	*/
	(){
		finalHttpParamshttpParams=newBasicHttpParams();

		if(useProxy){
			HttpHostproxy=newHttpHost(proxyHost,proxyPort,"http");
			httpParams.setParameter(ConnRoutePNames.DEFAULT_PROXY,proxy);
		}

		HttpConnectionParams.setConnectionTimeout(httpParams,TIMEOUT_CONNECTION);
		HttpConnectionParams.setSoTimeout(httpParams,TIMEOUT_SOCKET);
		HttpClientParams.setRedirecting(httpParams,true);
		finalStringuserAgent="Mozilla/5.0(Windows;U;WindowsNT6.1;zh-CN;rv:1.9.2.14)Gecko/20110218Firefox/3.6.14";

		HttpProtocolParams.setUserAgent(httpParams,userAgent);
		HttpProtocolParams.setVersion(httpParams,HttpVersion.HTTP_1_1);
		HttpClientParams.setCookiePolicy(httpParams,CookiePolicy.RFC_2109);
		
		HttpProtocolParams.setUseExpectContinue(httpParams,false);
		HttpClientclient=newDefaultHttpClient(httpParams);

		returnclient;
	}

	/**
	*
	*得到httpClient
	*
	*@return
	*/
	(){
		finalHttpParamshttpParams=newBasicHttpParams();

		if(useProxy){
			HttpHostproxy=newHttpHost(proxyHost,proxyPort,"http");
			httpParams.setParameter(ConnRoutePNames.DEFAULT_PROXY,proxy);
		}

		HttpConnectionParams.setConnectionTimeout(httpParams,TIMEOUT_CONNECTION);
		HttpConnectionParams.setSoTimeout(httpParams,TIMEOUT_SOCKET);
		HttpClientParams.setRedirecting(httpParams,true);
		finalStringuserAgent="Mozilla/5.0(Windows;U;WindowsNT6.1;zh-CN;rv:1.9.2.14)Gecko/20110218Firefox/3.6.14";

		HttpProtocolParams.setUserAgent(httpParams,userAgent);
		HttpProtocolParams.setVersion(httpParams,HttpVersion.HTTP_1_1);
		HttpClientParams.setCookiePolicy(httpParams,CookiePolicy.BROWSER_COMPATIBILITY);
		HttpProtocolParams.setUseExpectContinue(httpParams,false);
		HttpClientclient=newDefaultHttpClient(httpParams);

		returnclient;
	}

	/**
	*列印返回內容
	*@paramresponse
	*@throwsParseException
	*@throwsIOException
	*/
	publicstaticvoidshowResponse(Stringstr)throwsException{
		Gsongson=newGson();		
		Map<String,Object>map=(Map<String,Object>)gson.fromJson(str,Object.class);
		Stringvalue=(String)map.get("data");		
		//StringdecodeValue=Des3Request.decode(value);
		//System.out.println(decodeValue);
		//logger.debug(decodeValue);
	}
	
	/**
	*
	*發起網路請求
	*
	*@paramurl
	*URL
	*@paramrequestData
	*requestData
	*@returnINPUTSTREAM
	*@throwsAppException
	*/
	publicstaticStringdoGet(Stringurl)throwsException{
		StringresponseBody=null;
		HttpGethttpGet=null;
		HttpClienthttpClient=null;
		intstatusCode=-1;
		inttime=0;
		do{
			try{
				httpGet=newHttpGet(url);
				httpClient=getHttpClient();
				HttpResponsehttpResponse=httpClient.execute(httpGet);
				statusCode=httpResponse.getStatusLine().getStatusCode();
				if(statusCode!=HttpStatus.SC_OK){
					System.out.println("HTTP"+""+"HttpMethodfailed:"+httpResponse.getStatusLine());
				}
				InputStreamis=httpResponse.getEntity().getContent();
				responseBody=getStreamAsString(is,HTTP.UTF_8);
				break;
			}catch(UnsupportedEncodingExceptione){
				time++;
				if(time<RETRY_TIME){
					try{
						Thread.sleep(1000);
					}catch(InterruptedExceptione1){
					}
					continue;
				}
				//發生致命的異常，可能是協議不對或者返回的內容有問題
				e.printStackTrace();

			}catch(ClientProtocolExceptione){
				time++;
				if(time<RETRY_TIME){
					try{
						Thread.sleep(1000);
					}catch(InterruptedExceptione1){
					}
					continue;
				}
				//發生致命的異常，可能是協議不對或者返回的內容有問題
				e.printStackTrace();
			}catch(IOExceptione){
				time++;
				if(time<RETRY_TIME){
					try{
						Thread.sleep(1000);
					}catch(InterruptedExceptione1){
					}
					continue;
				}
				//發生網路異常
				e.printStackTrace();
			}catch(Exceptione){
				time++;
				if(time<RETRY_TIME){
					try{
						Thread.sleep(1000);
					}catch(InterruptedExceptione1){
					}
					continue;
				}
				//發生網路異常
				e.printStackTrace();
			}finally{
				httpClient.getConnectionManager().shutdown();
				httpClient=null;
			}
		}while(time<RETRY_TIME);
		returnresponseBody;
	}
}

Ⅲ java中try到某個異常catch中如何重新運行異常的該行代碼

把trycatch 放在循環裡面，在catch部分重新運行就好了。

Ⅳ java問題，項目運行時，for循環會有3中狀態1.成功 2.失敗 3.可重試

你好 首先這段代碼運行的結果是1 2 4 3 2 4 3 2 8。從運行結果可以看出這段程序執行for循環執行了兩次（因為輸出兩次4）。
要理解for循環的本質：首先執行test（『1』）方法輸出1，
再判斷test('2')&&(x<=2)為真所以輸出2,4，這時第一次進入循環。注意這時x的值是2.結束第一次循環後，執行test（『3』），所以輸出3。
這時又要判斷test('2')&&(x<=2)是否為真，因為為真所以執行循環，所以輸出：2,4，這時又要去執行test（『3』），所以輸出3。執行之後再判斷test('2')&&(x<=2)是否為真，因為此時x的值為3，不滿足判斷條件（但是test（『2』）執行了）所以輸出2，退出循環輸出count的值為8（因為之前調用test（char num）方法8次），所以輸出8。因此最終結果為1 2 4 3 2 4 3 2 8。其實這個for循環語句和for（int i=0；i<2;i++）本質一樣，好好想想這個for循環的執行過程就明白了。
希望我的回答對你有幫助，謝謝~

Ⅳ java如何實現發送簡訊驗證碼功能

1、創建一個Http的模擬請求工具類，然後寫一個POST方法或者GET方法

/** * 文件說明 * @Description:擴展說明 * @Copyright: XXXX dreamtech.com.cn Inc. All right reserved * @Version: V6.0 */package com.demo.util; import java.io.IOException;import java.util.Map; import org.apache.commons.httpclient.HttpClient;import org.apache.commons.httpclient.HttpException;import org.apache.commons.httpclient.SimpleHttpConnectionManager;import org.apache.commons.httpclient.methods.GetMethod;import org.apache.commons.httpclient.methods.PostMethod; /** * @Author: feizi * @Date: XXXX年XX月XX日 XX:XX:XX * @ModifyUser: feizi * @ModifyDate: XXXX年XX月XX日 XX:XX:XX * @Version:V6.0 */public class HttpRequestUtil { /** * HttpClient 模擬POST請求 * 方法說明 * @Discription:擴展說明 * @param url * @param params * @return String * @Author: feizi * @Date: XXXX年XX月XX日 XX:XX:XX * @ModifyUser：feizi * @ModifyDate: XXXX年XX月XX日 XX:XX:XX */ public static String postRequest(String url, Map<String, String> params) { //構造HttpClient的實例 HttpClient httpClient = new HttpClient(); //創建POST方法的實例 PostMethod postMethod = new PostMethod(url); //設置請求頭信息 postMethod.setRequestHeader("Connection", "close"); //添加參數 for (Map.Entry<String, String> entry : params.entrySet()) { postMethod.addParameter(entry.getKey(), entry.getValue()); } //使用系統提供的默認的恢復策略,設置請求重試處理，用的是默認的重試處理：請求三次 httpClient.getParams().setBooleanParameter("http.protocol.expect-continue", false); //接收處理結果 String result = null; try { //執行Http Post請求 httpClient.executeMethod(postMethod); //返回處理結果 result = postMethod.getResponseBodyAsString(); } catch (HttpException e) { // 發生致命的異常，可能是協議不對或者返回的內容有問題 System.out.println("請檢查輸入的URL!"); e.printStackTrace(); } catch (IOException e) { // 發生網路異常 System.out.println("發生網路異常!"); e.printStackTrace(); } finally { //釋放鏈接 postMethod.releaseConnection(); //關閉HttpClient實例 if (httpClient != null) { ((SimpleHttpConnectionManager) httpClient.getHttpConnectionManager()).shutdown(); httpClient = null; } } return result; } /** * HttpClient 模擬GET請求 * 方法說明 * @Discription:擴展說明 * @param url * @param params * @return String * @Author: feizi * @Date: XXXX年XX月XX日 XX:XX:XX * @ModifyUser：feizi * @ModifyDate: XXXX年XX月XX日 XX:XX:XX */ public static String getRequest(String url, Map<String, String> params) { //構造HttpClient實例 HttpClient client = new HttpClient(); //拼接參數 String paramStr = ""; for (String key : params.keySet()) { paramStr = paramStr + "&" + key + "=" + params.get(key); } paramStr = paramStr.substring(1); //創建GET方法的實例 GetMethod method = new GetMethod(url + "?" + paramStr); //接收返回結果 String result = null; try { //執行HTTP GET方法請求 client.executeMethod(method); //返回處理結果 result = method.getResponseBodyAsString(); } catch (HttpException e) { // 發生致命的異常，可能是協議不對或者返回的內容有問題 System.out.println("請檢查輸入的URL!"); e.printStackTrace(); } catch (IOException e) { // 發生網路異常 System.out.println("發生網路異常!"); e.printStackTrace(); } finally { //釋放鏈接 method.releaseConnection(); //關閉HttpClient實例 if (client != null) { ((SimpleHttpConnectionManager) client.getHttpConnectionManager()).shutdown(); client = null; } } return result; }}

2、在創建一個類，生成驗證碼，然後傳遞相應的參數（不同的簡訊平台介面會有不同的參數要求，這個一般簡訊平台提供的介面文檔中都會有的，直接看文檔然後按要求來即可）

/** * 文件說明 * @Description:擴展說明 * @Copyright: XXXX dreamtech.com.cn Inc. All right reserved * @Version: V6.0 */package com.demo.util; import java.net.URLEncoder;import java.util.HashMap;import java.util.Map; /** * @Author: feizi * @Date: XXXX年XX月XX日 XX:XX:XX * @ModifyUser: feizi * @ModifyDate: XXXX年XX月XX日 XX:XX:XX * @Version:V6.0 */public class SendMsgUtil { /** * 發送簡訊消息 * 方法說明 * @Discription:擴展說明 * @param phones * @param content * @return * @return String * @Author: feizi * @Date: 2015年4月17日 下午7:18:08 * @ModifyUser：feizi * @ModifyDate: 2015年4月17日 下午7:18:08 */ @SuppressWarnings("deprecation") public static String sendMsg(String phones,String content){ //簡訊介面URL提交地址 String url = "簡訊介面URL提交地址"; Map<String, String> params = new HashMap<String, String>(); params.put("zh", "用戶賬號"); params.put("mm", "用戶密碼"); params.put("dxlbid", "簡訊類別編號"); params.put("extno", "擴展編號"); //手機號碼，多個號碼使用英文逗號進行分割 params.put("hm", phones); //將簡訊內容進行URLEncoder編碼 params.put("nr", URLEncoder.encode(content)); return HttpRequestUtil.getRequest(url, params); } /** * 隨機生成6位隨機驗證碼 * 方法說明 * @Discription:擴展說明 * @return * @return String * @Author: feizi * @Date: 2015年4月17日 下午7:19:02 * @ModifyUser：feizi * @ModifyDate: 2015年4月17日 下午7:19:02 */ public static String createRandomVcode(){ //驗證碼 String vcode = ""; for (int i = 0; i < 6; i++) { vcode = vcode + (int)(Math.random() * 9); } return vcode; } /** * 測試 * 方法說明 * @Discription:擴展說明 * @param args * @return void * @Author: feizi * @Date: XXXX年XX月XX日 XX:XX:XX * @ModifyUser：feizi * @ModifyDate: XXXX年XX月XX日 XX:XX:XX */ public static void main(String[] args) {// System.out.println(SendMsgUtil.createRandomVcode());// System.out.println("&ecb=12".substring(1)); System.out.println(sendMsg("18123456789,15123456789", "尊敬的用戶，您的驗證碼為" + SendMsgUtil.createRandomVcode() + "，有效期為60秒，如有疑慮請詳詢XXX-XXX-XXXX【XXX中心】")); }

然後執行一下，一般的情況下參數傳遞正確，按照介面文檔的規范來操作的話，都會發送成功的，手機都能收到驗證碼的，然後可能會出現的問題就是：發送的簡訊內容有可能會出現中文亂碼，然後就會發送不成功，按照簡訊平台的要求進行相應的編碼即可。一般都會是UTF-8編碼。

Ⅵ java客戶端調用webservice時 連接超時知道是網路原因 ，如何重試如果不重試程序就死瑣了，

先把連接超時的時間設置長一點！
拋異常處理時，空處理異常，繼續調用連接方法，不過，伺服器一般都有連接超時的時間的，超過時間連接不上，就會自動中斷客戶端的請求。釋放資源！

Ⅶ 手機解鎖手勢和密碼怎麼用java實現的

"若手機屏幕鎖屏密碼忘記，建議您參考以下內容：
1.若設置的是圖案/簽名解鎖方式，可使用繪制解鎖圖案/簽名時設置的PIN碼進行解鎖。操作：
1).輸入五次不正確的解鎖圖案，屏幕上會顯示「請在30秒後重試「的提示信息，點擊「確定「。點擊屏幕右下角的「備份PIN「（忘記密碼），輸入之前設置好的PIN密碼，點擊確定即可。
2).如果是簽名解鎖方式，輸入五次不正確的簽名後，屏幕會出現輸入PIN碼的提示，輸入之前設置好的PIN密碼，點擊確定即可。
提示：解鎖時提示的PIN碼，是您在設置圖案鎖定等時設置的備份密碼。
若無效、備份PIN密碼忘記或不符合上述要求，請您將機器送到就近的服務中心，由售後工程師幫助您進行安全解鎖。 "

Ⅷ elasticsearch中,如何與java中TransportClient在斷開後自動重連

不建議使用TransportClient，因為es官方自己都放棄了。建議使用java自身的http客戶端，使用rest api進行操作即可。不存在斷開重連，只存在api失敗重試。

Ⅸ java怎麼實現redis分布式鎖

Redis有一系列的命令，特點是以NX結尾，NX是Not eXists的縮寫，如SETNX命令就應該理解為：SET if Not eXists。這系列的命令非常有用，這里講使用SETNX來實現分布式鎖。

用SETNX實現分布式鎖

利用SETNX非常簡單地實現分布式鎖。例如：某客戶端要獲得一個名字foo的鎖，客戶端使用下面的命令進行獲取：

SETNX lock.foo <current Unix time + lock timeout + 1>

如返回1，則該客戶端獲得鎖，把lock.foo的鍵值設置為時間值表示該鍵已被鎖定，該客戶端最後可以通過DEL lock.foo來釋放該鎖。
如返回0，表明該鎖已被其他客戶端取得，這時我們可以先返回或進行重試等對方完成或等待鎖超時。
解決死鎖

上面的鎖定邏輯有一個問題：如果一個持有鎖的客戶端失敗或崩潰了不能釋放鎖，該怎麼解決？我們可以通過鎖的鍵對應的時間戳來判斷這種情況是否發生了，如果當前的時間已經大於lock.foo的值，說明該鎖已失效，可以被重新使用。

發生這種情況時，可不能簡單的通過DEL來刪除鎖，然後再SETNX一次，當多個客戶端檢測到鎖超時後都會嘗試去釋放它，這里就可能出現一個競態條件,讓我們模擬一下這個場景：

C0操作超時了，但它還持有著鎖，C1和C2讀取lock.foo檢查時間戳，先後發現超時了。
C1 發送DEL lock.foo
C1 發送SETNX lock.foo 並且成功了。
C2 發送DEL lock.foo
C2 發送SETNX lock.foo 並且成功了。
這樣一來，C1，C2都拿到了鎖！問題大了！

幸好這種問題是可以避免D，讓我們來看看C3這個客戶端是怎樣做的：

C3發送SETNX lock.foo 想要獲得鎖，由於C0還持有鎖，所以Redis返回給C3一個0
C3發送GET lock.foo 以檢查鎖是否超時了，如果沒超時，則等待或重試。
反之，如果已超時，C3通過下面的操作來嘗試獲得鎖：
GETSET lock.foo <current Unix time + lock timeout + 1>
通過GETSET，C3拿到的時間戳如果仍然是超時的，那就說明，C3如願以償拿到鎖了。
如果在C3之前，有個叫C4的客戶端比C3快一步執行了上面的操作，那麼C3拿到的時間戳是個未超時的值，這時，C3沒有如期獲得鎖，需要再次等待或重試。留意一下，盡管C3沒拿到鎖，但它改寫了C4設置的鎖的超時值，不過這一點非常微小的誤差帶來的影響可以忽略不計。
注意：為了讓分布式鎖的演算法更穩鍵些，持有鎖的客戶端在解鎖之前應該再檢查一次自己的鎖是否已經超時，再去做DEL操作，因為可能客戶端因為某個耗時的操作而掛起，操作完的時候鎖因為超時已經被別人獲得，這時就不必解鎖了。

示例偽代碼

根據上面的代碼，我寫了一小段Fake代碼來描述使用分布式鎖的全過程：

# get lock
lock = 0
while lock != 1:
timestamp = current Unix time + lock timeout + 1
lock = SETNX lock.foo timestamp
if lock == 1 or (now() > (GET lock.foo) and now() > (GETSET lock.foo timestamp)):
break;
else:
sleep(10ms)

# do your job
do_job()

# release
if now() < GET lock.foo:
DEL lock.foo
是的，要想這段邏輯可以重用，使用python的你馬上就想到了Decorator，而用Java的你是不是也想到了那誰？AOP + annotation？行，怎樣舒服怎樣用吧，別重復代碼就行。

Ⅹ java怎麼實現同步非阻塞

1.非阻塞演算法

非阻塞演算法屬於並發演算法，它們可以安全地派生它們的線程，不通過鎖定派生，而是通過低級的原子性的硬體原生形式 —— 例如比較和交換。非阻塞演算法的設計與實現極為困難，但是它們能夠提供更好的吞吐率，對生存問題（例如死鎖和優先順序反轉）也能提供更好的防禦。使用底層的原子化機器指令取代鎖,比如比較並交換(CAS,compare-and-swap).
2.悲觀技術
獨占鎖是一種悲觀的技術.它假設最壞的情況發生(如果不加鎖,其它線程會破壞對象狀態),即使沒有發生最壞的情況,仍然用鎖保護對象狀態.
3.樂觀技術
依賴沖突監測.先更新,如果監測發生沖突發生,則放棄更新後重試,否則更新成功.現在處理器都有原子化的讀-改-寫指令,比如比較並交換(CAS,compare-and-swap).
4.CAS操作
CAS有3個操作數，內存值V，舊的預期值A，要修改的新值B。當且僅當預期值A和內存值V相同時，將內存值V修改為B，否則什麼都不做。CAS典型使用模式是：首先從V中讀取A，並根據A計算新值B，然後再通過CAS以原子方式將V中的值由A變成B（只要在這期間沒有任何線程將V的值修改為其他值）。
清單 3. 說明比較並交換的行為（而不是性能）的代碼
public class SimulatedCAS {
private int value;

public synchronized int getValue() { return value; }

public synchronized int compareAndSwap(int expectedValue, int newValue) {
int oldValue = value;
if (value == expectedValue)
value = newValue;
return oldValue;
}
}

清單 4. 使用比較並交換實現計數器

public class CasCounter {
private SimulatedCAS value;
public int getValue() {
return value.getValue();
}
public int increment() {
int oldValue = value.getValue();
while (value.compareAndSwap(oldValue, oldValue + 1) != oldValue)
oldValue = value.getValue();
return oldValue + 1;
}
}

5.原子變數
原子變數支持不用鎖保護就能原子性更新操作，其底層用CAS實現。共有12個原子變數，可分為4組：標量類、更新器類、數組類以及復合變數類。最常用的原子變數就是標量類：AtomicInteger、AtomicLong、AtomicBoolean以及AtomicReference。所有類型都支持CAS。
6.性能比較：鎖與原子變數
在中低程度的競爭下，原子變數能提供很高的可伸縮性，原子變數性能超過鎖；而在高強度的競爭下，鎖能夠更有效地避免競爭，鎖的性能將超過原子變數的性能。但在更真實的實際情況中，原子變數的性能將超過鎖的性能。