本文实例讲述了java基于socket实现的客户端和服务端通信功能。分享给大家供大家参考，具体如下：
以下代码参考马士兵的聊天项目，先运行chatserver.java实现端口监听，然后再运行chatclient.java
客户端实例
chatclient.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
|
package socketdemo;
import java.awt.*;
import java.awt.event.*;
import java.io.*;
import java.net.*;
public class chatclient extends frame {
socket s = null;
dataoutputstream dos = null;
datainputstream dis = null;
private boolean bconnected = false;
textfield tftxt = new textfield();
textarea tacontent = new textarea();
thread trecv = new thread(new recvthread());
public static void main(string[] args) {
new chatclient().launchframe();
}
public void launchframe() {
setlocation(400, 300);
this.setsize(300, 300);
add(tftxt, borderlayout.south);
add(tacontent, borderlayout.north);
pack();
this.addwindowlistener(new windowadapter() {
@override
public void windowclosing(windowevent arg0) {
disconnect();
system.exit(0);
}
});
tftxt.addactionlistener(new tflistener());
setvisible(true);
connect();
trecv.start();
}
public void connect() {
try {
s = new socket("localhost", 8888);
dos = new dataoutputstream(s.getoutputstream());
dis = new datainputstream(s.getinputstream());
system.out.println("connected!");
bconnected = true;
} catch (unknownhostexception e) {
e.printstacktrace();
} catch (ioexception e) {
e.printstacktrace();
}
}
public void disconnect() {
try {
dos.close();
dis.close();
s.close();
} catch (ioexception e) {
e.printstacktrace();
}
/*
* try { bconnected = false; trecv.join(); } catch(interruptedexception
* e) { e.printstacktrace(); } finally { try { dos.close(); dis.close();
* s.close(); } catch (ioexception e) { e.printstacktrace(); } }
*/
}
private class tflistener implements actionlistener {
public void actionperformed(actionevent e) {
string str = tftxt.gettext().trim();
// tacontent.settext(str);
tftxt.settext("");
try {
// system.out.println(s);
dos.writeutf(str);
dos.flush();
// dos.close();
} catch (ioexception e1) {
e1.printstacktrace();
}
}
}
private class recvthread implements runnable {
public void run() {
try {
while (bconnected) {
string str = dis.readutf();
// system.out.println(str);
tacontent.settext(tacontent.gettext() + str + '\n');
}
} catch (socketexception e) {
system.out.println("退出了，bye!");
} catch (eofexception e) {
system.out.println("推出了，bye - bye!");
} catch (ioexception e) {
e.printstacktrace();
}
}
}
}
|
socket服务端代码
chatserver.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
|
package socketdemo;
import java.io.*;
import java.net.*;
import java.util.*;
public class chatserver {
boolean started = false;
serversocket ss = null;
list<client> clients = new arraylist<client>();
public static void main(string[] args) {
new chatserver().start();
}
public void start() {
try {
ss = new serversocket(8888);
started = true;
} catch (bindexception e) {
system.out.println("端口使用中....");
system.out.println("请关掉相关程序并重新运行服务器！");
system.exit(0);
} catch (ioexception e) {
e.printstacktrace();
}
try {
while (started) {
socket s = ss.accept();
client c = new client(s);
system.out.println("a client connected!");
new thread(c).start();
clients.add(c);
// dis.close();
}
} catch (ioexception e) {
e.printstacktrace();
} finally {
try {
ss.close();
} catch (ioexception e) {
// todo auto-generated catch block
e.printstacktrace();
}
}
}
class client implements runnable {
private socket s;
private datainputstream dis = null;
private dataoutputstream dos = null;
private boolean bconnected = false;
public client(socket s) {
this.s = s;
try {
dis = new datainputstream(s.getinputstream());
dos = new dataoutputstream(s.getoutputstream());
bconnected = true;
} catch (ioexception e) {
e.printstacktrace();
}
}
public void send(string str) {
try {
dos.writeutf(str);
} catch (ioexception e) {
clients.remove(this);
system.out.println("对方退出了！我从list里面去掉了！");
// e.printstacktrace();
}
}
public void run() {
try {
while (bconnected) {
string str = dis.readutf();
system.out.println(str);
for (int i = 0; i < clients.size(); i++) {
client c = clients.get(i);
c.send(str);
// system.out.println(" a string send !");
}
/*
* for(iterator<client> it = clients.iterator();
* it.hasnext(); ) { client c = it.next(); c.send(str); }
*/
/*
* iterator<client> it = clients.iterator();
* while(it.hasnext()) { client c = it.next(); c.send(str);
* }
*/
}
} catch (eofexception e) {
system.out.println("client closed!");
} catch (ioexception e) {
e.printstacktrace();
} finally {
try {
if (dis != null)
dis.close();
if (dos != null)
dos.close();
if (s != null) {
s.close();
// s = null;
}
} catch (ioexception e1) {
e1.printstacktrace();
}
}
}
}
}
|
本机测试运行结果：
关闭客户端窗口后，提示信息如下：
希望本文所述对大家java程序设计有所帮助。
原文链接：https://blog.csdn.net/nuli888/article/details/51884931