欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

java实现小型局域网群聊功能(C/S模式)

程序员文章站 2024-03-13 21:12:40
本文实例为大家分享了java群聊功能,供大家参考,具体内容如下 java 对tcp协议的支持: --> java.net包中定义了两个类serversocket...

本文实例为大家分享了java群聊功能,供大家参考,具体内容如下

java 对tcp协议的支持:
--> java.net包中定义了两个类serversocket 和socket ,分别用来实现双向连接的server 端和client 端。 
--> client 类定义客户端 

package com.dragon.java.tcpchat;

import java.io.ioexception;
import java.net.socket;
import java.net.unknownhostexception;

/**
 * 客户端
 * 
 * @author auser
 * 
 */
public class client {
  public static void main(string args[]) throws unknownhostexception,
      ioexception {
    socket client = new socket("192.168.1.188", 10000);

    // 穿件发送信息的线程
    new clientsend(client).start();
    // 创建接收信息的线程
    new clientreceive(client).start();
     // 因为要实现聊天功能,而不是只发送一次信息,所以输出流和客户端都不能关闭。
    // client.shutdownoutput();
    // client.close();

  }
}

--> clientsend 类 定义客户端向服务端发送信息的线程 

package com.dragon.java.tcpchat;

import java.io.ioexception;
import java.io.printstream;
import java.net.socket;
import java.util.scanner;

/**
 * 客户端向服务端发送信息的线程
 * 
 * @author auser
 * 
 */
public class clientsend extends thread {
  private scanner scanner;
  private socket socket;

  public clientsend(socket socket) {
    this.socket = socket;
  }

  @override
  public void run() {
    scanner = new scanner(system.in);

    try {
      printstream ps = new printstream(socket.getoutputstream());
      string line = "";
      // 阻塞式发送信息
      while ((line = scanner.nextline()) != null) {
        ps.println(line);
      }
    } catch (ioexception e) {
      e.printstacktrace();
    }
  }
}

--> clientreceive 类 定义客户端接收服务端信息的线程 

package com.dragon.java.tcpchat;

import java.io.bufferedreader;
import java.io.inputstreamreader;
import java.net.socket;

/**
 * 客户端接收信息的线程
 * 
 * @author auser
 * 
 */
public class clientreceive extends thread {
  private socket socket;

  public clientreceive(socket socket) {
    this.socket = socket;
  }

  @override
  public void run() {
    try {
      bufferedreader br = new bufferedreader(new inputstreamreader(
          socket.getinputstream()));
      // 按行接收信息
      string line = "";
      while ((line = br.readline()) != null) {
        system.out.println(line);
      }
    } catch (exception e) {
      e.printstacktrace();
    }
  }

}

--> server 类定义服务端 

package com.dragon.java.tcpchat;

import java.io.ioexception;
import java.net.serversocket;
import java.net.socket;
import java.util.arraylist;
import java.util.list;

/**
 * 服务器
 * 
 * @author auser
 * 
 */
public class server {
  public static void main(string[] args) throws ioexception,
      interruptedexception {
    list<socket> list = new arraylist<>();

    // 创建服务器端的套接字
    serversocket server = new serversocket(10000);

    while (true) {
      // 接收客户端的阻塞方法
      socket socket = server.accept();
      // 设计到多个线程可能会对集合进行增删的操作,要进行同步的处理
      synchronized (list) {
        list.add(socket);
      }
      // 启动一个新的线程去处理这个客户端的交流
      new handlesocket(socket, list).start();
    }
     // 因为不知道客户端什么时候发送信息,所以服务端要一直开启不能关闭。
  }
}

--> handlesocket 类对连接到服务端的客户端进行操作(上下线通知、屏蔽拉黑、将信息发送到每个客户端等...) 

package com.dragon.java.tcpchat;

import java.io.bufferedreader;
import java.io.ioexception;
import java.io.inputstreamreader;
import java.io.printstream;
import java.net.inetaddress;
import java.net.socket;
import java.util.list;

/**
 * 处理每个(单个)连接到服务器的客户端的线程
 * 
 * @author auser
 * 
 */
public class handlesocket extends thread {

  private socket socket;
  private list<socket> list;

  /**
   * 构造方法
   * 
   * @param socket
   *      当前连接的客户端
   * @param list
   *      存储已连接客户端的集合
   */
  public handlesocket(socket socket, list<socket> list) {
    this.socket = socket;
    this.list = list;
  }

  /**
   * 线程run方法
   */
  @override
  public void run() {
    inetaddress address = socket.getinetaddress(); // 获取连接到服务器的这的客户端的地址
    string ip = address.gethostaddress();
    system.out.println(ip + "上线了!");
    if (ip.equals("192.168.1.117")) {
      synchronized (list) {
        sendtoall(ip + "由于违规操作,已被拉入黑名单!");
        list.remove(socket);
      }
      return;
    }

    try {
      bufferedreader br = new bufferedreader(new inputstreamreader(
          socket.getinputstream(), "gbk"));

      string line = "";
      while ((line = br.readline()) != null) {
        string msg = ip + ":" + line;
        system.out.println(msg); // 输出到服务器端的控制台
        // 把这个客户端说的话,发给其他所有的客户端
        sendtoall(msg);
      }

    } catch (ioexception e) {
      // e.printstacktrace();
      system.out.println(ip + "下线了!");
      synchronized (list) {
        list.remove(socket);
      }
    }
  }

  /**
   * 把信息发送给所有的客户端,去除当前socket
   * 
   * @param msg
   *      发送的信息
   */
  private void sendtoall(string msg) {
    synchronized (list) {
      for (socket s : list) {
        if (s != socket) {
          try {
            printstream ps = new printstream(s.getoutputstream());
            ps.println();
          } catch (ioexception e) {
            e.printstacktrace();
          }
        }
      }
    }
  }

}

--> 注意:因为要实现客户端连接到服务端,即客户端要先找到服务端,所以服务端要先开启,再开启服务端...

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。