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

java socket实现聊天室 java实现多人聊天功能

程序员文章站 2024-02-21 21:32:07
用java socket做一个聊天室,实现多人聊天的功能。看了极客学院的视频后跟着敲的。(1day) 服务端: 1. 先写服务端的类myserversock...

用java socket做一个聊天室,实现多人聊天的功能。看了极客学院的视频后跟着敲的。(1day)

服务端:

1. 先写服务端的类myserversocket,里面放一个监听线程,一启动就好
2. 实现服务端监听类serverlistener.java,用accept来监听,一旦有客户端连上,生成新的socket,就新建个线程实例chatsocket。启动线程后就把线程交给chatmanager管理
3. 在chatsocket中实现从客户端读取内容,把读取到的内容发给集合内所有的客户端
4. chatmanager里面用vector来管理socket线程实例chatsocket,并实现发送信息给其他的客户端

客户端:

1. 新建一个继承jframe的mainwindow.java类,主要实现聊天窗口的ui,以及事件响应。
2. 新建startclient.java类,把mainwindow中生成mainwindow主方法部分代码拷贝过来,这样就能在主程序中把窗体执行出来了。
3. 新建chatmanager(需要单例化的类)管理socket,实现聊天的输入输出功能。最后记得在1中新建窗口后,传一份frame的引用到chatmanager中,才能实现chatmanager对界面的显示。

工程结构如图

java socket实现聊天室 java实现多人聊天功能

以下为代码

服务端:

1. 先写服务端的类myserversocket,里面放一个监听线程,一启动就好

package com.starnet.testserversocket.main;


public class myserversocket {
  public static void main(string[] args) {
    new serverlistener().start();
  }
}

2.实现服务端监听类serverlistener.java,用accept来监听,一旦有客户端连上,生成新的socket,就新建个线程实例chatsocket。启动线程后就把线程交给chatmanager管理

package com.starnet.testserversocket.main;

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

import javax.swing.joptionpane;

public class serverlistener extends thread {
  public void run() {
    try {
      serversocket serversocket = new serversocket(23456);
      while (true) {
        // block
        socket socket = serversocket.accept();
        // 建立链接 
        joptionpane.showmessagedialog(null, "有客户端连到本机23456端口");
        //将socket传递给新的线程
        chatsocket cs= new chatsocket(socket);
        cs.start();
        chatmanager.getchatmanager().add(cs);
      }
    } catch (ioexception e) {
      e.printstacktrace();
    }
  }
}

3.在chatsocket中实现从客户端读取内容,把读取到的内容发给集合内所有的客户端

package com.starnet.testserversocket.main;

import java.io.bufferedreader;
import java.io.ioexception;
import java.io.inputstreamreader;
import java.io.unsupportedencodingexception;
import java.net.socket;
/*每一个连上的客户端,服务器都有一个线程为之服务*/
public class chatsocket extends thread {
  socket socket;

  public chatsocket(socket s) {
    this.socket = s;
  }

  //发送数据
  public void out(string out) {
    try {
      socket.getoutputstream().write(out.getbytes("utf-8"));
    } catch (unsupportedencodingexception e) {
      // todo auto-generated catch block
      e.printstacktrace();
    } catch (ioexception e) {
      // todo auto-generated catch block
      e.printstacktrace();
    }
  }

  //服务器会不断地从客户端读取内容,把读取到的内容发给集合内所有的客户端。
  public void run() {
    try {
      //接收数据
      bufferedreader br = new bufferedreader(
          new inputstreamreader(
              socket.getinputstream(), "utf-8"));
      string line=null;
      //发送读到的内容
      while ((line = br.readline())!=null) {
        system.out.println(line);
        chatmanager.getchatmanager().publish(this, line);
      }
      br.close();
    } catch (ioexception e) {
      // todo auto-generated catch block
      e.printstacktrace();
    }
  }
}

4.chatmanager里面用vector来管理socket线程实例chatsocket,并实现发送信息给其他的客户端

package com.starnet.testserversocket.main;

import java.util.vector;
//一个聊天服务器只能有一个manager,要单例化处理
public class chatmanager {
  private chatmanager(){}
  private static final chatmanager cm=new chatmanager();
  public static chatmanager getchatmanager(){
    return cm;
  }

  vector<chatsocket> vector = new vector<chatsocket>();
  /*增加chatsocket 实例到vector中*/
  public void add(chatsocket cs){
    vector.add(cs);
  }

  /*发布消息给其他客户端
   *chatsocket cs: 调用publish的线程
   *msg:要发送的信息 */
  public void publish(chatsocket cs, string msg){
    for (int i = 0; i < vector.size(); i++) {
      chatsocket cstemp = vector.get(i);
      if (!cs.equals(cstemp)) {
        cstemp.out(msg+"\n");//不用发送给自己。
      }
    }
  }

}

客户端:

1. 新建一个继承jframe的mainwindow.java类,主要实现聊天窗口的ui,以及事件响应。

package com.starnet.javaclient.view;

import java.awt.borderlayout;
import java.awt.eventqueue;

import javax.swing.jframe;
import javax.swing.jpanel;
import javax.swing.border.emptyborder;
import javax.swing.jtextarea;
import javax.swing.grouplayout;
import javax.swing.grouplayout.alignment;
import javax.swing.jtextfield;
import javax.swing.jbutton;
import javax.swing.layoutstyle.componentplacement;

import com.starnet.javaclient.main.chatmanager;
import com.sun.xml.internal.ws.client.senderexception;

import java.awt.event.mouseadapter;
import java.awt.event.mouseevent;

public class mainwindow extends jframe {

  /**
   * 
   */
  private static final long serialversionuid = 1l;
  private jpanel contentpane;
  private jtextarea txt;
  private jtextfield txtip;
  private jtextfield txtsend;

  /**
   * create the frame.
   */
  public mainwindow() {
    setalwaysontop(true);
    setdefaultcloseoperation(jframe.exit_on_close);
    setbounds(100, 100, 450, 300);
    contentpane = new jpanel();
    contentpane.setborder(new emptyborder(5, 5, 5, 5));
    setcontentpane(contentpane);

    txt = new jtextarea();
    txt.settext("ready...");

    txtip = new jtextfield();
    txtip.settext("127.0.0.1");
    txtip.setcolumns(10);

    jbutton btnconnect = new jbutton("connect");
    btnconnect.addmouselistener(new mouseadapter() {
      @override
      public void mouseclicked(mouseevent e) {
        chatmanager.getchatmanager().connect(txtip.gettext());
      }
    });

    txtsend = new jtextfield();
    txtsend.settext("hello");
    txtsend.setcolumns(10);

    jbutton btnsend = new jbutton("send");
    btnsend.addmouselistener(new mouseadapter() {
      @override
      public void mouseclicked(mouseevent e) {
        chatmanager.getchatmanager().send(txtsend.gettext());
        appendtext("我说: "+txtsend.gettext());
        txtsend.settext("");
      }
    });
    grouplayout gl_contentpane = new grouplayout(contentpane);
    gl_contentpane.sethorizontalgroup(
      gl_contentpane.createparallelgroup(alignment.leading)
        .addgroup(alignment.trailing, gl_contentpane.createsequentialgroup()
          .addgroup(gl_contentpane.createparallelgroup(alignment.trailing)
            .addgroup(gl_contentpane.createsequentialgroup()
              .addcomponent(txtsend, grouplayout.default_size, 325, short.max_value)
              .addpreferredgap(componentplacement.related)
              .addcomponent(btnsend, grouplayout.preferred_size, 109, grouplayout.preferred_size))
            .addgroup(alignment.leading, gl_contentpane.createsequentialgroup()
              .addcomponent(txtip, grouplayout.preferred_size, 294, grouplayout.preferred_size)
              .addpreferredgap(componentplacement.related)
              .addcomponent(btnconnect, grouplayout.default_size, 140, short.max_value))
            .addcomponent(txt, grouplayout.default_size, 434, short.max_value))
          .addcontainergap())
    );
    gl_contentpane.setverticalgroup(
      gl_contentpane.createparallelgroup(alignment.leading)
        .addgroup(gl_contentpane.createsequentialgroup()
          .addgroup(gl_contentpane.createparallelgroup(alignment.baseline)
            .addcomponent(txtip, grouplayout.preferred_size, grouplayout.default_size, grouplayout.preferred_size)
            .addcomponent(btnconnect))
          .addpreferredgap(componentplacement.related)
          .addcomponent(txt, grouplayout.default_size, 198, short.max_value)
          .addpreferredgap(componentplacement.related)
          .addgroup(gl_contentpane.createparallelgroup(alignment.trailing)
            .addcomponent(btnsend)
            .addcomponent(txtsend, grouplayout.preferred_size, grouplayout.default_size, grouplayout.preferred_size)))
    );
    contentpane.setlayout(gl_contentpane);
  }
  /*客户端发送的内容添加到中间的txt控件中*/
  public void appendtext(string in) {
    txt.append("\n" + in);
  }
}

2.新建startclient.java类,把mainwindow中生成mainwindow主方法部分代码拷贝过来,这样就能在主程序中把窗体执行出来了。

package com.starnet.javaclient.main;

import java.awt.eventqueue;

import com.starnet.javaclient.view.mainwindow;

public class startclient {
  public static void main(string[] args) {
    /*先新建一个jframe,然后把自动生成的代码贴过来*/
    eventqueue.invokelater(new runnable() {
      public void run() {
        try {
          mainwindow frame = new mainwindow();
          frame.setvisible(true);
          //创建完这个frame以后,传一份window的引用到chatmanager去
          chatmanager.getchatmanager().setwindow(frame);
        } catch (exception e) {
          e.printstacktrace();
        }
      }
    });
  }
}

3.新建chatmanager(需要单例化的类)管理socket,实现聊天的输入输出功能。最后记得在1中新建窗口后,传一份frame的引用到chatmanager中,才能实现chatmanager对界面的显示。

package com.starnet.javaclient.main;

import java.io.bufferedreader;
import java.io.ioexception;
import java.io.inputstreamreader;
import java.io.outputstreamwriter;
import java.io.printwriter;
import java.net.socket;
import java.net.unknownhostexception;

import com.starnet.javaclient.view.mainwindow;

public class chatmanager {
  private chatmanager(){}
  private static final chatmanager instance=new chatmanager();
  public static chatmanager getchatmanager(){
    return instance;
  }
  mainwindow window;//为了能在界面上显示服务器发来的信息,就需要传一个mainwindow的引用进来
  socket socket;
  private string ip;
  bufferedreader breader;
  printwriter pwriter;
  public void setwindow(mainwindow window) {
    this.window = window;
    window.appendtext("文本框已经和chatmanager绑定了");
  }
  public void connect(string ip) {
    this.ip = ip;
    new thread(){

      @override
      public void run() {
        //实现网络方法
        try {
          socket = new socket(ip, 23456);
          //输出流
          pwriter = new printwriter(
              new outputstreamwriter(
                  socket.getoutputstream()));
          //输入流
          breader = new bufferedreader(
              new inputstreamreader(
                  socket.getinputstream()));

          string line = null;
          //如果读取数据为空
          while ((line = breader.readline())!=null) {
            window.appendtext("收到: "+line);
          }
          //读完数据之后要关闭
          pwriter.close();
          breader.close();
          pwriter = null;
          breader = null;

        } catch (unknownhostexception e) {
          e.printstacktrace();
        } catch (ioexception e) {
          e.printstacktrace();
        }
      }
    }.start();
  }

  public void send(string sendmsg){
    if (pwriter!=null) {
      pwriter.write(sendmsg+"\n");
      pwriter.flush();
    } else {
      window.appendtext("当前链接已经中断...");
    }
  }
}

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