欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

Java利用TCP實(shí)現(xiàn)服務(wù)端向客戶端消息群發(fā)的示例代碼

 更新時(shí)間:2022年08月26日 09:21:00   作者:洛陽泰山  
這篇文章主要為大家詳細(xì)介紹了Java如何利用TCP協(xié)議實(shí)現(xiàn)服務(wù)端向客戶端消息群發(fā)功能,文中的示例代碼講解詳細(xì),需要的可以參考下,希望對(duì)你有所幫助

前言 

項(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)

    如何在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
  • Java zookeeper服務(wù)的使用詳解

    Java zookeeper服務(wù)的使用詳解

    ZooKeeper是一個(gè)分布式的,開放源碼的分布式應(yīng)用程序協(xié)調(diào)服務(wù),是Google的Chubby一個(gè)開源的實(shí)現(xiàn),是Hadoop和Hbase的重要組件。它是一個(gè)為分布式應(yīng)用提供一致性服務(wù)的軟件,提供的功能包括:配置維護(hù)、域名服務(wù)、分布式同步、組服務(wù)等
    2022-08-08
  • 將bean注入到Spring中的方式總結(jié)

    將bean注入到Spring中的方式總結(jié)

    在Java的Spring框架中,將bean注入到容器中是核心概念之一,這是實(shí)現(xiàn)依賴注入的基礎(chǔ),Spring提供了多種方式來將bean注入到容器中,本文給大家總結(jié)了將bean注入到Spring中的幾種方式,需要的朋友可以參考下
    2023-12-12
  • 深入理解JAVA核心:揭秘反射機(jī)制的奧秘

    深入理解JAVA核心:揭秘反射機(jī)制的奧秘

    歡迎來到JAVA反射機(jī)制指南!想要了解如何在JAVA中實(shí)現(xiàn)靈活的編程技巧嗎?本指南將帶你揭開JAVA反射機(jī)制的神秘面紗,讓你的編程世界更加精彩!趕緊跟我一起來探索吧!
    2024-02-02
  • 基于JavaMail的Java實(shí)現(xiàn)復(fù)雜郵件發(fā)送功能

    基于JavaMail的Java實(shí)現(xiàn)復(fù)雜郵件發(fā)送功能

    這篇文章主要為大家詳細(xì)介紹了基于JavaMail的Java實(shí)現(xiàn)復(fù)雜郵件發(fā)送功能,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2017-09-09
  • SpringBoot中ApplicationEvent和ApplicationListener用法小結(jié)

    SpringBoot中ApplicationEvent和ApplicationListener用法小結(jié)

    這篇文章介紹SpringBoot中ApplicationEvent用法,注意ApplicationEvent和MQ隊(duì)列雖然實(shí)現(xiàn)的功能相似,但是MQ還是有其不可替代性的,最本質(zhì)的區(qū)別就是MQ可以用于不同系統(tǒng)之間的消息發(fā)布,而SpringEvent這種模式只能在一個(gè)系統(tǒng)中,需要的朋友可以參考下
    2023-03-03
  • Hibernate連接三種數(shù)據(jù)庫的配置文件

    Hibernate連接三種數(shù)據(jù)庫的配置文件

    今天小編就為大家分享一篇關(guān)于Hibernate連接三種數(shù)據(jù)庫的配置文件,小編覺得內(nèi)容挺不錯(cuò)的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來看看吧
    2019-03-03
  • tomcat啟動(dòng)完成執(zhí)行 某個(gè)方法 定時(shí)任務(wù)(Spring)操作

    tomcat啟動(dòng)完成執(zhí)行 某個(gè)方法 定時(shí)任務(wù)(Spring)操作

    這篇文章主要介紹了tomcat啟動(dòng)完成執(zhí)行 某個(gè)方法 定時(shí)任務(wù)(Spring)操作,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧
    2020-09-09
  • JDK1.8安裝與配置超詳細(xì)教程

    JDK1.8安裝與配置超詳細(xì)教程

    JDK1.8即為JDK8,JDK8是目前是最成熟最穩(wěn)定的版本,本文將詳細(xì)介紹JDK1.8的安裝與配置,需要的朋友可以參考下
    2023-03-03
  • java實(shí)現(xiàn)乘地鐵方案的最優(yōu)選擇(票價(jià),距離)

    java實(shí)現(xiàn)乘地鐵方案的最優(yōu)選擇(票價(jià),距離)

    這篇文章主要介紹了java實(shí)現(xiàn)乘地鐵方案的最優(yōu)選擇(票價(jià),距離),文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2019-07-07

最新評(píng)論