java基于C/S模式实现聊天程序(服务器)

上篇介绍了java基于C/S模式实现聊天程序的客户端写法,这一篇介绍服务器的写法。

服务器的功能是:接收来自客户端的消息,然后将消息转发给当前连接的所有用户。这里一个困扰我许久的地方是如何存储所有用户的地址(套接字),找了许久我找到了一种变长数组的数据结构Vector,用size()来获取长度,用add()来添加元素,这样就容易多了,解决了服务器最大的问题。

服务器我定义了一个启动服务器的按钮,通过此按钮可以启动服务器的监听线程,我把服务器的创建放在了监听线程中。
服务器主要由两个线程组成:监听和消息处理。

监听线程:建立服务器的套接字,接收来自客户端的连接,每当有客户端连接到服务器时,服务器都要把该客户端的套接字添加到变长数组socketsss中,并且要给每个用户都创建单独的线程。

消息处理线程:在输入流中读取来自客户端的UTF字符串,然后遍历Vector数组socketsss,将UTF字符串写入到对每一个用户的输出流中。

服务器的功能就是这些了,这样就能实现基本的聊天室功能了,感觉最难的地方就是消息转发了,不过最后找到了合适的方法也解决了。只有当自己动手去写了才会发现自己有什么地方的不足,比如,设置关闭按钮的响应时,在弹出的对话框中点什么都关闭,后来发现是前面窗体设置关闭没有改成无操作;还有就是刚开始服务器只能接收处理一组消息,第二组就出问题了,是因为我以为把监听写到线程中就可以无限调用了,还是要把他放到循环中去。总之,纸上得来终觉浅绝知此事要躬行,凡事动手去做比看书理解要深刻,学编程还是要多动动手。

界面展示:

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();//这里用到了变长对象数组,用来存储来自客户端的socket对象
 ServerSocket server = null;
 Socket clients;

 Server() { // 服务器的构造函数,并且初始化
 init();
 setVisible(true);
 setDefaultCloseOperation(JFrame.DO_NOTHING_ON_CLOSE);
 setBounds(450, 150, 340, 455);
 setTitle("好好学习天天向上聊天室服务器");
 setResizable(false);
 }

 void init() { // 设置布局和事件监视器
 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("       启动服务器       ");
 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) {  //在这里启动监听的线程
  Listen listen = new Listen();
  Thread go = new Thread(listen);
  go.start();
  }
 });

 addWindowListener(new WindowAdapter() { // 响应关闭按钮功能
  public void windowClosing(WindowEvent e) {
  int option = JOptionPane
   .showConfirmDialog(null, "亲爱的你真的要离开聊天室么?",
    " 好好学习天天向上聊天室", JOptionPane.YES_NO_OPTION,
    JOptionPane.QUESTION_MESSAGE);
  if (option == JOptionPane.YES_OPTION)
   System.exit(0);

  }
 });

 } // init()结束

 class ServerThread extends Thread { // 服务器消息处理的线程
 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();// 堵塞状态,除非读取到信息
   for (int j = 0; j < sockets.size(); j++) {
   out = new DataOutputStream(
    ((Socket) sockets.get(j)).getOutputStream()); // 对于每个数组内的socket对象都建立输出流
   out.writeUTF(r);
   }
  } catch (IOException e) {
   textShow.append("有一个逗比离开了\n");
   return;
  }
  }
 }
 }

 class Listen implements Runnable { // 服务器监听线程
 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())
    + "服务器已开启\n");
  } catch (IOException e1) {
   textShow.append("正在监听\n"); // ServerSocket对象不能重复创建
  }
  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(); // 为每个用户创建单独的消息处理线程
   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();
 }
}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持呐喊教程,关注呐喊教程公众号的更多精彩内容。

声明:本文内容来源于网络,版权归原作者所有,内容由互联网用户自发贡献自行上传,本网站不拥有所有权,未作人工编辑处理,也不承担相关法律责任。如果您发现有涉嫌版权的内容,欢迎发送邮件至:notice#nhooo.com(发邮件时,请将#更换为@)进行举报,并提供相关证据,一经查实,本站将立刻删除涉嫌侵权内容。