java多人聊天室系统代码实现步骤,java实现聊天室功能(包含全部代码,有界面)

  java多人聊天室系统代码实现步骤,java实现聊天室功能(包含全部代码,有界面)

  本文实例为大家分享了爪哇实现多人聊天室的具体代码,供大家参考,具体内容如下

  先说,记录本人的学习过程,当笔记了

  多人聊天室分为

  

1.服务器

.正在…循环(管波)每连接一个用户就记录一个用户的属性。.定义一个存储用户的类我的口袋.接收信息(服务器线程)并发给每一位用户不需要再次发给自己

 

  

2.客户机

.线程(克里斯)接收数据添加到文本框。.秋千(可折叠)做界面。

 

  代码如下:

  先客户机吧简单点

  导入javax。挥棒。*;导入Java。awt。*;导入Java。awt。事件。动作事件;导入Java。io。*;导入Java。网。插座;导入Java。时间。日期时间异常;类CilThr扩展线程{ Socket Socket textarea tap public cil thr(Socket Socket,JTextArea ta){//获取客户端的窝和文本区域this . socket=socket this . ta=ta } @ Override公共void run() { while (true){//一直在接收中请尝试{ InputStream InputStream=套接字。getinputstream();//字节输入流数据输入流din=新数据输入流(输入流);//数据输入流字符串text=din。读取utf();//获取输入的数据ta.append(文本);//添加到文本区域} catch(io异常e){ e . printstacktrace();} } } }公共类kefu duang { JFrame jjlabel jLabelJTextField tf1,tf2JButton开始,发送;JTextArea taSocket套接字=新套接字( localhost ,9000);//连接服务器需要的端口号9000公共课教室()抛出IOException { jf=new JFrame(客户端);jLabel=新jLabel(用户名);tf1=new JTextField(15);tf2=new JTextField(35);start=new JButton(连接);send=new JButton(发送);ta=新JTextArea(40,40);init();//调用方法实现界面} public void init(){ JPanel jp1=new JPanel();JPanel jp2=new JPanel();JPanel jp3=new JPanel();ta。设置可编辑(false);//让文本框不能输入,只是显示出来发送。set enabled(假);//设置发送按钮,不能按,因为还没有连接上服务器jp1。添加(jLabel);jp1。添加(tf1);jp1.add(开始);jp2。添加(ta);jp2.add(新的JScrollPane(ta,JScrollPane .垂直滚动条总是水平_滚动条_总是));//设置文本区域的滚动条jp3。添加(tf2);jp3.add(发送);jf.add(jp1,BorderLayout .北);//设置布局jf.add(jp2,BorderLayout .中心);jf.add(jp3,BorderLayout .南);JF。设置可见(真);JF。setlocationrelativeto(null);jf.setSize(500,

  500);        jf.setDefaultCloseOperation(JFrame.DISPOSE_ON_CLOSE);                handler();//添加按钮监听        new CilThr(socket,ta).start();//接收其他客户端发来的信息    }    private void handler() {        start.addActionListener(new AbstractAction() {//连接            @Override            public void actionPerformed(ActionEvent e) {                //发起连接                String user= tf1.getText();//获取用户名                System.out.println(user+"发起连接请求");                try {                    OutputStream outputStream=socket.getOutputStream();//字节输出流                    DataOutputStream dout=new DataOutputStream(outputStream);//数据输出流                    dout.writeUTF(user+" 加入聊天");//.writeUTF里的内容输出到文本里                    ta.append(user+" 加入聊天"+"n");//添加到显示的文本区域                    send.setEnabled(true);//再设置“发送”按钮可以被点击                } catch (IOException ex) {                    ex.printStackTrace();                }                //接收            }        });        send.addActionListener(new AbstractAction() {//“发送”按钮            @Override            public void actionPerformed(ActionEvent e) {                try {                    OutputStream outputStream=socket.getOutputStream();//字节输出流                    DataOutputStream dout=new DataOutputStream(outputStream);//数据输出流                    String text=tf2.getText();//获取待发送文本框的内容                    dout.writeUTF(text);//输出到文件                    ta.append("我说: "+text+"n");//添加到显示的文本区域                    tf2.setText("");//设置下一次需要输入文本框的内容为空                } catch (IOException ex) {                    ex.printStackTrace();                }            }        });    }    public static void main(String[] args) throws IOException {        new kefuduang(); //调用构造方法 出界面    }}下面是服务器:

  

import java.io.*;import java.net.ServerSocket;import java.net.Socket;import java.util.ArrayList;import java.util.Date;class ServerThread extends Thread{    Socket socket;    ArrayList<MySocket> sockets;    public ServerThread(Socket socket, ArrayList<MySocket> sockets) {//获取主函数传过来的值        this.socket=socket;        this.sockets=sockets;    }    @Override    public void run() {        while(true){//接收一个用户的多次发送信息            try {                InputStream inputStream=socket.getInputStream();//字节输入流                DataInputStream din=new DataInputStream(inputStream);//数据输入流                String text=din.readUTF();//获取输入的信息                String user="";//设置当前用户名为空,以防下一次赋值                for(int i=0;i<sockets.size();i++){//遍历sockets集合                    if(socket==sockets.get(i).getSocket()){//判断当前发放信息的用户                        user=sockets.get(i).getUser();//获取当前发放信息的用户名                    }                }                for(int i=0;i<sockets.size();i++){                    Socket sc=sockets.get(i).getSocket();//获取每个用户的socket                    if(sc!=socket){//判断 不需要自己发信息给自己                        OutputStream outputStream=sc.getOutputStream();//字节输出流                        DataOutputStream dout=new DataOutputStream(outputStream);//数据输出流                        dout.writeUTF(user+":"+text+"n");//把当前客户端的名字和信息发送给除自己以外的其他客户端                    }                }            } catch (IOException e) {                e.printStackTrace();            }        }    }}class MySocket{//把每一台客户端的socket 和用户名联系起来   private Socket socket;//客户端的socket   private String user;//客户名    public MySocket(Socket socket, String user) {        this.socket=socket;        this.user=user;    }    public Socket getSocket() {        return socket;    }    public void setSocket(Socket socket) {        this.socket = socket;    }    public String getUser() {        return user;    }    public void setUser(String user) {        this.user = user;    }}public class guanbo {    static ArrayList<MySocket> sockets=new ArrayList<MySocket>();//定义一个静态的集合里面的类型是class类 MySocket    public static void main(String[] args) throws IOException {        ServerSocket ss=new ServerSocket(9000);//服务器的端口号为9000        System.out.println("服务器准备就绪");        while(true){//收集每一次客户端的连接            Socket socket=ss.accept();            System.out.println("响应请求");            //每响应一个客户端就产生一个myscokcet            InputStream inputStream=socket.getInputStream();//字节输入流            DataInputStream din=new DataInputStream(inputStream);//数据输入流            String user=din.readUTF();//获取客户端的名称             user=user.substring(0,user.length()-4);//把客户端的名字获取,删除“加入聊天”            MySocket ms=new MySocket(socket,user);//把用户的名字和socket放到MyScket里            sockets.add(ms);//再添加到集合里,这样就可以保存每一个客户端的名字和socket            new ServerThread(socket,sockets).start();//启动线程 把当前客户端的socket和加入到服务器的所有socket传到线程通过构造器,并开启线程run方法        }    }}

运行结果:

 

  

 

  

 

  先开服务器,再开客户端!

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

郑重声明:本文由网友发布,不代表盛行IT的观点,版权归原作者所有,仅为传播更多信息之目的,如有侵权请联系,我们将第一时间修改或删除,多谢。

留言与评论(共有 条评论)
   
验证码: