最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

java Socket實(shí)現(xiàn)網(wǎng)頁(yè)版在線聊天

 更新時(shí)間:2021年07月04日 11:45:57   投稿:lijiao  
這篇文章主要為大家詳細(xì)介紹了java Socket實(shí)現(xiàn)網(wǎng)頁(yè)版在線聊天具體代碼,文中示例代碼介紹的非常詳細(xì),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下

本文為大家分享了一個(gè)滿(mǎn)足在線網(wǎng)頁(yè)交流需求的實(shí)例,由于java Socket實(shí)現(xiàn)的網(wǎng)頁(yè)版在線聊天功能,供大家參考,具體內(nèi)容如下

實(shí)現(xiàn)步驟:

1、使用awt組件和socket實(shí)現(xiàn)簡(jiǎn)單的單客戶(hù)端向服務(wù)端持續(xù)發(fā)送消息;
2、結(jié)合線程,實(shí)現(xiàn)多客戶(hù)端連接服務(wù)端發(fā)送消息;
3、實(shí)現(xiàn)服務(wù)端轉(zhuǎn)發(fā)客戶(hù)端消息至所有客戶(hù)端,同時(shí)在客戶(hù)端顯示;
4、把a(bǔ)wt組件生成的窗口界面改成前端jsp或者h(yuǎn)tml展示的界面,java socket實(shí)現(xiàn)的客戶(hù)端改為前端技術(shù)實(shí)現(xiàn)。

這里首先實(shí)現(xiàn)第一步的簡(jiǎn)單功能,難點(diǎn)在于:
1、沒(méi)有用過(guò)awt組件,沒(méi)有用過(guò)java相關(guān)的監(jiān)聽(tīng)事件;
2、長(zhǎng)時(shí)間沒(méi)有使用socket進(jìn)行客戶(hù)端和服務(wù)端的交互,并且沒(méi)有真正進(jìn)行過(guò)cs結(jié)構(gòu)的開(kāi)發(fā)。

實(shí)現(xiàn)功能的代碼

在線聊天客戶(hù)端:

1、生成圖形窗口界面輪廓
2、為輪廓添加關(guān)閉事件
3、在輪廓中加入輸入?yún)^(qū)域和內(nèi)容展示區(qū)域
4、為輸入?yún)^(qū)域添加回車(chē)事件
5、建立服務(wù)端連接并發(fā)送數(shù)據(jù)

package chat.chat; 
 
import java.awt.BorderLayout; 
import java.awt.Frame; 
import java.awt.TextArea; 
import java.awt.TextField; 
import java.awt.event.ActionEvent; 
import java.awt.event.ActionListener; 
import java.awt.event.WindowAdapter; 
import java.awt.event.WindowEvent; 
import java.io.DataOutputStream; 
import java.io.IOException; 
import java.net.Socket; 
import java.net.UnknownHostException; 
 
/** 
 * 在線聊天客戶(hù)端 1、生成圖形窗口界面輪廓 2、為輪廓添加關(guān)閉事件 3、在輪廓中加入輸入?yún)^(qū)域和內(nèi)容展示區(qū)域 4、為輸入?yún)^(qū)域添加回車(chē)事件 
 * 5、建立服務(wù)端連接并發(fā)送數(shù)據(jù) 
 * 
 * @author tuzongxun123 
 * 
 */ 
public class ChatClient extends Frame { 
  // 用戶(hù)輸入?yún)^(qū)域 
  private TextField tfTxt = new TextField(); 
  // 內(nèi)容展示區(qū)域 
  private TextArea tarea = new TextArea(); 
  private Socket socket = null; 
  // 數(shù)據(jù)輸出流 
  private DataOutputStream dataOutputStream = null; 
 
  public static void main(String[] args) { 
    new ChatClient().launcFrame(); 
  } 
 
  /** 
   * 建立一個(gè)簡(jiǎn)單的圖形化窗口 
   * 
   * @author:tuzongxun 
   * @Title: launcFrame 
   * @param 
   * @return void 
   * @date May 18, 2016 9:57:00 AM 
   * @throws 
   */ 
  public void launcFrame() { 
    setLocation(300, 200); 
    this.setSize(200, 400); 
    add(tfTxt, BorderLayout.SOUTH); 
    add(tarea, BorderLayout.NORTH); 
    pack(); 
    // 監(jiān)聽(tīng)圖形界面窗口的關(guān)閉事件 
    this.addWindowListener(new WindowAdapter() { 
 
      @Override 
      public void windowClosing(WindowEvent e) { 
        System.exit(0); 
        disConnect(); 
      } 
    }); 
    tfTxt.addActionListener(new TFLister()); 
    setVisible(true); 
    connect(); 
  } 
 
  /** 
   * 連接服務(wù)器 
   * 
   * @author:tuzongxun 
   * @Title: connect 
   * @param 
   * @return void 
   * @date May 18, 2016 9:56:49 AM 
   * @throws 
   */ 
  public void connect() { 
    try { 
      // 新建服務(wù)端連接 
      socket = new Socket("127.0.0.1", 8888); 
      // 獲取客戶(hù)端輸出流 
      dataOutputStream = new DataOutputStream(socket.getOutputStream()); 
      System.out.println("連上服務(wù)端"); 
    } catch (UnknownHostException e) { 
      e.printStackTrace(); 
    } catch (IOException e) { 
      e.printStackTrace(); 
    } 
  } 
 
  /** 
   * 關(guān)閉客戶(hù)端資源 
   * 
   * @author:tuzongxun 
   * @Title: disConnect 
   * @param 
   * @return void 
   * @date May 18, 2016 9:57:46 AM 
   * @throws 
   */ 
  public void disConnect() { 
    try { 
      dataOutputStream.close(); 
      socket.close(); 
    } catch (IOException e) { 
      e.printStackTrace(); 
    } 
  } 
 
  /** 
   * 向服務(wù)端發(fā)送消息 
   * 
   * @author:tuzongxun 
   * @Title: sendMessage 
   * @param @param text 
   * @return void 
   * @date May 18, 2016 9:57:56 AM 
   * @throws 
   */ 
  private void sendMessage(String text) { 
    try { 
      dataOutputStream.writeUTF(text); 
      dataOutputStream.flush(); 
    } catch (IOException e1) { 
      e1.printStackTrace(); 
    } 
  } 
 
  /** 
   * 圖形窗口輸入?yún)^(qū)域監(jiān)聽(tīng)回車(chē)事件 
   * 
   * @author tuzongxun123 
   * 
   */ 
  private class TFLister implements ActionListener { 
 
    @Override 
    public void actionPerformed(ActionEvent e) { 
      String text = tfTxt.getText().trim(); 
      tarea.setText(text); 
      tfTxt.setText(""); 
      // 回車(chē)后發(fā)送數(shù)據(jù)到服務(wù)器 
      sendMessage(text); 
    } 
  } 
} 

服務(wù)端:

package chat.chat; 
 
import java.io.DataInputStream; 
import java.io.EOFException; 
import java.io.IOException; 
import java.net.BindException; 
import java.net.ServerSocket; 
import java.net.Socket; 
 
/** 
 * java使用socket和awt組件簡(jiǎn)單實(shí)現(xiàn)在線聊天功能服務(wù)端 可以實(shí)現(xiàn)一個(gè)客戶(hù)端連接后不斷向服務(wù)端發(fā)送消息 
 * 但不支持多個(gè)客戶(hù)端同時(shí)連接,原因在于代碼中獲得客戶(hù)端連接后會(huì)一直循環(huán)監(jiān)聽(tīng)客戶(hù)端輸入,造成阻塞 
 * 以至于服務(wù)端無(wú)法二次監(jiān)聽(tīng)另外的客戶(hù)端,如要實(shí)現(xiàn),需要使用異步或者多線程 
 * 
 * @author tuzongxun123 
 * 
 */ 
public class ChatServer { 
 
  public static void main(String[] args) { 
    // 是否成功啟動(dòng)服務(wù)端 
    boolean isStart = false; 
    // 服務(wù)端socket 
    ServerSocket ss = null; 
    // 客戶(hù)端socket 
    Socket socket = null; 
    // 服務(wù)端讀取客戶(hù)端數(shù)據(jù)輸入流 
    DataInputStream dataInputStream = null; 
    try { 
      // 啟動(dòng)服務(wù)器 
      ss = new ServerSocket(8888); 
    } catch (BindException e) { 
      System.out.println("端口已在使用中"); 
      // 關(guān)閉程序 
      System.exit(0); 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } 
 
    try { 
      isStart = true; 
      while (isStart) { 
        boolean isConnect = false; 
        // 啟動(dòng)監(jiān)聽(tīng) 
        socket = ss.accept(); 
        System.out.println("one client connect"); 
        isConnect = true; 
        while (isConnect) { 
          // 獲取客戶(hù)端輸入流 
          dataInputStream = new DataInputStream( 
              socket.getInputStream()); 
          // 讀取客戶(hù)端傳遞的數(shù)據(jù) 
          String message = dataInputStream.readUTF(); 
          System.out.println("客戶(hù)端說(shuō):" + message); 
        } 
 
      } 
    } catch (EOFException e) { 
      System.out.println("client closed!"); 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } finally { 
      // 關(guān)閉相關(guān)資源 
      try { 
        dataInputStream.close(); 
        socket.close(); 
      } catch (IOException e) { 
        e.printStackTrace(); 
      } 
    } 
  } 
} 

繼續(xù),在單客戶(hù)端連接的基礎(chǔ)上,這里第二步需要實(shí)現(xiàn)多客戶(hù)端的連接,也就需要使用到線程。每當(dāng)有一個(gè)新的客戶(hù)端連接上來(lái),服務(wù)端便需要新啟動(dòng)一個(gè)線程進(jìn)行處理,從而解決之前的循環(huán)讀取中造成阻塞的問(wèn)題。

寫(xiě)線程通常有兩種方法,集成Thread或者實(shí)現(xiàn)runnable接口,原則上是能實(shí)現(xiàn)runnable的情況下就不繼承,因?yàn)閷?shí)現(xiàn)接口的方式更加靈活。

客戶(hù)端代碼相較之前沒(méi)有變化,變得是服務(wù)端,因此這里便只貼出服務(wù)端代碼:

java使用socket和awt組件以及多線程簡(jiǎn)單實(shí)現(xiàn)在線聊天功能服務(wù)端 :

實(shí)現(xiàn)多個(gè)客戶(hù)端連接后不斷向服務(wù)端發(fā)送消息, 相對(duì)于第一個(gè)版本,重點(diǎn)在于使用了多線程。服務(wù)端還未實(shí)現(xiàn)轉(zhuǎn)發(fā)功能,客戶(hù)端圖形窗口中只能看到自己輸入的信息,不能看到其他客戶(hù)端發(fā)送的消息。

package chat.chat; 
 
import java.io.DataInputStream; 
import java.io.EOFException; 
import java.io.IOException; 
import java.net.BindException; 
import java.net.ServerSocket; 
import java.net.Socket; 
import java.net.SocketException; 
 
/** 
 * * 
 * @author tuzongxun123 
 * 
 */ 
public class ChatServer { 
 
  public static void main(String[] args) { 
    new ChatServer().start(); 
  } 
 
  // 是否成功啟動(dòng)服務(wù)端 
  private boolean isStart = false; 
  // 服務(wù)端socket 
  private ServerSocket ss = null; 
  // 客戶(hù)端socket 
  private Socket socket = null; 
 
  public void start() { 
    try { 
      // 啟動(dòng)服務(wù)器 
      ss = new ServerSocket(8888); 
    } catch (BindException e) { 
      System.out.println("端口已在使用中"); 
      // 關(guān)閉程序 
      System.exit(0); 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } 
 
    try { 
      isStart = true; 
      while (isStart) { 
        // 啟動(dòng)監(jiān)聽(tīng) 
        socket = ss.accept(); 
        System.out.println("one client connect"); 
        // 啟動(dòng)客戶(hù)端線程 
        Client client = new Client(socket); 
        new Thread(client).start(); 
      } 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } finally { 
      // 關(guān)閉服務(wù) 
      try { 
        ss.close(); 
      } catch (IOException e) { 
        e.printStackTrace(); 
      } 
    } 
 
  } 
 
  /** 
   * 客戶(hù)端線程 
   * 
   * @author tuzongxun123 
   * 
   */ 
  class Client implements Runnable { 
    // 客戶(hù)端socket 
    private Socket socket = null; 
    // 客戶(hù)端輸入流 
    private DataInputStream dataInputStream = null; 
    private boolean isConnect = false; 
 
    public Client(Socket socket) { 
      this.socket = socket; 
      try { 
        isConnect = true; 
        // 獲取客戶(hù)端輸入流 
        dataInputStream = new DataInputStream(socket.getInputStream()); 
      } catch (IOException e) { 
        e.printStackTrace(); 
      } 
    } 
 
    @Override 
    public void run() { 
      isConnect = true; 
      try { 
        while (isConnect) { 
          // 讀取客戶(hù)端傳遞的數(shù)據(jù) 
          String message = dataInputStream.readUTF(); 
          System.out.println("客戶(hù)端說(shuō):" + message); 
        } 
      } catch (EOFException e) { 
        System.out.println("client closed!"); 
      } catch (SocketException e) { 
        System.out.println("Client is Closed!!!!"); 
      } catch (Exception e) { 
        e.printStackTrace(); 
      } finally { 
        // 關(guān)閉相關(guān)資源 
        try { 
          dataInputStream.close(); 
          socket.close(); 
        } catch (IOException e) { 
          e.printStackTrace(); 
        } 
      } 
    } 
 
  } 
 
} 

上面主要介紹了利用線程使服務(wù)端實(shí)現(xiàn)了能夠接收多客戶(hù)端請(qǐng)求的功能,這里便需要客戶(hù)端接收多客戶(hù)端消息的同時(shí)還能把消息轉(zhuǎn)發(fā)到每個(gè)連接的客戶(hù)端,并且客戶(hù)端要能在內(nèi)容顯示區(qū)域顯示出來(lái),從而實(shí)現(xiàn)簡(jiǎn)單的在線群聊。

在實(shí)現(xiàn)客戶(hù)端轉(zhuǎn)發(fā),無(wú)非就是增加輸出流;而之前客戶(hù)端都只發(fā)不收,這里也需要更改客戶(hù)端達(dá)到循環(huán)接收服務(wù)端消息的目的,因此也需要實(shí)現(xiàn)多線程。

在實(shí)現(xiàn)這個(gè)功能的時(shí)候,偶然想起隨機(jī)生成驗(yàn)證碼的功能,于是也靈機(jī)一動(dòng)隨機(jī)給每個(gè)客戶(hù)端生成一個(gè)名字,從而在輸出的時(shí)候看起來(lái)更加像是群聊,不僅有消息輸出,還能看到是誰(shuí)。

實(shí)現(xiàn)這些功能之后,基本上就可以幾個(gè)人同時(shí)在線群聊了,因?yàn)榇a中有main方法,因此可以把服務(wù)端和客戶(hù)端都打成可執(zhí)行jar包,可參考我的另一篇博文:使用eclipse創(chuàng)建java程序可執(zhí)行jar包

之后在桌面雙擊相應(yīng)的jar文件啟動(dòng)服務(wù)端和客戶(hù)端即可,不需要再依賴(lài)eclipse運(yùn)行。

修改后的客戶(hù)端代碼如下:

package chat.chat; 
 
import java.awt.BorderLayout; 
import java.awt.Frame; 
import java.awt.TextArea; 
import java.awt.TextField; 
import java.awt.event.ActionEvent; 
import java.awt.event.ActionListener; 
import java.awt.event.WindowAdapter; 
import java.awt.event.WindowEvent; 
import java.io.DataInputStream; 
import java.io.DataOutputStream; 
import java.io.IOException; 
import java.net.Socket; 
import java.net.UnknownHostException; 
import java.util.Random; 
 
/** 
 * 在線聊天客戶(hù)端 步驟: 

 *1、生成圖形窗口界面輪廓 

 *2、為輪廓添加關(guān)閉事件 

 *3、在輪廓中加入輸入?yún)^(qū)域和內(nèi)容展示區(qū)域 

 *4、為輸入?yún)^(qū)域添加回車(chē)事件 
 * 5、建立服務(wù)端連接并發(fā)送數(shù)據(jù) 
 * 
 * @author tuzongxun123 
 * 
 */ 
public class ChatClient extends Frame { 
  /** 
   * 
   */ 
  private static final long serialVersionUID = 1L; 
  // 用戶(hù)輸入?yún)^(qū)域 
  private TextField tfTxt = new TextField(); 
  // 內(nèi)容展示區(qū)域 
  private TextArea tarea = new TextArea(); 
  private Socket socket = null; 
  // 數(shù)據(jù)輸出流 
  private DataOutputStream dataOutputStream = null; 
  // 數(shù)據(jù)輸入流 
  private DataInputStream dataInputStream = null; 
  private boolean isConnect = false; 
  Thread tReceive = new Thread(new ReceiveThread()); 
  String name = ""; 
 
  public static void main(String[] args) { 
    ChatClient chatClient = new ChatClient(); 
    chatClient.createName(); 
    chatClient.launcFrame(); 
 
  } 
 
  /** 
   * 建立一個(gè)簡(jiǎn)單的圖形化窗口 
   * 
   * @author:tuzongxun 
   * @Title: launcFrame 
   * @param 
   * @return void 
   * @date May 18, 2016 9:57:00 AM 
   * @throws 
   */ 
  public void launcFrame() { 
    setLocation(300, 200); 
    this.setSize(200, 400); 
    add(tfTxt, BorderLayout.SOUTH); 
    add(tarea, BorderLayout.NORTH); 
    // 根據(jù)窗口里面的布局及組件的preferedSize來(lái)確定frame的最佳大小 
    pack(); 
    // 監(jiān)聽(tīng)圖形界面窗口的關(guān)閉事件 
    this.addWindowListener(new WindowAdapter() { 
 
      @Override 
      public void windowClosing(WindowEvent e) { 
        System.exit(0); 
        disConnect(); 
      } 
    }); 
    tfTxt.addActionListener(new TFLister()); 
    // 設(shè)置窗口可見(jiàn) 
    setVisible(true); 
    connect(); 
    // 啟動(dòng)接受消息的線程 
    tReceive.start(); 
  } 
 
  /** 
   * 連接服務(wù)器 
   * 
   * @author:tuzongxun 
   * @Title: connect 
   * @param 
   * @return void 
   * @date May 18, 2016 9:56:49 AM 
   * @throws 
   */ 
  public void connect() { 
    try { 
      // 新建服務(wù)端連接 
      socket = new Socket("127.0.0.1", 8888); 
      // 獲取客戶(hù)端輸出流 
      dataOutputStream = new DataOutputStream(socket.getOutputStream()); 
      dataInputStream = new DataInputStream(socket.getInputStream()); 
      System.out.println("連上服務(wù)端"); 
      isConnect = true; 
    } catch (UnknownHostException e) { 
      e.printStackTrace(); 
    } catch (IOException e) { 
      e.printStackTrace(); 
    } 
  } 
 
  // 生成隨機(jī)的客戶(hù)端名字 
  public void createName() { 
    String[] str1 = { "a", "b", "c", "d", "e", "f", "g", "h", "i", "j", 
        "k", "l", "m", "n", "o", "p", "q", "r", "s", "t", "u", "v", 
        "w", "x", "y", "z", "1", "2", "3", "4", "5", "6", "7", "8", 
        "9", "0", "A", "B", "C", "D", "E", "F", "G", "H", "I", "J", 
        "K", "L", "M", "N", "O", "P", "Q", "R", "S", "T", "U", "V", 
        "W", "X", "Y", "Z" }; 
    Random ran = new Random(); 
 
    for (int i = 0; i < 6; i++) { 
      // long num = Math.round(Math.random() * (str1.length - 0) + 0); 
      // int n = (int) num; 
      int n = ran.nextInt(str1.length); 
      if (n < str1.length) { 
        String str = str1[n]; 
        name = name + str; 
        System.out.println(name); 
      } else { 
        i--; 
        continue; 
      } 
 
    } 
    this.setTitle(name); 
  } 
 
  /** 
   * 關(guān)閉客戶(hù)端資源 
   * 
   * @author:tuzongxun 
   * @Title: disConnect 
   * @param 
   * @return void 
   * @date May 18, 2016 9:57:46 AM 
   * @throws 
   */ 
  public void disConnect() { 
    try { 
      isConnect = false; 
      // 停止線程 
      tReceive.join(); 
    } catch (InterruptedException e) { 
      e.printStackTrace(); 
    } finally { 
      try { 
        if (dataOutputStream != null) { 
          dataOutputStream.close(); 
        } 
        if (socket != null) { 
          socket.close(); 
          socket = null; 
        } 
 
      } catch (IOException e) { 
        e.printStackTrace(); 
      } 
    } 
  } 
 
  /** 
   * 向服務(wù)端發(fā)送消息 
   * 
   * @author:tuzongxun 
   * @Title: sendMessage 
   * @param @param text 
   * @return void 
   * @date May 18, 2016 9:57:56 AM 
   * @throws 
   */ 
  private void sendMessage(String text) { 
    try { 
      dataOutputStream.writeUTF(name + ":" + text); 
      dataOutputStream.flush(); 
    } catch (IOException e1) { 
      e1.printStackTrace(); 
    } 
  } 
 
  /** 
   * 圖形窗口輸入?yún)^(qū)域監(jiān)聽(tīng)回車(chē)事件 
   * 
   * @author tuzongxun123 
   * 
   */ 
  private class TFLister implements ActionListener { 
 
    @Override 
    public void actionPerformed(ActionEvent e) { 
      String text = tfTxt.getText().trim(); 
      // 清空輸入?yún)^(qū)域信息 
      tfTxt.setText(""); 
      // 回車(chē)后發(fā)送數(shù)據(jù)到服務(wù)器 
      sendMessage(text); 
    } 
 
  } 
 
  private class ReceiveThread implements Runnable { 
 
    @Override 
    public void run() { 
      try { 
        while (isConnect) { 
          String message = dataInputStream.readUTF(); 
          System.out.println(message); 
          String txt = tarea.getText(); 
          if (txt != null && !"".equals(txt.trim())) { 
            message = tarea.getText() + "\n" + message; 
          } 
          tarea.setText(message); 
        } 
      } catch (IOException e) { 
        e.printStackTrace(); 
      } 
    } 
 
  } 
} 

修改后的服務(wù)端代碼如下:

package chat.chat; 
 
import java.io.DataInputStream; 
import java.io.DataOutputStream; 
import java.io.EOFException; 
import java.io.IOException; 
import java.net.BindException; 
import java.net.ServerSocket; 
import java.net.Socket; 
import java.net.SocketException; 
import java.util.ArrayList; 
import java.util.List; 
 
/** 
 * java使用socket和awt組件以及多線程簡(jiǎn)單實(shí)現(xiàn)在線聊天功能服務(wù)端 : 
 * 實(shí)現(xiàn)服務(wù)端把接收到的客戶(hù)端信息轉(zhuǎn)發(fā)到所有連接的客戶(hù)端,并且讓客戶(hù)端讀取到這些信息并顯示在內(nèi)容顯示區(qū)域中。 
 * 
 * @author tuzongxun123 
 * 
 */ 
public class ChatServer { 
 
  public static void main(String[] args) { 
    new ChatServer().start(); 
  } 
 
  // 是否成功啟動(dòng)服務(wù)端 
  private boolean isStart = false; 
  // 服務(wù)端socket 
  private ServerSocket ss = null; 
  // 客戶(hù)端socket 
  private Socket socket = null; 
  // 保存客戶(hù)端集合 
  List<Client> clients = new ArrayList<Client>(); 
 
  public void start() { 
    try { 
      // 啟動(dòng)服務(wù)器 
      ss = new ServerSocket(8888); 
    } catch (BindException e) { 
      System.out.println("端口已在使用中"); 
      // 關(guān)閉程序 
      System.exit(0); 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } 
 
    try { 
      isStart = true; 
      while (isStart) { 
        // 啟動(dòng)監(jiān)聽(tīng) 
        socket = ss.accept(); 
        System.out.println("one client connect"); 
        // 啟動(dòng)客戶(hù)端線程 
        Client client = new Client(socket); 
 
        new Thread(client).start(); 
        clients.add(client); 
      } 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } finally { 
      // 關(guān)閉服務(wù) 
      try { 
        ss.close(); 
      } catch (IOException e) { 
        e.printStackTrace(); 
      } 
    } 
 
  } 
 
  /** 
   * 客戶(hù)端線程 
   * 
   * @author tuzongxun123 
   * 
   */ 
  private class Client implements Runnable { 
    // 客戶(hù)端socket 
    private Socket socket = null; 
    // 客戶(hù)端輸入流 
    private DataInputStream dataInputStream = null; 
    // 客戶(hù)端輸出流 
    private DataOutputStream dataOutputStream = null; 
    private boolean isConnect = false; 
 
    public Client(Socket socket) { 
      this.socket = socket; 
      try { 
        isConnect = true; 
        // 獲取客戶(hù)端輸入流 
        dataInputStream = new DataInputStream(socket.getInputStream()); 
        // 獲取客戶(hù)端輸出流 
        dataOutputStream = new DataOutputStream( 
            socket.getOutputStream()); 
      } catch (IOException e) { 
        e.printStackTrace(); 
      } 
    } 
 
    /** 
     * 向客戶(hù)端群發(fā)(轉(zhuǎn)發(fā))數(shù)據(jù) 
     * 
     * @author:tuzongxun 
     * @Title: sendMessageToClients 
     * @param @param message 
     * @return void 
     * @date May 18, 2016 11:28:10 AM 
     * @throws 
     */ 
    public void sendMessageToClients(String message) { 
      try { 
        dataOutputStream.writeUTF(message); 
      } catch (SocketException e) { 
 
      } catch (IOException e) { 
        e.printStackTrace(); 
      } 
    } 
 
    @Override 
    public void run() { 
      isConnect = true; 
      Client c = null; 
      try { 
        while (isConnect) { 
          // 讀取客戶(hù)端傳遞的數(shù)據(jù) 
          String message = dataInputStream.readUTF(); 
          System.out.println("客戶(hù)端說(shuō):" + message); 
          for (int i = 0; i < clients.size(); i++) { 
            c = clients.get(i); 
 
            c.sendMessageToClients(message); 
          } 
 
        } 
      } catch (EOFException e) { 
        System.out.println("client closed!"); 
      } catch (SocketException e) { 
        if (c != null) { 
          clients.remove(c); 
        } 
        System.out.println("Client is Closed!!!!"); 
      } catch (Exception e) { 
        e.printStackTrace(); 
      } finally { 
        // 關(guān)閉相關(guān)資源 
        try { 
          if (dataInputStream != null) { 
            dataInputStream.close(); 
          } 
          if (socket != null) { 
            socket.close(); 
            socket = null; 
          } 
        } catch (IOException e) { 
          e.printStackTrace(); 
        } 
      } 
    } 
  } 
 
} 

就先為大家介紹到這里,之后如果有新的內(nèi)容再為大家進(jìn)行更新。

關(guān)于網(wǎng)頁(yè)在線聊天功能的實(shí)現(xiàn)大,大家還可以參考一下幾篇文章進(jìn)行學(xué)習(xí):

java實(shí)現(xiàn)一個(gè)簡(jiǎn)單TCPSocket聊天室功能分享

以上就是本文的全部?jī)?nèi)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家可以繼續(xù)關(guān)注腳本之家的更多精彩內(nèi)容。

相關(guān)文章

  • springboot項(xiàng)目打包并部署到Tomcat上及報(bào)錯(cuò)處理方案

    springboot項(xiàng)目打包并部署到Tomcat上及報(bào)錯(cuò)處理方案

    這篇文章主要介紹了springboot項(xiàng)目打包并部署到Tomcat上及報(bào)錯(cuò)處理方案,本文給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧
    2024-08-08
  • 使用HandlerMethodArgumentResolver用于統(tǒng)一獲取當(dāng)前登錄用戶(hù)

    使用HandlerMethodArgumentResolver用于統(tǒng)一獲取當(dāng)前登錄用戶(hù)

    這篇文章主要介紹了使用HandlerMethodArgumentResolver用于統(tǒng)一獲取當(dāng)前登錄用戶(hù)實(shí)例,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
    2022-12-12
  • Java手寫(xiě)線程池之向JDK線程池進(jìn)發(fā)

    Java手寫(xiě)線程池之向JDK線程池進(jìn)發(fā)

    在前面的文章自己動(dòng)手寫(xiě)乞丐版線程池中,我們寫(xiě)了一個(gè)非常簡(jiǎn)單的線程池實(shí)現(xiàn),這個(gè)只是一個(gè)非常簡(jiǎn)單的實(shí)現(xiàn),在本篇文章當(dāng)中我們將要實(shí)現(xiàn)一個(gè)和JDK內(nèi)部實(shí)現(xiàn)的線程池非常相似的線程池,需要的可以了解一下
    2022-10-10
  • 一文弄懂Mybatis中介者模式

    一文弄懂Mybatis中介者模式

    本文主要介紹了一文弄懂Mybatis中介者模式,文中通過(guò)示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧
    2023-06-06
  • javaCV開(kāi)發(fā)詳解之收流器實(shí)現(xiàn)

    javaCV開(kāi)發(fā)詳解之收流器實(shí)現(xiàn)

    這篇文章主要介紹了javaCV開(kāi)發(fā)詳解之收流器實(shí)現(xiàn),對(duì)javaCV有研究的同學(xué),可以參考下
    2021-04-04
  • Spring實(shí)例化bean的四種方式詳解

    Spring實(shí)例化bean的四種方式詳解

    這篇文章主要給大家介紹了關(guān)于Spring中實(shí)例化bean的四種方式:構(gòu)造方法、靜態(tài)工廠、實(shí)例工廠和FactoryBean,感興趣的可以了解一下
    2022-06-06
  • 使用Maven搭建Hadoop開(kāi)發(fā)環(huán)境

    使用Maven搭建Hadoop開(kāi)發(fā)環(huán)境

    這篇文章主要介紹了使用Maven搭建Hadoop開(kāi)發(fā)環(huán)境的相關(guān)資料,具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下
    2016-10-10
  • 友盟 微信第三方登錄示例

    友盟 微信第三方登錄示例

    這篇文章主要介紹了友盟 微信第三方登錄示例的相關(guān)資料,需要的朋友可以參考下
    2016-10-10
  • Java實(shí)戰(zhàn)之用Spring開(kāi)發(fā)條形碼和驗(yàn)證碼

    Java實(shí)戰(zhàn)之用Spring開(kāi)發(fā)條形碼和驗(yàn)證碼

    這篇文章主要介紹了Java實(shí)戰(zhàn)之用Spring開(kāi)發(fā)條形碼和驗(yàn)證碼,文中有非常詳細(xì)的代碼示例,對(duì)正在學(xué)習(xí)java的小伙伴們有非常好的幫助,需要的朋友可以參考下
    2021-04-04
  • springboot 整合fluent mybatis的過(guò)程,看這篇夠了

    springboot 整合fluent mybatis的過(guò)程,看這篇夠了

    這篇文章主要介紹了springboot 整合fluent mybatis的過(guò)程,配置數(shù)據(jù)庫(kù)連接創(chuàng)建數(shù)據(jù)庫(kù)的詳細(xì)代碼,本文給大家介紹的非常詳細(xì),需要的朋友可以參考下
    2021-08-08

最新評(píng)論

海城市| 花莲市| 巴林右旗| 义乌市| 白水县| 隆回县| 蒙自县| 夏河县| 德格县| 景德镇市| 南昌市| 固阳县| 平和县| 安平县| 承德县| 关岭| 和平区| 始兴县| 灌南县| 和政县| 凌源市| 镇坪县| 丰原市| 彩票| 阜宁县| 朝阳县| 南皮县| 花莲县| 伊宁县| 汉川市| 望谟县| 台中市| 韶关市| 无为县| 西贡区| 香格里拉县| 元氏县| 松潘县| 新泰市| 荥经县| 台北市|