个人中心
gpt4 book ai didi

java聊天室的实现代码

转载 作者：qq735679552 更新时间：2022-09-28 22:32:09 24 4
gpt4 key购买 nike

CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.

这篇CFSDN的博客文章java聊天室的实现代码由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.

本文实例为大家分享了java实现聊天室的具体代码，供大家参考，具体内容如下 。

聊天室界面:

java聊天室的实现代码

源码:

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
public class clientframe extends frame {
 
  private textfield textfieldcontent = new textfield();
  private textarea textareacontent = new textarea();
  private socket socket = null ;
  private outputstream out = null ;
  private dataoutputstream dos = null ;
  private inputstream in = null ;
  private datainputstream dis = null ;
  private boolean flag = false ;
 
  /**
   * 学校：山东师范大学 程序员：外力_victor 日期：2016年5月8日 上午9:19:51 功能：启动客户端程序
   *
   * @param args
   */
  public static void main(string[] args) {
   new clientframe().init();
  }
 
  /**
   * 学校：山东师范大学 程序员：外力_victor 日期：2016年5月8日 上午9:20:43 功能：对窗口进行初始化
   */
  private void init() {
   this .setsize( 300 , 300 );
   setlocation( 250 , 150 );
   setvisible( true );
   settitle( "wechatroom" );
 
   // 添加控件
   this .add(textareacontent);
   this .add(textfieldcontent, borderlayout.south);
   textareacontent.setfocusable( false );
   pack();
 
   // 关闭事件
   addwindowlistener( new windowadapter() {
    public void windowclosing(windowevent e) {
     system.out.println( "用户试图关闭窗口" );
     disconnect();
     system.exit( 0 );
    }
 
   });
   // textfieldcontent添加回车事件
   textfieldcontent.addactionlistener( new actionlistener() {
    public void actionperformed(actionevent e) {
     onclickenter();
    }
   });
 
   // 建立连接
   connect();
   new thread( new recivemessage()).start();
  }
 
  private class recivemessage implements runnable {
   @override
   public void run() {
    flag = true ;
    try {
     while (flag) {
      string message = dis.readutf();
      textareacontent.append(message + "\n" );
     }
    } catch (eofexception e) {
     flag = false ;
     system.out.println( "客户端已关闭" );
     // e.printstacktrace();
    } catch (socketexception e) {
     flag = false ;
     system.out.println( "客户端已关闭" );
     // e.printstacktrace();
    } catch (ioexception e) {
     flag = false ;
     system.out.println( "接受消息失败" );
     e.printstacktrace();
    }
   }
 
  }
 
  /**
   * 功能：当点击回车时出发的事件 学校：山东师范大学 程序员：外力_victor 日期：2016年5月8日 上午9:49:30
   */
  private void onclickenter() {
   string message = textfieldcontent.gettext().trim();
   if (message != null && !message.equals( "" )) {
    string time = new simpledateformat( "h:m:s" ).format( new date());
    textareacontent.append(time + "\n" + message + "\n" );
    textfieldcontent.settext( "" );
    sendmessagetoserver(message);
   }
  }
 
  /**
   * 功能：给服务器发送消息 学校：山东师范大学 程序员：外力_victor 日期：2016年5月8日 上午10:13:48
   *
   * @param message
   */
  private void sendmessagetoserver(string message) {
   try {
    dos.writeutf(message);
    dos.flush();
   } catch (ioexception e) {
    system.out.println( "发送消息失败" );
    e.printstacktrace();
   }
  }
 
  /**
   * 功能：申请socket链接 学校：山东师范大学 程序员：外力_victor 日期：2016年5月8日 上午10:00:38
   */
  private void connect() {
   try {
    socket = new socket( "localhost" , 8888 );
    out = socket.getoutputstream();
    dos = new dataoutputstream(out);
    in = socket.getinputstream();
    dis = new datainputstream(in);
   } catch (unknownhostexception e) {
    system.out.println( "申请链接失败" );
    e.printstacktrace();
   } catch (ioexception e) {
    system.out.println( "申请链接失败" );
    e.printstacktrace();
   }
  }
 
  /**
   * 功能：关闭流和链接 学校：山东师范大学 程序员：外力_victor 日期：2016年5月8日 上午10:01:32
   */
  private void disconnect() {
   flag = false ;
   if (dos != null ) {
    try {
     dos.close();
    } catch (ioexception e) {
     system.out.println( "dos关闭失败" );
     e.printstacktrace();
    }
   }
   if (out != null ) {
    try {
     out.close();
    } catch (ioexception e) {
     system.out.println( "dos关闭失败" );
     e.printstacktrace();
    }
   }
   if (socket != null ) {
    try {
     socket.close();
    } catch (ioexception e) {
     system.out.println( "socket关闭失败" );
     e.printstacktrace();
    }
    ;
   }
  }
 
}
?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
package com.chat;
 
import java.io.datainputstream;
import java.io.dataoutputstream;
import java.io.eofexception;
import java.io.ioexception;
import java.io.inputstream;
import java.io.outputstream;
import java.net.bindexception;
import java.net.serversocket;
import java.net.socket;
import java.net.socketexception;
import java.util.arraylist;
import java.util.list;
 
public class chatserver {
 
  private list<client> clients = new arraylist<>();
 
  /**
   * 功能：启动chatsever 学校：山东师范大学 程序员：外力_victor 日期：2016年5月8日 上午10:26:41
   *
   * @param args
   */
  public static void main(string[] args) {
   new chatserver().init();
  }
 
  /**
   * 功能：对chatserver初始化 学校：山东师范大学 程序员：外力_victor 日期：2016年5月8日 上午10:27:09
   */
  private void init() {
   system.out.println( "服务器已开启" );
   // bindexception
 
   serversocket ss = null ;
   socket socket = null ;
   try {
    ss = new serversocket( 8888 );
   } catch (bindexception e) {
    system.out.println( "端口已被占用" );
    e.printstacktrace();
   } catch (ioexception e1) {
    e1.printstacktrace();
   }
   try {
    client client = null ;
    while ( true ) {
     socket = ss.accept();
     system.out.println( "客户驾到" );
     client = new client(socket);
     clients.add(client);
     new thread(client).start();
    }
   } catch (ioexception e) {
    e.printstacktrace();
   }
  }
 
  private class client implements runnable {
   private socket socket = null ;
   inputstream in = null ;
   datainputstream din = null ;
   outputstream out = null ;
   dataoutputstream dos = null ;
   boolean flag = true ;
 
   public client(socket socket) {
    this .socket = socket;
    try {
     in = socket.getinputstream();
     din = new datainputstream(in);
    } catch (ioexception e) {
     system.out.println( "接受消息失败" );
     e.printstacktrace();
    }
 
   }
 
   public void run() {
 
    string message;
    try {
     while (flag) {
      message = din.readutf();
      // system.out.println("客户说：" + message);
      forwordtoallclients(message);
     }
    } catch (socketexception e) {
     flag = false ;
     system.out.println( "客户下线" );
     clients.remove( this );
     // e.printstacktrace();
    } catch (eofexception e) {
     flag = false ;
     system.out.println( "客户下线" );
     clients.remove( this );
     // e.printstacktrace();
    } catch (ioexception e) {
     flag = false ;
     system.out.println( "接受消息失败" );
     clients.remove( this );
     e.printstacktrace();
    }
 
    if (din != null ) {
     try {
      din.close();
     } catch (ioexception e) {
      system.out.println( "din关闭失败" );
      e.printstacktrace();
     }
    }
    if (in != null ) {
     try {
      in.close();
     } catch (ioexception e) {
      system.out.println( "din关闭失败" );
      e.printstacktrace();
     }
    }
    if (socket != null ) {
     try {
      socket.close();
     } catch (ioexception e) {
      system.out.println( "din关闭失败" );
      e.printstacktrace();
     }
    }
 
   }
 
   /**
    * 功能：转发给所有客户端 学校：山东师范大学 程序员：外力_victor 日期：2016年5月8日 上午11:11:59
    *
    * @param message
    * @throws ioexception
    */
   private void forwordtoallclients(string message) throws ioexception {
    for (client c : clients) {
     if (c != this ) {
      out = c.socket.getoutputstream();
      dos = new dataoutputstream(out);
      forwordtoclient(message);
     }
    }
   }
 
   /**
    * 功能：发送给一个客户端 学校：山东师范大学 程序员：外力_victor 日期：2016年5月8日 上午11:16:12
    *
    * @throws ioexception
    */
   private void forwordtoclient(string message) throws ioexception {
    dos.writeutf(message);
    dos.flush();
    system.out.println( "转发成功！" );
   }
 
  }
}

源码下载：java聊天室代码 。

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

原文链接：https://blog.csdn.net/qq_24082497/article/details/51347426 。

最后此篇关于java聊天室的实现代码的文章就讲到这里了,如果你想了解更多关于java聊天室的实现代码的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。

24 4 0
文章推荐： JGroups实现聊天小程序
文章推荐： spring boot 监控处理方案实例详解
文章推荐： java 记录一个子串在整串中出现的次数实例
文章推荐： 详解spring cloud分布式整合zipkin的链路跟踪
qq735679552
个人简介

我是一名优秀的程序员,十分优秀！

滴滴打车优惠券免费领取
滴滴打车优惠券
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com