程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 編程語言 >> JAVA編程 >> 關於JAVA >> 基於Java Socket完成一個簡略單純在線聊天功效(一)

基於Java Socket完成一個簡略單純在線聊天功效(一)

編輯:關於JAVA

基於Java Socket完成一個簡略單純在線聊天功效(一)。本站提示廣大學習愛好者:(基於Java Socket完成一個簡略單純在線聊天功效(一))文章只能為提供參考,不一定能成為您想要的結果。以下是基於Java Socket完成一個簡略單純在線聊天功效(一)正文


比來做了一個項目,個中有一個在線網頁交換的需求,很久沒寫代碼了,手都陌生了,因而先寫demo練練手,分享到平台,以此做個記載,便利本身和年夜家應用。

先給年夜家說下完成步調分如許幾年夜步:

1、應用awt組件和socket完成簡略的單客戶端向辦事端連續發送新聞;

2、聯合線程,完成多客戶端銜接辦事端發送新聞;

3、完成辦事端轉發客戶端新聞至一切客戶端,同時在客戶端顯示;

4、把awt組件生成的窗口界面改成前端jsp或許html展現的界面,java socket完成的客戶端改成前端技巧完成。

這裡起首完成第一步的簡略功效,難點在於:

1、沒有效過awt組件,沒有效過java相干的監聽事宜;

2、長時光沒有應用socket停止客戶端和辦事真個交互,而且沒有真正停止過cs構造的開辟。

完成功效的代碼以下:

客戶端:

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; 
/** 
 * 在線聊天客戶端 1、生成圖形窗口界面輪廓 2、為輪廓添加封閉事宜 3、在輪廓中參加輸出區域和內容展現區域 4、為輸出區域添加回車事宜 
 * 5、樹立辦事端銜接並發送數據 
 * 
 * @author tuzongxun123 
 * 
 */ 
public class ChatClient extends Frame { 
  // 用戶輸出區域 
  private TextField tfTxt = new TextField(); 
  // 內容展現區域 
  private TextArea tarea = new TextArea(); 
  private Socket socket = null; 
  // 數據輸入流 
  private DataOutputStream dataOutputStream = null; 
  public static void main(String[] args) { 
    new ChatClient().launcFrame(); 
  } 
  /** 
   * 樹立一個簡略的圖形化窗口 
   * 
   * @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(); 
    // 監聽圖形界面窗口的封閉事宜 
    this.addWindowListener(new WindowAdapter() { 
      @Override 
      public void windowClosing(WindowEvent e) { 
        System.exit(0); 
        disConnect(); 
      } 
    }); 
    tfTxt.addActionListener(new TFLister()); 
    setVisible(true); 
    connect(); 
  } 
  /** 
   * 銜接辦事器 
   * 
   * @author:tuzongxun 
   * @Title: connect 
   * @param 
   * @return void 
   * @date May 18, 2016 9:56:49 AM 
   * @throws 
   */ 
  public void connect() { 
    try { 
      // 新建辦事端銜接 
      socket = new Socket("127.0.0.1", 8888); 
      // 獲得客戶端輸入流 
      dataOutputStream = new DataOutputStream(socket.getOutputStream()); 
      System.out.println("連上辦事端"); 
    } catch (UnknownHostException e) { 
      e.printStackTrace(); 
    } catch (IOException e) { 
      e.printStackTrace(); 
    } 
  } 
  /** 
   * 封閉客戶端資本 
   * 
   * @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(); 
    } 
  } 
  /** 
   * 向辦事端發送新聞 
   * 
   * @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(); 
    } 
  } 
  /** 
   * 圖形窗口輸出區域監聽回車事宜 
   * 
   * @author tuzongxun123 
   * 
   */ 
  private class TFLister implements ActionListener { 
    @Override 
    public void actionPerformed(ActionEvent e) { 
      String text = tfTxt.getText().trim(); 
      tarea.setText(text); 
      tfTxt.setText(""); 
      // 回車後發送數據到辦事器 
      sendMessage(text); 
    } 
  } 
} 

辦事端:

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組件簡略完成在線聊天功效辦事端 可以完成一個客戶端銜接後赓續向辦事端發送新聞 
 * 但不支撐多個客戶端同時銜接,緣由在於代碼中取得客戶端銜接後會一向輪回監聽客戶端輸出,形成壅塞 
 * 以致於辦事端沒法二次監聽別的的客戶端,如要完成,須要應用異步或許多線程 
 * 
 * @author tuzongxun123 
 * 
 */ 
public class ChatServer { 
  public static void main(String[] args) { 
    // 能否勝利啟動辦事端 
    boolean isStart = false; 
    // 辦事端socket 
    ServerSocket ss = null; 
    // 客戶端socket 
    Socket socket = null; 
    // 辦事端讀取客戶端數據輸出流 
    DataInputStream dataInputStream = null; 
    try { 
      // 啟動辦事器 
      ss = new ServerSocket(8888); 
    } catch (BindException e) { 
      System.out.println("端口已在應用中"); 
      // 封閉法式 
      System.exit(0); 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } 
    try { 
      isStart = true; 
      while (isStart) { 
        boolean isConnect = false; 
        // 啟動監聽 
        socket = ss.accept(); 
        System.out.println("one client connect"); 
        isConnect = true; 
        while (isConnect) { 
          // 獲得客戶端輸出流 
          dataInputStream = new DataInputStream( 
              socket.getInputStream()); 
          // 讀取客戶端傳遞的數據 
          String message = dataInputStream.readUTF(); 
          System.out.println("客戶端說:" + message); 
        } 
      } 
    } catch (EOFException e) { 
      System.out.println("client closed!"); 
    } catch (Exception e) { 
      e.printStackTrace(); 
    } finally { 
      // 封閉相干資本 
      try { 
        dataInputStream.close(); 
        socket.close(); 
      } catch (IOException e) { 
        e.printStackTrace(); 
      } 
    } 
  } 
} 

以上所述是小編給年夜家引見的Java Socket完成一個簡略單純在線聊天功效(一)的相干常識,願望對年夜家有所贊助,假如年夜家有任何疑問請給我留言,小編會實時答復年夜家的。在此也異常感激年夜家對網站的支撐!

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved