程式師世界 >> 編程語言 >> JAVA編程 >> 關於JAVA >> Java基於UDP協定完成簡略的聊天室法式

Java基於UDP協定完成簡略的聊天室法式

編輯：關於JAVA

Java基於UDP協定完成簡略的聊天室法式。本站提示廣大學習愛好者：（Java基於UDP協定完成簡略的聊天室法式）文章只能為提供參考，不一定能成為您想要的結果。以下是Java基於UDP協定完成簡略的聊天室法式正文

比來比擬閒，一向在抽閒回想一些Java方面的技巧運用。
明天沒甚麼事做，基於UDP協定，寫了一個異常簡略的聊天室法式。
如今的任務，很罕用到socket，也算是對Java收集編程方面的一個簡略回想。

先看一下後果：

完成的後果可以說長短常異常簡略，但照樣可以簡略的看到一個完成道理。
“聊天室001”的用戶，小紅和小綠互相聊了兩句，“聊天室002”的小黑無人理睬，在一旁孤單著。

看一下代碼完成：

1、起首是新聞辦事器的完成，功效很簡略：
•將客戶真個信息（進入了哪個聊天室等）停止掛號；
•結構UDP協定套接字對象，接收各個客戶端發送的新聞；
•解析新聞內容，將聊天信息推送回對應聊天室的各個客戶端；

package com.tsr.simplechat.receive_server;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
import java.util.ArrayList;
import java.util.HashMap;

import com.谷歌.gson.Gson;
import com.tsr.simplechat.bean.MessageEntity;
import com.tsr.simplechat.client.ChatClient;

//聊天辦事器
public class ChatServer extends Thread {
 // 法式占用端標語
 private static final int PORT = 10000;
 // 新聞接收套接字對象
 private static DatagramSocket server = null;
 // 字典對象(Key：聊天室ID，Value：該聊天室下的客戶端用戶聚集);
 private static HashMap<String, ArrayList<ChatClient>> groups = new HashMap<String, ArrayList<ChatClient>>();

 // 結構器
 public ChatServer() {
 try {
  // 新聞接收套接字對象的結構初始化
  server = new DatagramSocket(PORT);
 } catch (SocketException e) {
  e.printStackTrace();
 }
 }

 // 注冊聊天室新登錄用戶
 public static void logInGroup(String groupID, ChatClient client) {
 // 經由過程聊天室ID，獲得該聊天室的一切在線用戶
 ArrayList<ChatClient> clients = groups.get(groupID);
 if (clients == null) {
  clients = new ArrayList<ChatClient>();
 }
 // 將此次進入聊天室的用戶掛號
 clients.add(client);
 // 更新聊天室信息
 groups.put(groupID, clients);
 }

 // 輪回吸收新聞
 @Override
 public void run() {
 while (true) {
  receiveMessage();
 }
 }

 private void receiveMessage() {
 // UDP數據包
 byte[] buf = new byte[1024];
 DatagramPacket packet = new DatagramPacket(buf, buf.length);
 while (true) {
  try {
  // 接收數據包
  server.receive(packet);
  } catch (IOException e) {
  // TODO Auto-generated catch block
  e.printStackTrace();
  }

  // 解析數據包，獲得聊天信息
  String content = new String(packet.getData(), 0, packet.getLength());

  // 經由過程第三方包解析json數據
  Gson gson = new Gson();
  MessageEntity me = gson.fromJson(content, MessageEntity.class);

  // 解析新聞內容，經由過程聊天室ID，獲得該聊天室的一切在線用戶
  ArrayList<ChatClient> clients = groups.get(me.getGroupId());

  // 將吸收到的新聞推送回該聊天室的各個用戶
  for (ChatClient client : clients) {
  client.pushBackMessage(me);
  }
 }
 }
}

2、客戶端法式，仍然很簡略：

•簡略的界說客戶端聊天室界面。
•結構新聞發送套接字對象。
•獲得聊天信息框的內容，發送到辦事器。

 package com.tsr.simplechat.client;

import java.awt.Button;
import java.awt.Event;
import java.awt.Frame;
import java.awt.TextArea;
import java.awt.TextField;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.net.SocketException;
import java.net.UnknownHostException;
import com.tsr.simplechat.bean.MessageEntity;
import com.tsr.simplechat.receive_server.ChatServer;

//客戶端法式
public class ChatClient extends Frame {
 private static final long serialVersionUID = 1L;
 // 聊天室ID
 private String groupID;
 // 客戶端用戶名
 private String clientName;
 // 客戶端新聞發送辦事套接字
 private DatagramSocket msg_send;
 // 辦事端口
 private final int PORT = 10000;
 // 辦事器IP地址
 private InetAddress ip;

 // 客戶端控件
 TextField tf = new TextField(20);
 TextArea ta = new TextArea();
 Button send = new Button("send");

 // 客戶端結構器
 public ChatClient(String groupID, String clientName) {

 super("聊天室:" + groupID + "/" + clientName);
 this.clientName = clientName;
 this.groupID = groupID;
 // 設置客戶端界面款式
 add("North", tf);
 add("Center", ta);
 add("South", send);
 setSize(250, 250);
 show();
 // 聊天相干辦事器初始化
 init();

 // 監督器
 addWindowListener(new WindowAdapter() {
  public void windowClosing(WindowEvent e) {
  // 封閉新聞發送辦事
  msg_send.close();
  // 封閉客戶端法式
  dispose();
  System.exit(0);
  }
 });

 }

 // 聊天相干辦事器初始化
 private void init() {
 // 注冊以後用戶及地點聊天室信息注冊到辦事器
 ChatServer.logInGroup(groupID, this);
 try {
  // 初始化新聞發送套接字對象
  msg_send = new DatagramSocket();
  // 指定新聞辦事器
  try {
  ip = InetAddress.getByName("127.0.0.1");
  } catch (UnknownHostException e) {
  System.out.println("未知的主機異常..");
  }
 } catch (SocketException e) {
  System.out.println("套接字銜接異常..");
 }
 }

 // 新聞發送按鈕時光監聽
 public boolean action(Event evt, Object arg) {
 if (evt.target.equals(send)) {
  try {
  // 獲得輸出內容
  String content = tf.getText();
  // 發送新聞
  send_message(content);
  // 清空聊天框
  tf.setText(null);
  } catch (Exception ioe) {
  System.out.print(ioe.getMessage());
  }
 }
 return true;
 }

 // 新聞發送
 private void send_message(String content) {
 // 新聞格局化(json格局)
 String message = messageFormat(content);
 // 將新聞封裝成UDP數據包
 byte[] buf = message.getBytes();
 DatagramPacket packet = new DatagramPacket(buf, buf.length, ip, PORT);

 try {
  // 經由過程UDP協定發送新聞
  msg_send.send(packet);
 } catch (IOException e) {
  System.out.println("IO異常..");
 }
 }

 // 新聞格局化
 private String messageFormat(String content) {
 StringBuffer buffer = new StringBuffer();
 buffer.append("{\"groupId\":").append("\"").append(groupID).append(
  "\",");
 buffer.append("\"userName\":\"").append(clientName).append("\",");
 buffer.append("\"text\":\"").append(content).append("\"}");

 return buffer.toString();

 }

 // 從辦事器獲得以後聊天室最新新聞(回調..)
 public void pushBackMessage(MessageEntity me) {
 ta.append(me.getUserName() + ":" + me.getText());
 ta.append("\n");

 }
}

3、新聞實體類
重要就是用於將新聞封裝成對象，包括：聊天室ID、新聞發送者昵稱，新聞內容。應用json格局解析。

 package com.tsr.simplechat.bean;

//新聞實體
public class MessageEntity {
 private String groupId;
 private String userName;
 private String text;

 public String getGroupId() {
 return groupId;
 }

 public void setGroupId(String groupId) {
 this.groupId = groupId;
 }

 public String getUserName() {
 return userName;
 }

 public void setUserName(String userName) {
 this.userName = userName;
 }

 public String getText() {
 return text;
 }

 public void setText(String text) {
 this.text = text;
 }

}

4、OK，到了這裡就根本弄定了，樹立一個測試類。

•開啟新聞辦事器。
•開啟三個客戶端，個中兩個進入“聊天室001”，另外一個進入“聊天室002”。

 import com.tsr.simplechat.client.ChatClient;
import com.tsr.simplechat.receive_server.ChatServer;

public class Test {
 public static void main(String[] args) {
 ChatServer r = new ChatServer();
 r.start();
 
 ChatClient c1 = new ChatClient("001", "小紅");
 ChatClient c2 = new ChatClient("001", "小綠");
 ChatClient c3 = new ChatClient("002", "小黑");
 }
}

以上就是本文的全體內容，願望對年夜家的進修有所贊助，也願望年夜家多多支撐。

關於JAVA