java聊天室的實現(xiàn)代碼

更新時間：2020年03月31日 16:41:16 作者：北漂程序員-阿力

這篇文章主要為大家詳細介紹了java聊天室的實現(xiàn)代碼，一個多客戶端聊天室，支持多客戶端聊天，具有一定的參考價值，感興趣的小伙伴們可以參考一下

本文實例為大家分享了java實現(xiàn)聊天室的具體代碼，供大家參考，具體內(nèi)容如下

聊天室界面：

源碼：

public class ClientFrame extends Frame {

 private TextField textFieldContent = new TextField();
 private TextArea textAreaContent = new TextArea();
 private Socket socket = null;
 private OutputStream out = null;
 private DataOutputStream dos = null;
 private InputStream in = null;
 private DataInputStream dis = null;
 private boolean flag = false;

 /**
 * 學校：山東師范大學 程序員：外力_Victor 日期：2016年5月8日 上午9:19:51 功能：啟動客戶端程序
 * 
 * @param args
 */
 public static void main(String[] args) {
 new ClientFrame().init();
 }

 /**
 * 學校：山東師范大學 程序員：外力_Victor 日期：2016年5月8日 上午9:20:43 功能：對窗口進行初始化
 */
 private void init() {
 this.setSize(300, 300);
 setLocation(250, 150);
 setVisible(true);
 setTitle("WeChatRoom");

 // 添加控件
 this.add(textAreaContent);
 this.add(textFieldContent, BorderLayout.SOUTH);
 textAreaContent.setFocusable(false);
 pack();

 // 關閉事件
 addWindowListener(new WindowAdapter() {
  public void windowClosing(WindowEvent e) {
  System.out.println("用戶試圖關閉窗口");
  disconnect();
  System.exit(0);
  }

 });
 // textFieldContent添加回車事件
 textFieldContent.addActionListener(new ActionListener() {
  public void actionPerformed(ActionEvent e) {
  onClickEnter();
  }
 });

 // 建立連接
 connect();
 new Thread(new ReciveMessage()).start();
 }

 private class ReciveMessage implements Runnable {
 @Override
 public void run() {
  flag = true;
  try {
  while (flag) {
   String message = dis.readUTF();
   textAreaContent.append(message + "\n");
  }
  } catch (EOFException e) {
  flag = false;
  System.out.println("客戶端已關閉");
  // e.printStackTrace();
  } catch (SocketException e) {
  flag = false;
  System.out.println("客戶端已關閉");
  // e.printStackTrace();
  } catch (IOException e) {
  flag = false;
  System.out.println("接受消息失敗");
  e.printStackTrace();
  }
 }

 }

 /**
 * 功能：當點擊回車時出發(fā)的事件 學校：山東師范大學 程序員：外力_Victor 日期：2016年5月8日 上午9:49:30
 */
 private void onClickEnter() {
 String message = textFieldContent.getText().trim();
 if (message != null && !message.equals("")) {
  String time = new SimpleDateFormat("h:m:s").format(new Date());
  textAreaContent.append(time + "\n" + message + "\n");
  textFieldContent.setText("");
  sendMessageToServer(message);
 }
 }

 /**
 * 功能：給服務器發(fā)送消息 學校：山東師范大學 程序員：外力_Victor 日期：2016年5月8日 上午10:13:48
 * 
 * @param message
 */
 private void sendMessageToServer(String message) {
 try {
  dos.writeUTF(message);
  dos.flush();
 } catch (IOException e) {
  System.out.println("發(fā)送消息失敗");
  e.printStackTrace();
 }
 }

 /**
 * 功能：申請socket鏈接 學校：山東師范大學 程序員：外力_Victor 日期：2016年5月8日 上午10:00:38
 */
 private void connect() {
 try {
  socket = new Socket("localhost", 8888);
  out = socket.getOutputStream();
  dos = new DataOutputStream(out);
  in = socket.getInputStream();
  dis = new DataInputStream(in);
 } catch (UnknownHostException e) {
  System.out.println("申請鏈接失敗");
  e.printStackTrace();
 } catch (IOException e) {
  System.out.println("申請鏈接失敗");
  e.printStackTrace();
 }
 }

 /**
 * 功能：關閉流和鏈接 學校：山東師范大學 程序員：外力_Victor 日期：2016年5月8日 上午10:01:32
 */
 private void disconnect() {
 flag = false;
 if (dos != null) {
  try {
  dos.close();
  } catch (IOException e) {
  System.out.println("dos關閉失敗");
  e.printStackTrace();
  }
 }
 if (out != null) {
  try {
  out.close();
  } catch (IOException e) {
  System.out.println("dos關閉失敗");
  e.printStackTrace();
  }
 }
 if (socket != null) {
  try {
  socket.close();
  } catch (IOException e) {
  System.out.println("socket關閉失敗");
  e.printStackTrace();
  }
  ;
 }
 }

}

package com.chat;

import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.EOFException;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.BindException;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.List;

public class ChatServer {

 private List<Client> clients = new ArrayList<>();

 /**
 * 功能：啟動ChatSever 學校：山東師范大學 程序員：外力_Victor 日期：2016年5月8日 上午10:26:41
 * 
 * @param args
 */
 public static void main(String[] args) {
 new ChatServer().init();
 }

 /**
 * 功能：對chatserver初始化 學校：山東師范大學 程序員：外力_Victor 日期：2016年5月8日 上午10:27:09
 */
 private void init() {
 System.out.println("服務器已開啟");
 // BindException

 ServerSocket ss = null;
 Socket socket = null;
 try {
  ss = new ServerSocket(8888);
 } catch (BindException e) {
  System.out.println("端口已被占用");
  e.printStackTrace();
 } catch (IOException e1) {
  e1.printStackTrace();
 }
 try {
  Client client = null;
  while (true) {
  socket = ss.accept();
  System.out.println("客戶駕到");
  client = new Client(socket);
  clients.add(client);
  new Thread(client).start();
  }
 } catch (IOException e) {
  e.printStackTrace();
 }
 }

 private class Client implements Runnable {
 private Socket socket = null;
 InputStream in = null;
 DataInputStream din = null;
 OutputStream out = null;
 DataOutputStream dos = null;
 boolean flag = true;

 public Client(Socket socket) {
  this.socket = socket;
  try {
  in = socket.getInputStream();
  din = new DataInputStream(in);
  } catch (IOException e) {
  System.out.println("接受消息失敗");
  e.printStackTrace();
  }

 }

 public void run() {

  String message;
  try {
  while (flag) {
   message = din.readUTF();
   // System.out.println("客戶說：" + message);
   forwordToAllClients(message);
  }
  } catch (SocketException e) {
  flag = false;
  System.out.println("客戶下線");
  clients.remove(this);
  // e.printStackTrace();
  } catch (EOFException e) {
  flag = false;
  System.out.println("客戶下線");
  clients.remove(this);
  // e.printStackTrace();
  } catch (IOException e) {
  flag = false;
  System.out.println("接受消息失敗");
  clients.remove(this);
  e.printStackTrace();
  }

  if (din != null) {
  try {
   din.close();
  } catch (IOException e) {
   System.out.println("din關閉失敗");
   e.printStackTrace();
  }
  }
  if (in != null) {
  try {
   in.close();
  } catch (IOException e) {
   System.out.println("din關閉失敗");
   e.printStackTrace();
  }
  }
  if (socket != null) {
  try {
   socket.close();
  } catch (IOException e) {
   System.out.println("din關閉失敗");
   e.printStackTrace();
  }
  }

 }

 /**
  * 功能：轉發(fā)給所有客戶端 學校：山東師范大學 程序員：外力_Victor 日期：2016年5月8日 上午11:11:59
  * 
  * @param message
  * @throws IOException
  */
 private void forwordToAllClients(String message) throws IOException {
  for (Client c : clients) {
  if (c != this) {
   out = c.socket.getOutputStream();
   dos = new DataOutputStream(out);
   forwordToClient(message);
  }
  }
 }

 /**
  * 功能：發(fā)送給一個客戶端 學校：山東師范大學 程序員：外力_Victor 日期：2016年5月8日 上午11:16:12
  * 
  * @throws IOException
  */
 private void forwordToClient(String message) throws IOException {
  dos.writeUTF(message);
  dos.flush();
  System.out.println("轉發(fā)成功！");
 }

 }
}

源碼下載：java聊天室代碼

以上就是本文的全部內(nèi)容，希望對大家的學習有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章: