Java利用TCP實(shí)現(xiàn)服務(wù)端向客戶端消息群發(fā)的示例代碼
前言
項(xiàng)目需要和第三方廠商的服務(wù)需要用TCP協(xié)議通訊,考慮到彼此雙方可能都會(huì)有斷網(wǎng)重連、宕機(jī)重啟的情況,需要保證 發(fā)生上述情況后,服務(wù)之間能夠自動(dòng)實(shí)現(xiàn)重新通信。研究測試之后整理如下代碼實(shí)現(xiàn)。因?yàn)榘l(fā)現(xiàn)客戶端重啟后,對(duì)于服務(wù)端來說原來的客戶端和服務(wù)端進(jìn)程進(jìn)程已經(jīng)關(guān)閉,啟動(dòng)又和服務(wù)端新開了一個(gè)進(jìn)程。所以實(shí)現(xiàn)原理就可以通過服務(wù)端向客戶端群發(fā)實(shí)現(xiàn),斷開重新連接通訊。
代碼
tcp服務(wù)端代碼
import java.io.*; import java.net.ServerSocket; import java.net.Socket; public class HttpSocketServer { public static void main(String[] args) { try { ServerSocket server=new ServerSocket(9020); while (true){ Socket client=server.accept(); System.out.println("進(jìn)入了1個(gè)客戶機(jī)連接:"+client.getRemoteSocketAddress().toString()); ServerThread st = new ServerThread(client); st.start(); } } catch (IOException e) { e.printStackTrace(); } } }
ServerThread 線程類
import java.io.*; import java.net.Socket; /** * 客戶機(jī) 線程 ——自動(dòng)執(zhí)行run * @author Lenovo */ public class ServerThread extends Thread{ private Socket client; /** * 方法描述: 用有參構(gòu)造 接收主函數(shù)那邊傳來的 客戶機(jī) */ public ServerThread(Socket client) { this.client=client; } @Override public void run() { try { processSocket();//調(diào)用你想執(zhí)行的 使線程啟動(dòng)時(shí)在run方法開始執(zhí)行 } catch (IOException e) { e.printStackTrace(); } } /** * 調(diào)用以上方法 */ public void processSocket() throws IOException { //加入集合 便于服務(wù)器群發(fā) TcpTool.addSocket(client); }
TcpTool 消息群發(fā)工具類
import java.io.IOException; import java.io.OutputStream; import java.net.Socket; import java.util.ArrayList; import java.util.List; /** * 聊天工具類 * @author tarzan */ public class TcpTool { private static List<Socket> clientList=new ArrayList<Socket>(); /** * 便于 驗(yàn)證成功后 加入客戶機(jī) * @param socket */ public static void addSocket(Socket socket) { clientList.add(socket); } /** * 群發(fā)=遍歷list中的all元素, 對(duì)每個(gè)元素 寫出 * @param msg * @throws IOException */ public static void sendAll(String msg){ for (int i = 0; i <clientList.size(); i++) { Socket client = clientList.get(i); if(clientIsClose(client)){ delSocket(client); i--; continue; } try { OutputStream ops = client.getOutputStream(); ops.write((msg+"\r\n").getBytes()); ops.flush(); } catch (IOException e) { e.printStackTrace(); } } } /** * 判斷是否斷開連接,斷開返回true,沒有返回false * @param socket * @return */ public static Boolean clientIsClose(Socket socket){ try{ //發(fā)送1個(gè)字節(jié)的緊急數(shù)據(jù),默認(rèn)情況下,服務(wù)器端沒有開啟緊急數(shù)據(jù)處理,不影響正常通信 socket.sendUrgentData(0xFF); // 發(fā)送一個(gè)數(shù)據(jù)包, 如果通信正常就不會(huì)報(bào)錯(cuò). 沒有報(bào)錯(cuò)說明沒有關(guān)閉., 返回false return false; }catch(Exception se){ return true; } } /** * 下線時(shí)刪除 * @param socket */ public static void delSocket(Socket socket){ clientList.remove(socket); } }
Tcp客戶端代碼
import org.springblade.core.tool.utils.StringUtil; import java.io.*; import java.net.Socket; /** * @author tarzan */ public class HttpSocketClient { public static void main(String[] args) throws IOException { Socket client=new Socket("127.0.0.1",9020); while (true) { try { if (!clientIsClose(client)) { InputStream is=client.getInputStream(); BufferedReader reader=new BufferedReader(new InputStreamReader(is)); String text=reader.readLine(); if(StringUtil.isNotBlank(text)){ System.out.println("來自服務(wù)端的消息:"+text); } }else{ try { //斷開5秒后重新連接 Thread.sleep(5000); } catch (InterruptedException e) { e.printStackTrace(); } client=new Socket("127.0.0.1",9020); } } catch (IOException e) { e.printStackTrace(); } } } public static Boolean clientIsClose(Socket socket){ try{ //發(fā)送1個(gè)字節(jié)的緊急數(shù)據(jù),默認(rèn)情況下,服務(wù)器端沒有開啟緊急數(shù)據(jù)處理,不影響正常通信 socket.sendUrgentData(0xFF); // 發(fā)送一個(gè)數(shù)據(jù)包, 如果通信正常就不會(huì)報(bào)錯(cuò). 沒有報(bào)錯(cuò)說明沒有關(guān)閉., 返回false return false; }catch(Exception se){ return true; } }
運(yùn)行一個(gè)服務(wù)端,啟動(dòng)多個(gè)客戶端進(jìn)行測試。
控制臺(tái)輸出
以上只是實(shí)現(xiàn)的最簡單的demo,服務(wù)端,因?yàn)榉?wù)端和客戶端都需要不斷監(jiān)聽彼此通信,發(fā)送消息時(shí)候,需要另起一個(gè)線程,調(diào)用TcpTool工具類想客戶端群發(fā)消息。
到此這篇關(guān)于Java利用TCP實(shí)現(xiàn)服務(wù)端向客戶端消息群發(fā)的示例代碼的文章就介紹到這了,更多相關(guān)Java TCP消息群發(fā)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
如何在springboot中引入?yún)?shù)校驗(yàn)
一般我們判斷前端傳過來的參數(shù),需要對(duì)某些值進(jìn)行判斷,是否滿足條件,而springboot相關(guān)的參數(shù)校驗(yàn)注解,可以解決我們這個(gè)問題,本文給大家介紹如何在springboot中引入?yún)?shù)校驗(yàn),感興趣的朋友一起看看吧2023-12-12基于JavaMail的Java實(shí)現(xiàn)復(fù)雜郵件發(fā)送功能
這篇文章主要為大家詳細(xì)介紹了基于JavaMail的Java實(shí)現(xiàn)復(fù)雜郵件發(fā)送功能,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2017-09-09SpringBoot中ApplicationEvent和ApplicationListener用法小結(jié)
這篇文章介紹SpringBoot中ApplicationEvent用法,注意ApplicationEvent和MQ隊(duì)列雖然實(shí)現(xiàn)的功能相似,但是MQ還是有其不可替代性的,最本質(zhì)的區(qū)別就是MQ可以用于不同系統(tǒng)之間的消息發(fā)布,而SpringEvent這種模式只能在一個(gè)系統(tǒng)中,需要的朋友可以參考下2023-03-03Hibernate連接三種數(shù)據(jù)庫的配置文件
今天小編就為大家分享一篇關(guān)于Hibernate連接三種數(shù)據(jù)庫的配置文件,小編覺得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來看看吧2019-03-03tomcat啟動(dòng)完成執(zhí)行 某個(gè)方法 定時(shí)任務(wù)(Spring)操作
這篇文章主要介紹了tomcat啟動(dòng)完成執(zhí)行 某個(gè)方法 定時(shí)任務(wù)(Spring)操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2020-09-09java實(shí)現(xiàn)乘地鐵方案的最優(yōu)選擇(票價(jià),距離)
這篇文章主要介紹了java實(shí)現(xiàn)乘地鐵方案的最優(yōu)選擇(票價(jià),距離),文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-07-07