怎么在java中利用C/S模式實(shí)現(xiàn)聊天程序

怎么在java中利用C/S模式實(shí)現(xiàn)聊天程序？相信很多沒有經(jīng)驗(yàn)的人對(duì)此束手無策，為此本文總結(jié)了問題出現(xiàn)的原因和解決方法，通過這篇文章希望你能解決這個(gè)問題。

監(jiān)聽線程：建立服務(wù)器的套接字，接收來自客戶端的連接，每當(dāng)有客戶端連接到服務(wù)器時(shí)，服務(wù)器都要把該客戶端的套接字添加到變長(zhǎng)數(shù)組socketsss中，并且要給每個(gè)用戶都創(chuàng)建單獨(dú)的線程。

消息處理線程：在輸入流中讀取來自客戶端的UTF字符串，然后遍歷Vector數(shù)組socketsss，將UTF字符串寫入到對(duì)每一個(gè)用戶的輸出流中。

服務(wù)器的功能就是這些了，這樣就能實(shí)現(xiàn)基本的聊天室功能了，感覺最難的地方就是消息轉(zhuǎn)發(fā)了，不過最后找到了合適的方法也解決了。只有當(dāng)自己動(dòng)手去寫了才會(huì)發(fā)現(xiàn)自己有什么地方的不足，比如，設(shè)置關(guān)閉按鈕的響應(yīng)時(shí)，在彈出的對(duì)話框中點(diǎn)什么都關(guān)閉，后來發(fā)現(xiàn)是前面窗體設(shè)置關(guān)閉沒有改成無操作；還有就是剛開始服務(wù)器只能接收處理一組消息，第二組就出問題了，是因?yàn)槲乙詾榘驯O(jiān)聽寫到線程中就可以無限調(diào)用了，還是要把他放到循環(huán)中去。總之，紙上得來終覺淺絕知此事要躬行，凡事動(dòng)手去做比看書理解要深刻，學(xué)編程還是要多動(dòng)動(dòng)手。

界面展示：

package server;

import java.awt.*;
import java.io.*;
import java.net.*;
import java.util.*;
import java.awt.event.*;

import javax.swing.*;

public class Server extends JFrame {

 JTextArea textShow;
 JButton start;
 Vector socketsss = new Vector();//這里用到了變長(zhǎng)對(duì)象數(shù)組，用來存儲(chǔ)來自客戶端的socket對(duì)象
 ServerSocket server = null;
 Socket clients;

 Server() { // 服務(wù)器的構(gòu)造函數(shù)，并且初始化
 init();
 setVisible(true);
 setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);
 setBounds(450, 150, 340, 455);
 setTitle("好好學(xué)習(xí)天天向上聊天室服務(wù)器");
 setResizable(false);
 }

 void init() { // 設(shè)置布局和事件監(jiān)視器
 setLayout(new FlowLayout());
 getContentPane().setBackground(new Color(20, 85, 237));
 textShow = new JTextArea(21, 29);
 textShow.setBackground(new Color(45, 210, 209));
 start = new JButton("       啟動(dòng)服務(wù)器       ");
 start.setBackground(new Color(236, 134, 21));
 add(start);
 add(new JScrollPane(textShow));
 textShow.setEditable(false);
 start.addActionListener(new ActionListener() {
  public void actionPerformed(ActionEvent e) {  //在這里啟動(dòng)監(jiān)聽的線程
  Listen listen = new Listen();
  Thread go = new Thread(listen);
  go.start();
  }
 });

 addWindowListener(new WindowAdapter() { // 響應(yīng)關(guān)閉按鈕功能
  public void windowClosing(WindowEvent e) {
  int option = JOptionPane
   .showConfirmDialog(null, "親愛的你真的要離開聊天室么？",
    " 好好學(xué)習(xí)天天向上聊天室", JOptionPane.YES_NO_OPTION,
    JOptionPane.QUESTION_MESSAGE);
  if (option == JOptionPane.YES_OPTION)
   System.exit(0);

  }
 });

 } // init()結(jié)束

 class ServerThread extends Thread { // 服務(wù)器消息處理的線程
 Socket socket;
 DataOutputStream out = null;
 DataInputStream in = null;
 String s = null;
 Vector sockets = new Vector();
 int j = 0;

 ServerThread(Socket t, Vector socketss) {
  socket = t;
  sockets = socketss;
  try { 
  in = new DataInputStream(socket.getInputStream());
  } catch (IOException e) {
  }
 }

 public void run() {
  while (true) {
  try {
   String r = in.readUTF();// 堵塞狀態(tài)，除非讀取到信息
   for (int j = 0; j < sockets.size(); j++) {
   out = new DataOutputStream(
    ((Socket) sockets.get(j)).getOutputStream()); // 對(duì)于每個(gè)數(shù)組內(nèi)的socket對(duì)象都建立輸出流
   out.writeUTF(r);
   }
  } catch (IOException e) {
   textShow.append("有一個(gè)逗比離開了\n");
   return;
  }
  }
 }
 }

 class Listen implements Runnable { // 服務(wù)器監(jiān)聽線程
 ServerSocket server;
 Socket clients;

 public void run() {
  while (true) {
  try {
   server = new ServerSocket(8888);
   textShow.append(new java.text.SimpleDateFormat(
    "yy-MM-dd HH:mm:ss").format(new Date())
    + "服務(wù)器已開啟\n");
  } catch (IOException e1) {
   textShow.append("正在監(jiān)聽\n"); // ServerSocket對(duì)象不能重復(fù)創(chuàng)建
  }
  try {
   textShow.append(new java.text.SimpleDateFormat(
    "yy-MM-dd HH:mm:ss").format(new Date())
    + " 等待用戶連接......\n");

   clients = server.accept();
   socketsss.add(clients);
   ServerThread handlers = new ServerThread(clients, socketsss);
   handlers.start(); // 為每個(gè)用戶創(chuàng)建單獨(dú)的消息處理線程
   textShow.append(new java.text.SimpleDateFormat(
    "yy-MM-dd HH:mm:ss").format(new Date())
    + "有用戶連接,用戶的地址:" + clients.getInetAddress() + "\n");
  } catch (IOException e1) {
   textShow.append(new java.text.SimpleDateFormat(
    "yy-MM-dd HH:mm:ss").format(new Date())
    + "正在等待逗比來臨......\n");
  }
  }
 }
 }

 public static void main(String args[]) {
 Server server = new Server();
 }
}

看完上述內(nèi)容，你們掌握怎么在java中利用C/S模式實(shí)現(xiàn)聊天程序的方法了嗎？如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容，歡迎關(guān)注億速云行業(yè)資訊頻道，感謝各位的閱讀！