堕落不振功业废,勤耕不辍日月新

JAVA Socket编程——基于ServerSocket建立聊天服务器

综合 hailen 18℃

JAVA Socket编程——基于ServerSocket建立聊天服务器

该篇博客目录
1、Socket介绍
2、Socket编程在客户端与服务端的使用注意
3、java实现基于ServerSocket的聊天服务器
一、Socket介绍
Socket类实现客户端套接字(也可以就叫“套接字”)。套接字是两台机器间通信的端点。

1、Socket特点
Socket基于TCP链接,数据传输有保障
Socket适用于建立长时间链接
Socket编程通常应用于即时通讯
2、Socket链接的建立过程
服务器监听
客户端发出请求
建立链接
通信
二、Socket编程在客户端与服务端的使用注意
对于客户端,需要使用new Socket(ip,port)
对于服务器端,需要借助于ServerSocket 的accept方法获得与特定的客户端相关联的Socket实例
通信的双方借助于socket里面的方法,获得输出流和输入流完成相关的通信的逻辑处理
三、java实现基于ServerSocket的聊天服务器
下面是每个类具体作用
MyServerSocket:测试类
GetSocket:服务器端的侦听类,负责获取连接成功的客户端
ChatSocket:客户端的通信,向客户端发送和输出信息,实现单独线程的通信
ChatManager:聊天管理,实现Socket入队列,发送数据
MyServerSocket类

package Socket_1;

/*
*
* 测试类
*
*/

public class MySeverSocket {

public static void main(String[] args) {
new GetSocket().start();
}

}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
GetSocket类(线程)
关于accept:若未被接收请求,accept会一直处于等待状态,线程阻塞(所以accept等这类阻塞方法,不能在主线程中使用,否主线程会被阻塞,需要放置到独立的线程当中)

package Socket_1;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

import javax.swing.JOptionPane;

/*
*服务器端的侦听类,负责获取连接成功的客户端
*获取socket与客户端通信
*
*/
public class GetSocket extends Thread {
@Override
public void run() {

try {
//创建绑定到特定端口的服务器套接字 1-65535
ServerSocket serversocket = new ServerSocket(62224);
while(true) {
//建立连接,获取socket对象
Socket socket=serversocket.accept();
//消息提示框
JOptionPane.showMessageDialog(null, “有客户端连接到了本机62224端口哦”);
//与客户端通信
ChatSocket cs=new ChatSocket(socket);
cs.start();
//添加socket到队列
ChatManager.GetChatManager().AddChatPeople(cs);
}
} catch (IOException e) {
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
ChatSocket类(线程)
这里有个关于getInputStream/getOutputStream在客户端还是服务端的作用区别

客户端上的使用

1.getInputStream方法可以得到一个输入流,客户端的Socket对象上的getInputStream方法得到输入流其实就是从服务器端发回的数据。

2.getOutputStream方法得到的是一个输出流,客户端的Socket对象上的getOutputStream方法得到的输出流其实就是发送给服务器端的数据。

服务器端上的使用

1.getInputStream方法得到的是一个输入流,服务端的Socket对象上的getInputStream方法得到的输入流其实就是从客户端发送给服务器端的数据流。

2.getOutputStream方法得到的是一个输出流,服务端的Socket对象上的getOutputStream方法得到的输出流其实就是发送给客户端的数据。

package Socket_1;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.net.Socket;
/*
*与客户端通信,向客户端发送信息
*实现单独线程的通信处理
*/
public class ChatSocket extends Thread {

Socket socket;
public ChatSocket(Socket socket) {
this.socket=socket;
}

/*
*向客户端输出信息
*/
public void Out(String str) {
try {
socket.getOutputStream().write(str.getBytes(“UTF-8”));
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
}
}
/*
*
* 向客户端发送消息
*/
@Override
public void run() {
Out(“success
“);
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().Send(this, line);
}
br.close();
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
} catch (IOException e) {
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
ChatManager类

package Socket_1;

import java.util.Vector;

/*
*
* 添加socket到队列,发送数据
*
*/

public class ChatManager {
//因为一个聊天系统只有一个聊天管理,所以需进行单例化private
/*
*单例化
*/
private ChatManager() {}
private static final ChatManager cm=new ChatManager();
public static ChatManager GetChatManager() {
return cm;
}

//创建保存socket的队列
Vector<ChatSocket> vector=new Vector<ChatSocket>();

//添加聊天人
public void AddChatPeople(ChatSocket cs) {
vector.add(cs);
}

//群发消息
public void Send(ChatSocket cs,String str) {
for (int i = 0; i < vector.size(); i++) {
ChatSocket chatsocket=(ChatSocket)vector.get(i);
if(!cs.equals(chatsocket))
{
chatsocket.Out(str);
}
}
}

}
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
win下打开命令行模拟客户端,eclipse模拟服务器
命令行下键入:telnet localhost 端口号

 

实现群聊

 

整个服务端流程
serversocket侦听
socket添加到队列
通过输入输出流实现向客户端的发送/接受信息
———————
作者:浅然_
来源:CSDN
原文:https://blog.csdn.net/w_linux/article/details/79394150
版权声明:本文为博主原创文章,转载请附上博文链接!

转载请注明:我是IT » JAVA Socket编程——基于ServerSocket建立聊天服务器

喜欢 (0)or分享 (0)