Java Websocket은 웹 브라우저와 웹 서버 간의 실시간 양방향 통신을 설정하는 데 사용되는 프로토콜입니다. 오늘날의 인터넷 애플리케이션에서는 실시간이 점점 더 중요해지고 있으며, 실시간 커뮤니케이션이 필요한 시나리오 중 하나가 소셜 채팅입니다. 채팅 시나리오에서는 대규모 동시 연결을 처리해야 합니다. 그리고 Java Websocket은 탁월한 선택입니다.
이 글에서는 Java Websocket을 사용하여 대규모 동시 연결을 처리하는 방법을 코드 예제를 통해 소개하겠습니다.
먼저 일반적인 아이디어를 살펴보겠습니다. Java Websocket에서는 Java EE의 Servlet과 WebSocketEndpoint를 자주 사용합니다. 몇 가지 간단한 예에서는 이러한 클래스를 사용하지만 연결 수가 증가할 때 이러한 클래스를 직접 사용하면 쉽게 성능 병목 현상이 발생할 수 있으므로 연결을 처리하려면 좀 더 효율적인 도구를 사용해야 합니다.
여기에서는 JavaTreasureChest의 netty-socketio 라이브러리를 사용하여 Java Websocket 연결을 처리하겠습니다. Netty는 고성능 네트워크 프로그래밍 프레임워크이고, SocketIO는 실시간 애플리케이션을 구현하기 위한 프로토콜입니다.
코드 예제
먼저 netty-socketio 라이브러리의 종속성을 추가해야 합니다. Maven 프로젝트에서는 pom.xml 파일에 다음 종속성을 추가할 수 있습니다.
<dependency>
<groupId>com.corundumstudio.socketio</groupId>
<artifactId>netty-socketio</artifactId>
<version>1.7.17</version>
</dependency>다음으로 Java 클래스를 WebSocket 서버로 구현하고 연결 요청을 수신해야 합니다. 샘플 코드는 다음과 같습니다.
import com.corundumstudio.socketio.*;
import com.corundumstudio.socketio.listener.*;
public class WebSocketServer {
public static void main(String[] args) {
// 创建配置对象
Configuration config = new Configuration();
config.setHostname("localhost");
config.setPort(9092);
// 创建SocketIO服务器
SocketIOServer server = new SocketIOServer(config);
// 添加连接事件监听器
server.addConnectListener(new ConnectListener() {
@Override
public void onConnect(SocketIOClient client) {
System.out.println("连接成功：" + client.getSessionId().toString());
}
});
// 启动服务器
server.start();
// 等待连接关闭
System.in.read();
server.stop();
}
}이 코드에서는 SocketIO 라이브러리의 SocketIOServer 클래스를 사용하여 WebSocket 서버를 생성합니다. 연결이 성공하면 연결 성공 메시지가 출력됩니다.
다음으로, 클라이언트가 연결될 때 처리될 수 있도록 서버에 리스너를 등록해야 합니다. 코드는 다음과 같습니다.
// 添加事件监听器
server.addEventListener("client_msg", String.class, new DataListener<String>() {
@Override
public void onData(SocketIOClient client, String data, AckRequest ackRequest) {
System.out.println("收到消息：" + data + "，sessionId=" + client.getSessionId());
}
});이 코드 조각에서는 "client_msg"라는 이벤트를 등록하고 수신된 메시지를 처리하기 위해 DataListener를 추가했습니다.
때때로 연결을 인증해야 할 수도 있습니다. SocketIO 라이브러리는 인증을 처리하기 위해 구현할 수 있는 AuthorizationListener 인터페이스를 제공합니다. 샘플 코드는 다음과 같습니다.
// 添加身份验证监听器
server.addAuthorizationListener(new AuthorizationListener() {
@Override
public boolean isAuthorized(HandshakeData handshakeData) {
// 验证用户是否具有连接权限
return true;
}
});이 코드 조각에서는 인증 요청을 처리하기 위해 AuthorizationListener를 추가했습니다. 여기서의 논리는 모든 연결을 인증하는 것입니다.
마지막으로 WebSocket 서버를 시작하고 연결이 닫힐 때까지 기다려야 합니다. 코드는 다음과 같습니다.
// 启动服务器 server.start(); // 等待连接关闭 System.in.read(); server.stop();
간단한 Java Websocket 서버 구현이지만 대규모 동시 연결을 처리할 수 없습니다. 다음 섹션에서는 netty-socketio 라이브러리를 사용하여 대규모 동시 연결을 처리하는 방법을 다룹니다.
네임스페이스와 공간을 사용하여 동시 연결 처리
많은 수의 동시 연결을 처리하려면 연결을 그룹화해야 합니다. netty-socketio 라이브러리에서는 그룹화를 위해 네임스페이스와 공간을 사용할 수 있습니다. 네임스페이스는 룸 그룹을 포함하는 논리 채널입니다. 룸은 사용자 그룹을 포함하는 룸입니다.
구체적인 사용법은 다음과 같습니다:
// 创建SocketIO服务器
SocketIOServer server = new SocketIOServer(config);
// 创建namespace
SocketIONamespace chatNamespace = server.addNamespace("/chat");
// 设置连接事件监听器
chatNamespace.addConnectListener(new ConnectListener() {
@Override
public void onConnect(SocketIOClient client) {
// 加入默认房间
client.joinRoom("default");
}
});
// 设置事件监听器
chatNamespace.addEventListener("client_msg", String.class, new DataListener<String>() {
@Override
public void onData(SocketIOClient client, String data, AckRequest ackRequest) {
String sessionId = client.getSessionId().toString();
System.out.println("收到消息：" + data + "，sessionId=" + sessionId);
// 广播消息到房间的所有用户
chatNamespace.getRoomOperations("default").sendEvent("server_msg", sessionId + ":" + data);
}
});
// 启动服务器
server.start();이 코드 조각에서는 네임스페이스와 공간을 사용하여 연결을 처리합니다. 먼저 "채팅"이라는 논리 채널을 만들고 기본 방을 추가했습니다. 다음으로 클라이언트 연결을 처리할 때 기본 룸에 연결을 추가합니다.
클라이언트로부터 메시지를 받으면 기본 방의 모든 사용자에게 메시지를 방송합니다. 여기서는 getRoomOperations 메소드를 사용하여 방의 작업 개체를 가져옵니다.
이런 식으로 네임스페이스와 룸을 사용하여 대규모 동시 연결을 처리할 수 있습니다.
성능 최적화
대규모 동시 연결에서 성능을 보장하려면 성능 최적화를 수행해야 합니다. 여기에는 몇 가지 일반적인 최적화 방법이 나열되어 있습니다.
동시 연결 수가 증가하면 스레드 풀을 사용하여 성능을 향상시킬 수 있습니다. netty-socketio에서는 다음을 통해 스레드 풀을 생성할 수 있습니다.
// 创建配置对象 Configuration config = new Configuration(); ... // 创建线程池 config.setWorkerThreads(100);
데이터베이스 작업에서 연결을 자주 생성하지 않도록 연결을 캐시할 수 있습니다. netty-socketio에서는 ConnectListener의 데이터베이스 연결을 캐시하고 이를 DataListener에서 사용할 수 있습니다. 샘플 코드는 다음과 같습니다.
chatNamespace.addConnectListener(new ConnectListener() {
@Override
public void onConnect(SocketIOClient client) {
// 加入默认房间
client.joinRoom("default");
// 缓存数据库连接
client.set("conn", getDBConnection());
}
});
chatNamespace.addEventListener("client_msg", String.class, new DataListener<String>() {
@Override
public void onData(SocketIOClient client, String data, AckRequest ackRequest) {
String sessionId = client.getSessionId().toString();
System.out.println("收到消息：" + data + "，sessionId=" + sessionId);
// 使用缓存的数据库连接
Connection conn = (Connection)client.get("conn");
...
}
});여기에서는 SocketIOClient의 set 메서드를 사용하여 데이터베이스 연결을 캐시하고 DataListener에서 사용합니다.
동시 메시지의 양이 많은 경우 캐시된 메시지 대기열에 메시지를 저장하고 후속 처리를 기다릴 수 있습니다. 이는 즉각적인 동시성 압력을 완화할 수 있습니다. 샘플 코드는 다음과 같습니다.
private Queue<String> messageQueue = new ConcurrentLinkedDeque<>();
chatNamespace.addEventListener("client_msg", String.class, new DataListener<String>() {
@Override
public void onData(SocketIOClient client, String data, AckRequest ackRequest) {
String sessionId = client.getSessionId().toString();
System.out.println("收到消息：" + data + "，sessionId=" + sessionId);
// 将消息放入缓存队列
messageQueue.offer(sessionId + ":" + data);
}
});
// 消息处理线程
new Thread(new Runnable() {
@Override
public void run() {
while (true) {
try {
// 从队列取出消息并处理
String message = messageQueue.poll();
processMessage(message);
// 睡眠1秒
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}).start();여기에서는 메시지를 저장하기 위한 ConcurrentLinkedDeque 대기열을 정의합니다. DataListener에서 메시지를 큐에 넣습니다. 처리 스레드에서는 메시지가 큐에서 가져와 처리됩니다. 과도한 CPU 사용을 방지하려면 여기에서 스레드 절전 시간을 설정해야 합니다.
요약
이 글에서는 netty-socketio를 사용하여 대규모 동시 연결을 처리하는 방법을 소개했습니다. 네임스페이스와 공간을 사용하여 연결을 그룹화하고 성능을 최적화하면 동기 통신 시나리오에서 많은 수의 연결을 처리하는 데 도움이 될 수 있습니다.
또한 WebSocket 프로토콜은 일반적으로 실시간 통신 시나리오에서 긴 연결을 구현하는 데 사용되지만 보안 위험이 있을 수도 있습니다. 따라서 실제 적용에서는 주의해서 사용해야 하며 안전성을 고려해야 합니다.
위 내용은 Java Websocket 개발 실습: 대규모 동시 연결을 처리하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!
![[웹 프런트엔드] Node.js 빠른 시작](https://img.php.cn/upload/course/000/000/067/662b5d34ba7c0227.png)
