ALL is Well!
敏捷是一条很长的路,摸索着前进着
BlogJava
::
首页
::
新随笔
::
联系
::
聚合
::
管理
::
30 随笔 :: 23 文章 :: 71 评论 :: 0 Trackbacks
<
2024年11月
>
日
一
二
三
四
五
六
27
28
29
30
31
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
1
2
3
4
5
6
7
公告
声明:
本博客文章如无特别注明,均为原创,作者保留所有权利!欢迎转载,转载请注明出处
BlogJava
。
常用链接
我的随笔
我的文章
我的评论
我的参与
最新评论
留言簿
(3)
给我留言
查看公开留言
查看私人留言
随笔分类
Freemarker(4)
(rss)
J2EE(3)
(rss)
J2SE(3)
(rss)
Java(16)
(rss)
JUnit(2)
(rss)
Linux(1)
(rss)
Maven2(8)
(rss)
MyBatis/iBatis(1)
(rss)
POI(1)
(rss)
Quartz(1)
(rss)
Spring(7)
(rss)
Struts2(3)
(rss)
TDD
(rss)
敏捷开发
(rss)
随笔档案
2011年4月 (2)
2011年3月 (2)
2010年12月 (4)
2010年11月 (3)
2010年10月 (5)
2010年9月 (26)
文章分类
J2EE(1)
(rss)
J2SE(3)
(rss)
JavaScript(1)
(rss)
MyBatis/iBatis
(rss)
POI
(rss)
技术知识(6)
(rss)
数据库(1)
(rss)
经验点滴(1)
(rss)
随笔
(rss)
文章档案
2010年12月 (1)
2010年9月 (10)
交流社区
CSDN
eoe(Android开发)
JavaEye
友情链接
Daniel Teng's blog
Max On Java
我在CSDN的家
胡奇的专栏
学习资源库
Maven -Available Plugins
maven repository
得益网
搜索
最新评论
1. re: JUnit单元测试Mock技术之jMock用法介绍
JMockService是啥?
--pjl
2. re: 通过Spring实现对自定义注解属性进行资源注入
ffhty
--如烦人烦人
3. re: 详细描述 快速排序 的过程 附Java实现
误人子弟啊!
--哥哥
4. re: POI3.6 生成Excel2007 效率低的解决办法
本来就应该这样写,而且可以直接在构造方法中实例化这些样式,然而即使这样也没有根本性的解决问题。当数据量稍微大些,多用户操作的时候就不知道怎么死的了。
--老左
5. re: Java SSH远程执行Shell脚本实现
请问如果脚本中的命令为top的话请问该怎么返回执行结果呢?
--tlone
阅读排行榜
1. MyEclipse的Maven插件 安装与配置(17781)
2. java代码实现利用 classloader 动态加载 jar包、文件夹到classpath中(13685)
3. Java SSH远程执行Shell脚本实现(13587)
4. JUnit4用法详解(13195)
5. JUnit单元测试Mock技术之jMock用法介绍(12054)
评论排行榜
1. 扩展Spring-实现对外部引用的属性文件进行加密、解密(8)
2. Java SSH远程执行Shell脚本实现(7)
3. MyEclipse的Maven插件 安装与配置(7)
4. freemarker数字格式化引入的问题(6)
5. iBatis/MyBatis 主子表关联查询(5)
java socket/swing聊天程序
很久以前写的程序,搬过来做个备忘:
服务器端代码:
1
package
com.test.talk;
2
3
import
java.awt.BorderLayout;
4
import
java.awt.FlowLayout;
5
import
java.awt.event.ActionEvent;
6
import
java.awt.event.ActionListener;
7
import
java.awt.event.WindowAdapter;
8
import
java.awt.event.WindowEvent;
9
import
java.io.DataInputStream;
10
import
java.io.DataOutputStream;
11
import
java.io.IOException;
12
import
java.net.BindException;
13
import
java.net.ServerSocket;
14
import
java.net.Socket;
15
import
java.util.LinkedList;
16
import
java.util.List;
17
18
import
javax.swing.JButton;
19
import
javax.swing.JFrame;
20
import
javax.swing.JLabel;
21
import
javax.swing.JPanel;
22
import
javax.swing.JTextField;
23
24
public
class
Server
extends
JFrame
25
{
26
boolean
started
=
false
;
27
28
private
ServerSocket ss
=
null
;
29
30
private
List clientList
=
new
LinkedList();
31
32
private
JLabel portLbl
=
null
;
33
34
private
JTextField portTxt
=
null
;
35
36
private
JButton portSetBtn
=
null
;
37
38
private
String port
=
null
;
39
40
private
JButton startBtn
=
null
;
41
42
private
JButton stopBtn
=
null
;
43
44
private
JPanel mainPanle
=
null
;
45
46
private
JPanel headPanle
=
null
;
47
48
public
static
void
main(String[] args)
49
{
50
new
Server();
51
}
52
53
public
Server()
54
{
55
headPanle
=
new
JPanel(
new
FlowLayout(FlowLayout.LEFT));
56
portLbl
=
new
JLabel(
"
PORT
"
);
57
portTxt
=
new
JTextField(
7
);
58
portSetBtn
=
new
JButton(
"
OK
"
);
59
portSetBtn.addActionListener(
new
ActionListener()
60
{
61
public
void
actionPerformed(ActionEvent e)
62
{
63
if
(portTxt.getText().matches(
"
\\d+
"
))
64
{
65
port
=
portTxt.getText();
66
startBtn.setEnabled(
true
);
67
stopBtn.setEnabled(
true
);
68
}
69
else
70
{
71
javax.swing.JOptionPane.showMessageDialog(
null
,
"
port be inputted is illegal
"
);
72
}
73
}
74
}
);
75
headPanle.add(portLbl);
76
headPanle.add(portTxt);
77
headPanle.add(portSetBtn);
78
getContentPane().add(headPanle, BorderLayout.NORTH);
79
startBtn
=
new
JButton(
"
Start
"
);
80
stopBtn
=
new
JButton(
"
Stop
"
);
81
startBtn.setEnabled(
false
);
82
stopBtn.setEnabled(
false
);
83
mainPanle
=
new
JPanel(
new
FlowLayout(FlowLayout.CENTER));
84
startBtn.addActionListener(
new
StartClickListener());
85
86
stopBtn.addActionListener(
new
ActionListener()
87
{
88
public
void
actionPerformed(ActionEvent e)
89
{
90
started
=
false
;
91
clientList.clear();
92
try
93
{
94
if
(ss
!=
null
)
95
{
96
ss.close();
97
}
98
}
99
catch
(IOException e1)
100
{
101
e1.printStackTrace();
102
}
103
}
104
}
);
105
mainPanle.add(startBtn);
106
mainPanle.add(stopBtn);
107
getContentPane().add(mainPanle, BorderLayout.CENTER);
108
109
addWindowListener(
new
WindowAdapter()
110
{
111
public
void
windowClosing(WindowEvent e)
112
{
113
started
=
false
;
114
clientList.clear();
115
try
116
{
117
if
(ss
!=
null
)
118
{
119
ss.close();
120
}
121
}
122
catch
(IOException e1)
123
{
124
e1.printStackTrace();
125
}
126
System.exit(
0
);
127
}
128
}
);
129
130
this
.setSize(
300
,
300
);
131
setLocation(
100
,
100
);
132
pack();
133
setVisible(
true
);
134
}
135
136
private
void
start()
137
{
138
try
139
{
140
ss
=
new
ServerSocket(Integer.parseInt(port));
141
started
=
true
;
142
}
143
catch
(BindException be)
144
{
145
javax.swing.JOptionPane.showMessageDialog(
null
,
"
port is useing by others
"
);
146
}
147
catch
(IOException e)
148
{
149
javax.swing.JOptionPane.showMessageDialog(
null
,
"
connect server fail
"
);
150
}
151
try
152
{
153
while
(started)
154
{
155
Socket s
=
ss.accept();
156
ClientImpl cr
=
new
ClientImpl(s);
157
new
Thread(cr).start();
158
clientList.add(cr);
159
System.out.println(
"
System Info:
"
+
s.getInetAddress()
+
"
connect successfully
"
);
160
}
161
}
162
catch
(IOException e)
163
{
164
System.out.println(
"
Client closed!
"
);
165
}
166
}
167
168
class
ClientImpl
implements
Runnable
169
{
170
private
Socket s;
171
172
private
DataInputStream dis
=
null
;
173
174
private
DataOutputStream dos
=
null
;
175
176
boolean
bConnect
=
false
;
177
178
public
ClientImpl(Socket s)
179
{
180
this
.s
=
s;
181
try
182
{
183
dis
=
new
DataInputStream(s.getInputStream());
184
dos
=
new
DataOutputStream(s.getOutputStream());
185
bConnect
=
true
;
186
}
187
catch
(IOException e)
188
{
189
e.printStackTrace();
190
}
191
}
192
193
private
void
send(String str)
194
{
195
try
196
{
197
dos.writeUTF(str);
198
}
199
catch
(IOException e)
200
{
201
e.printStackTrace();
202
}
203
204
}
205
206
public
void
run()
207
{
208
ClientImpl cr
=
null
;
209
try
210
{
211
while
(bConnect)
212
{
213
String str
=
dis.readUTF();
214
System.out.println(str);
215
for
(
int
i
=
0
; i
<
clientList.size(); i
++
)
216
{
217
cr
=
(ClientImpl) clientList.get(i);
218
cr.send(str);
219
}
220
}
221
}
222
catch
(Exception e)
223
{
224
clientList.remove(cr);
225
System.out.println(s.getInetAddress()
+
"
has leaved
"
);
226
}
227
finally
228
{
229
try
230
{
231
if
(dis
!=
null
)
232
dis.close();
233
if
(dos
!=
null
)
234
dos.close();
235
if
(s
!=
null
)
236
{
237
s.close();
238
s
=
null
;
239
}
240
}
241
catch
(IOException io)
242
{
243
io.printStackTrace();
244
}
245
}
246
}
247
}
248
249
class
StartClickListener
implements
Runnable, ActionListener
250
{
251
public
void
actionPerformed(ActionEvent e)
252
{
253
new
Thread(
this
).start();
254
}
255
256
public
void
run()
257
{
258
start();
259
}
260
}
261
}
262
客户端代码:
1
package
com.test.talk;
2
3
import
java.awt.BorderLayout;
4
import
java.awt.FlowLayout;
5
import
java.awt.event.ActionEvent;
6
import
java.awt.event.ActionListener;
7
import
java.awt.event.WindowAdapter;
8
import
java.awt.event.WindowEvent;
9
import
java.io.DataInputStream;
10
import
java.io.DataOutputStream;
11
import
java.io.IOException;
12
import
java.net.Socket;
13
import
java.net.UnknownHostException;
14
15
import
javax.swing.JButton;
16
import
javax.swing.JFrame;
17
import
javax.swing.JLabel;
18
import
javax.swing.JPanel;
19
import
javax.swing.JTextArea;
20
import
javax.swing.JTextField;
21
22
/** */
/**
23
* Client
24
*
25
*
@author
hx0272
26
*
27
*/
28
public
class
Client
29
{
30
public
static
void
main(String[] args)
31
{
32
ClientFrame frame
=
new
ClientFrame();
33
}
34
}
35
36
class
ClientFrame
extends
JFrame
37
{
38
private
JPanel mainPanel;
39
40
private
JPanel headPanel;
41
42
private
JPanel footPanel;
43
44
private
JTextArea showArea;
45
46
private
JTextField inputTxt;
47
48
private
JLabel portLbl;
49
50
private
JLabel ipLbl;
51
52
private
JLabel nameLbl;
53
54
private
JTextField portTxt;
55
56
private
JTextField ipTxt;
57
58
private
JTextField nameTxt;
59
60
private
JButton submitBtn;
61
62
private
JButton nameBtn;
63
64
private
JButton loginBtn;
65
66
private
Socket clientSocket
=
null
;
67
68
private
DataOutputStream dos
=
null
;
69
70
private
DataInputStream dis
=
null
;
71
72
private
boolean
bConnect
=
false
;
73
74
private
String name
=
""
;
75
76
public
ClientFrame()
77
{
78
init();
79
}
80
81
private
void
init()
82
{
83
//
main panel Begin
84
mainPanel
=
new
JPanel();
85
showArea
=
new
JTextArea(
15
,
80
);
86
showArea.setEditable(
false
);
87
mainPanel.add(showArea);
88
getContentPane().add(mainPanel, BorderLayout.CENTER);
89
//
main panel End
90
91
//
head panel Begin
92
headPanel
=
new
JPanel(
new
FlowLayout(FlowLayout.LEFT));
93
portLbl
=
new
JLabel(
"
PORT
"
);
94
portTxt
=
new
JTextField(
7
);
95
ipLbl
=
new
JLabel(
"
IP
"
);
96
ipTxt
=
new
JTextField(
25
);
97
98
nameLbl
=
new
JLabel(
"
name
"
);
99
100
nameTxt
=
new
JTextField(
15
);
101
102
nameBtn
=
new
JButton(
"
OK
"
);
103
104
loginBtn
=
new
JButton(
"
login
"
);
105
nameBtn.addActionListener(
new
ActionListener()
106
{
107
public
void
actionPerformed(ActionEvent e)
108
{
109
String tmp
=
nameTxt.getText();
110
if
(tmp
!=
null
||
!
tmp.equals(
""
))
111
{
112
int
id
=
javax.swing.JOptionPane.showConfirmDialog(
null
,
"
yes or no
"
,
"
choose yes
"
,
113
javax.swing.JOptionPane.OK_OPTION);
114
if
(id
==
0
)
115
{
116
name
=
nameTxt.getText();
117
loginBtn.setEnabled(
true
);
118
nameBtn.setEnabled(
false
);
119
}
120
}
121
}
122
}
);
123
headPanel.add(portLbl);
124
headPanel.add(portTxt);
125
headPanel.add(ipLbl);
126
headPanel.add(ipTxt);
127
128
headPanel.add(loginBtn);
129
headPanel.add(nameLbl);
130
headPanel.add(nameTxt);
131
headPanel.add(nameBtn);
132
loginBtn.setEnabled(
false
);
133
loginBtn.addActionListener(
new
ButtonClickAction());
134
getContentPane().add(headPanel, BorderLayout.NORTH);
135
//
head panel End
136
137
//
foot panel Begin
138
footPanel
=
new
JPanel(
new
FlowLayout(FlowLayout.LEFT));
139
inputTxt
=
new
JTextField(
70
);
140
submitBtn
=
new
JButton(
"
submit
"
);
141
142
footPanel.add(inputTxt);
143
footPanel.add(submitBtn);
144
145
submitBtn.addActionListener(
new
ButtonClickAction());
146
submitBtn.setEnabled(
false
);
147
getContentPane().add(footPanel, BorderLayout.SOUTH);
148
//
foot panel End
149
150
addWindowListener(
new
WindowAdapter()
151
{
152
public
void
windowClosing(WindowEvent e)
153
{
154
disConnect();
155
System.exit(
0
);
156
}
157
}
);
158
159
this
.setSize(
300
,
300
);
160
setLocation(
100
,
100
);
161
pack();
162
setVisible(
true
);
163
}
164
165
/** */
/**
166
* login button / submit button action listener
167
*
168
*
@author
hx0272
169
*
170
*/
171
class
ButtonClickAction
implements
ActionListener
172
{
173
public
void
actionPerformed(ActionEvent e)
174
{
175
if
(
"
submit
"
.equals(e.getActionCommand()))
176
{
177
String str
=
inputTxt.getText().trim();
178
inputTxt.setText(
""
);
179
sendToServer(str);
180
}
181
else
if
(
"
login
"
.equals(e.getActionCommand()))
182
{
183
connect();
184
}
185
}
186
}
187
188
/** */
/**
189
* enter be inputted event
190
*
191
*
@author
hx0272
192
*/
193
class
EnterClickAction
implements
ActionListener
194
{
195
public
void
actionPerformed(ActionEvent e)
196
{
197
String str
=
inputTxt.getText().trim();
198
inputTxt.setText(
""
);
199
sendToServer(str);
200
}
201
}
202
203
/** */
/**
204
* send message to server
205
*
206
*
@author
hx0272
207
*/
208
private
void
sendToServer(String str)
209
{
210
try
211
{
212
dos.writeUTF(name
+
"
:
"
+
str);
213
dos.flush();
214
}
215
catch
(IOException e)
216
{
217
e.printStackTrace();
218
}
219
}
220
221
/** */
/**
222
* close resource
223
*
224
*
@author
hx0272
225
*/
226
private
void
disConnect()
227
{
228
try
229
{
230
//
clientSocket.close();
231
//
232
//
dos.close();
233
234
bConnect
=
false
;
235
}
236
catch
(Exception e)
237
{
238
e.printStackTrace();
239
}
240
}
241
242
/** */
/**
243
* receive message from server
244
*
245
*
@author
hx0272
246
*/
247
private
class
Receive
implements
Runnable
248
{
249
public
void
run()
250
{
251
try
252
{
253
while
(bConnect)
254
{
255
String str
=
dis.readUTF();
256
showArea.setText(showArea.getText()
+
str
+
'
\n
'
);
257
}
258
}
259
catch
(IOException e)
260
{
261
javax.swing.JOptionPane.showMessageDialog(
null
,
"
connect server error
"
);
262
}
263
264
}
265
}
266
267
/** */
/**
268
* connection begin
269
*
270
*
@author
hx0272
271
*/
272
private
void
connect()
273
{
274
try
275
{
276
if
(ipTxt.getText().matches(
"
\\d{1,3}.\\d{1,3}.\\d{1,3}.\\d{1,3}
"
)
&&
portTxt.getText().matches(
"
\\d+
"
))
277
{
278
clientSocket
=
new
Socket(ipTxt.getText(), Integer.parseInt(portTxt.getText()));
279
dos
=
new
DataOutputStream(clientSocket.getOutputStream());
280
dis
=
new
DataInputStream(clientSocket.getInputStream());
281
bConnect
=
true
;
282
new
Thread(
new
Receive()).start();
283
System.out.println(
"
I am coming
"
);
284
javax.swing.JOptionPane.showMessageDialog(
null
,
"
connect server success
"
);
285
submitBtn.setEnabled(
true
);
286
inputTxt.addActionListener(
new
EnterClickAction());
287
}
288
else
289
{
290
javax.swing.JOptionPane.showMessageDialog(
null
,
"
port or ip be inputted is illegal
"
);
291
}
292
}
293
catch
(UnknownHostException uhe)
294
{
295
javax.swing.JOptionPane.showMessageDialog(
null
,
"
connect server error
"
);
296
}
297
catch
(IOException e)
298
{
299
javax.swing.JOptionPane.showMessageDialog(
null
,
"
connect server error
"
);
300
}
301
}
302
}
303
使用说明:
1.先运行服务器端程序,设定好端口号
2.点击Start按钮,运行服务器
3.运行客户端程序
4.设定好昵称
5.设定与服务器端匹配的端口号和服务器的ip地址
6.点击Login按钮,登录到聊天系统
7.可以聊天了。
----2008年11月24日
posted on 2010-09-01 10:40
李 明
阅读(870)
评论(0)
编辑
收藏
所属分类:
J2SE
、
Java
新用户注册
刷新评论列表
只有注册用户
登录
后才能发表评论。
网站导航:
博客园
IT新闻
知识库
C++博客
博问
管理
相关文章:
Swing 线程之SwingUtilities.invokeLater()
继承JButton,做一个圆形的按钮。
java socket/swing聊天程序
Powered by:
BlogJava
Copyright © 李 明