快捷導航

詳解基于java的Socket聊天程序——初始設(shè)計（附demo）

更新時間：2016年12月12日 09:20:12 作者：jAVA-yaolin

本篇文章主要介紹了Socket聊天程序——初始設(shè)計（附demo），小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧

寫在前面：

可能是臨近期末了，各種課程設(shè)計接踵而來，最近在csdn上看到2個一樣問答，那就是編寫一個基于socket的聊天程序，正好最近剛用socket做了一些事，出于興趣，自己抽了幾個晚上的空閑時間敲了一個，目前僅支持單聊，群聊，文件傳送這些功能。首先，貼出一個丑丑的程序圖（UI是用java swing寫的，這個早就忘光了，無奈看著JDK的API寫了一個），如下圖：　　

服務(wù)端設(shè)計：

服務(wù)端主要有兩個操作，一是阻塞接收客戶端的socket并做響應(yīng)處理，二是檢測客戶端的心跳，如果客戶端一段時間內(nèi)沒有發(fā)送心跳則移除該客戶端，由Server創(chuàng)建ServerSocket，然后啟動兩個線程池去處理這兩件事（newFixedThreadPool，newScheduledThreadPool），對應(yīng)的處理類分別是SocketDispatcher、SocketSchedule，其中SocketDispatcher根據(jù)socket不同的請求分發(fā)給不同SocketHandler去處理，而SocketWrapper則是對socket加了一層外殼包裝，用lastAliveTime記錄socket最新的交互時間，SocketHolder存儲當前跟服務(wù)端交互的socket集合。設(shè)計如下：

客戶端設(shè)計：

客戶端設(shè)計主要分成兩個部分，分別是socket通訊模塊設(shè)計和UI相關(guān)設(shè)計

客戶端socket通訊設(shè)計，這里的設(shè)計其實跟服務(wù)端的設(shè)計差不多，不同的是服務(wù)端是接收心跳包，而客戶端是發(fā)送心跳包，由于客戶端只與一個服務(wù)端進行通訊（客戶端之間的通訊也是由服務(wù)端進行分發(fā)的），所以這里只使用了一個大小為2的線程池去處理這兩件事（newFixedThreadPool(2)），對應(yīng)的處理類分別是ReceiveListener、KeepAliveDog，其中ReceiveListener在初始化的時候傳入一個Callback作為客戶端收到服務(wù)端的消息的回調(diào)，Callback的默認實現(xiàn)是DefaultCallback，DefaultCallback根據(jù)不同的事件通過HF分發(fā)給不同Handler去處理，而ClientHolder則是存儲當前客戶端信息，設(shè)計如下：

UI相關(guān)設(shè)計，這里我不打算自己寫UI，畢竟自己寫出來的太丑了，所以后期可能會叫同學或朋友幫忙敲一下，所以我將UI的事件處理都交由Action去處理，將UI設(shè)計和事件響應(yīng)簡單分離，所有UI繼承JFrame并實現(xiàn)View接口，上面的Handler實現(xiàn)類通過Router獲取（存在則直接返回，不存在則創(chuàng)建并存儲）指定的UI，View中提供了UI的創(chuàng)建create()、獲取container()、獲取UI中的組件getComponent()，顯示display()，回收trash()；ResultWrapper和ResultHolder只是為了創(chuàng)建和存儲聊天選項卡。

Common模塊設(shè)計：

Common模塊主要是數(shù)據(jù)交互，這里使用JSON數(shù)據(jù)進行交互，common模塊定義了各類交互信息，SendHelper實現(xiàn)的socket信息的傳送，I18N是語言話，ConstantValue是系統(tǒng)中的配置以及常量（這里常量都是用接口，這個可能不太好），對于ReturnMessage擁有一系列的DTO作為其content屬性。

程序入口：

最后給出服務(wù)端和客戶端的入口程序（完整代碼掛在csdn上，有時間會持續(xù)更新，文章最后有地址）

服務(wù)端入口：

package yaolin.chat.server;

import java.io.IOException;
import java.net.ServerSocket;
import java.util.Date;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

import yaolin.chat.common.ConstantValue;
import yaolin.chat.util.LoggerUtil;

/**
 * 服務(wù)器
 * @author yaolin
 */
public class Server {

  private final ServerSocket server;
  private final ExecutorService pool;
  
  public Server() throws IOException {
    server = new ServerSocket(ConstantValue.SERVER_PORT);
    pool = Executors.newFixedThreadPool(ConstantValue.MAX_POOL_SIZE);
  }

  public void start() {
    try {
      ScheduledExecutorService schedule = Executors.newScheduledThreadPool(1);
      // Watch dog. Exception??
      schedule.scheduleAtFixedRate(new SocketSchedule(), 10, ConstantValue.TIME_OUT, TimeUnit.SECONDS);

      while (true) {
        pool.execute(new SocketDispatcher(server.accept()));
        LoggerUtil.info("ACCEPT A CLIENT AT " + new Date());
      }
    } catch (IOException e) {
      pool.shutdown();
    }
  }
  
  
  public static void main(String[] args) {
    try {
      new Server().start();
    } catch (IOException e) {
      LoggerUtil.error("Server start failed! -> " + e.getMessage(), e);
    }
  }
}

客戶端入口：

package yaolin.chat.client;

import java.io.IOException;

import javax.swing.JOptionPane;

import yaolin.chat.client.callback.DefaultCallback;
import yaolin.chat.client.view.Router;
import yaolin.chat.client.view.impl.RegisterAndLoginView;

/**
 * 
 * @author yaolin
 *
 */
public class NiloayChat {

  public static void main(String[] args) {
    RegisterAndLoginView v = (RegisterAndLoginView) Router.getView(RegisterAndLoginView.class).create();
    try {
      v.display();
      Client client = new Client(new DefaultCallback());
      client.start();
      ClientHolder.setClient(client);
    } catch (IOException e) {
      JOptionPane.showMessageDialog(v.getContentPane(), e.getMessage());
    }
  }
}

源碼下載：demo

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

您可能感興趣的文章: