WebSocket을 사용하여 Java에서 인스턴트 채팅 기능을 구현하는 방법-java지도 시간-php.cn

집

Java

java지도 시간

WebSocket을 사용하여 Java에서 인스턴트 채팅 기능을 구현하는 방법

王林

Dec 18, 2023 am 08:43 AM

javawebsocket실시간 채팅

WebSocket을 사용하여 Java에서 인스턴트 채팅 기능을 구현하는 방법

인터넷의 급속한 발전으로 인스턴트 메시징은 사람들의 삶에 없어서는 안될 부분이 되었습니다. 전이중 통신 프로토콜인 WebSocket은 점차 전통적인 HTTP 프로토콜을 대체하고 인스턴트 메시징 기능을 구현하는 중요한 기술 중 하나가 되었습니다. 이 기사에서는 WebSocket을 사용하여 Java에서 인스턴트 채팅 기능을 구현하는 방법을 소개하고 구체적인 코드 예제를 제공합니다.

먼저 다음 환경과 도구를 준비해야 합니다.

JDK 1.8 이상
Maven 빌드 도구
IDE(Eclipse 또는 IntelliJ IDEA 등)

다음으로 인스턴트 채팅 기능 구현을 시작합니다.

1단계: Java 기반 WebSocket 서버 만들기
우리는 Java의 Spring Boot 프레임워크를 사용하여 WebSocket 서버를 만듭니다. Spring Boot는 WebSocket의 개발자 친화적인 API와 편리한 구성을 제공합니다. WebSocket 서버를 생성하기 전에 Spring Boot 프로젝트를 생성해야 합니다.

먼저 IDE에서 새 Spring Boot 프로젝트를 생성하고 다음 종속성을 도입합니다.

<dependencies>
   <dependency>
       <groupId>org.springframework.boot</groupId>
       <artifactId>spring-boot-starter-websocket</artifactId>
   </dependency>
</dependencies>

그런 다음 WebSocketConfig라는 구성 클래스를 생성하고 다음 코드를 추가합니다.

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(chatWebSocketHandler(), "/chat").setAllowedOrigins("*");
    }

    @Bean
    public WebSocketHandler chatWebSocketHandler() {
        return new ChatWebSocketHandler();
    }

}

위 코드에서 를 전달합니다. @EnableWebSocket 주석은 WebSocket을 활성화하고 registerWebSocketHandlers 메서드를 통해 chatWebSocketHandler라는 WebSocket 핸들러를 등록합니다. 프로세서 경로는 "/chat"이며 필요에 따라 경로를 사용자 정의할 수 있습니다. @EnableWebSocket注解启用WebSocket，并通过registerWebSocketHandlers方法注册了一个名为chatWebSocketHandler的WebSocket处理器。处理器的路径是"/chat"，我们可以根据需要自定义路径。

第二步：实现WebSocket处理器
接下来，我们需要实现WebSocket处理器来处理和管理WebSocket连接。在这个处理器中，我们将实现接收和发送消息的功能。

创建一个名为ChatWebSocketHandler的类，并实现WebSocketHandler接口。在这个类中，我们需要重写一些方法：

public class ChatWebSocketHandler extends TextWebSocketHandler {

    private static final List<WebSocketSession> sessions = new CopyOnWriteArrayList<>();

    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        sessions.add(session);
    }

    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        for (WebSocketSession webSocketSession : sessions) {
            webSocketSession.sendMessage(message);
        }
    }

    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        sessions.remove(session);
    }
}

在上述代码中，我们使用了一个sessions列表来管理所有连接的WebSocket会话。afterConnectionEstablished方法在建立连接后会被调用，我们将会话添加到列表中。handleTextMessage方法用于接收和处理消息，我们将接收到的消息发送给所有连接的会话。afterConnectionClosed方法在连接关闭后会被调用，我们需要将会话从列表中移除。

第三步：前端页面
最后，我们需要创建一个前端页面来实现用户的即时聊天功能。

在项目的static文件夹中创建一个名为chat.html的HTML文件，并添加以下代码：

<!DOCTYPE html>
<html>
<head>
    <title>Chat</title>
    <script src="https://code.jquery.com/jquery-3.5.1.min.js"></script>
</head>
<body>
    <div id="messages"></div>
    <input id="input" type="text" />
    <button id="send">Send</button>

    <script>
        var socket = new WebSocket("ws://localhost:8080/chat");

        socket.onmessage = function(event) {
            var message = event.data;
            $("#messages").append("<p>" + message + "</p>");
        };

        $("#send").click(function() {
            var message = $("#input").val();
            socket.send(message);
            $("#input").val("");
        });
    </script>
</body>
</html>

在上述代码中，我们通过WebSocket对象与服务器建立连接，并使用onmessage事件处理接收到的消息。当用户点击Send按钮时，我们将输入框中的文本发送给服务器。

到此为止，我们已经完成了在Java中利用WebSocket实现即时聊天功能的全部代码。接下来，我们对整个流程进行一下简单的说明。

用户通过浏览器访问chat.html页面，与服务器建立WebSocket连接。当用户在输入框中输入消息并点击Send按钮时，浏览器将发送消息给服务器。服务器收到消息后，会将消息发送给所有连接的会话。会话收到消息后，会将其展示在页面上。

运行项目后，多个用户可以通过访问chat.html

2단계: WebSocket 프로세서 구현

다음으로 WebSocket 연결을 처리하고 관리하기 위해 WebSocket 프로세서를 구현해야 합니다. 이 프로세서에서는 메시지 수신 및 전송 기능을 구현합니다.

🎜ChatWebSocketHandler라는 클래스를 만들고 WebSocketHandler 인터페이스를 구현하세요. 이 클래스에서는 몇 가지 메서드를 재정의해야 합니다. 🎜rrreee🎜위 코드에서는 sessions 목록을 사용하여 연결된 모든 WebSocket 세션을 관리합니다. 연결이 설정된 후 afterConnection Used 메서드가 호출되고 목록에 세션을 추가합니다. handleTextMessage 메소드는 메시지를 수신하고 처리하는 데 사용됩니다. 수신된 메시지를 연결된 모든 세션에 보냅니다. afterConnectionClosed 메서드는 연결이 닫힌 후 호출되며 목록에서 세션을 제거해야 합니다. 🎜🎜3단계: 프런트엔드 페이지🎜마지막으로 사용자의 인스턴트 채팅 기능을 구현하기 위해 프런트엔드 페이지를 생성해야 합니다. 🎜🎜프로젝트의 정적 폴더에 chat.html이라는 HTML 파일을 생성하고 다음 코드를 추가합니다. 🎜rrreee🎜위 코드에서는 WebSocket 객체를 전달합니다. 서버와의 연결을 설정하고 onmessage 이벤트를 사용하여 수신된 메시지를 처리합니다. 사용자가 보내기 버튼을 클릭하면 입력 상자의 텍스트를 서버로 보냅니다. 🎜🎜지금까지 Java에서 WebSocket을 이용하여 인스턴트 채팅 기능을 구현하기 위한 모든 코드를 완성했습니다. 다음으로 전체 과정에 대해 간략하게 설명하겠습니다. 🎜🎜사용자는 브라우저를 통해 chat.html 페이지에 접속하고 서버와 WebSocket 연결을 설정합니다. 사용자가 입력 상자에 메시지를 입력하고 보내기 버튼을 클릭하면 브라우저는 해당 메시지를 서버로 보냅니다. 서버는 메시지를 받은 후 연결된 모든 세션에 메시지를 보냅니다. 세션이 메시지를 받은 후 페이지에 표시합니다. 🎜🎜프로젝트 실행 후 chat.html 페이지에 접속하여 여러 사용자가 인스턴트 채팅 기능을 구현할 수 있습니다. 🎜🎜요약하자면 이 글에서는 WebSocket을 사용하여 Java에서 인스턴트 채팅 기능을 구현하는 방법을 소개하고 구체적인 코드 예제를 제공합니다. 이 기사가 도움이 되기를 바랍니다! 🎜

위 내용은 WebSocket을 사용하여 Java에서 인스턴트 채팅 기능을 구현하는 방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명

본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.

핫 AI 도구

Undresser.AI Undress

사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover

사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool

무료로 이미지를 벗다

Clothoff.io

AI 옷 제거제

AI Hentai Generator

AI Hentai를 무료로 생성하십시오.

뜨거운 도구

에디트플러스 중국어 크랙 버전

작은 크기, 구문 강조, 코드 프롬프트 기능을 지원하지 않음

메모장++7.3.1

사용하기 쉬운 무료 코드 편집기

SecList

SecLists는 최고의 보안 테스터의 동반자입니다. 보안 평가 시 자주 사용되는 다양한 유형의 목록을 한 곳에 모아 놓은 것입니다. SecLists는 보안 테스터에게 필요할 수 있는 모든 목록을 편리하게 제공하여 보안 테스트를 더욱 효율적이고 생산적으로 만드는 데 도움이 됩니다. 목록 유형에는 사용자 이름, 비밀번호, URL, 퍼징 페이로드, 민감한 데이터 패턴, 웹 셸 등이 포함됩니다. 테스터는 이 저장소를 새로운 테스트 시스템으로 간단히 가져올 수 있으며 필요한 모든 유형의 목록에 액세스할 수 있습니다.

MinGW - Windows용 미니멀리스트 GNU

이 프로젝트는 osdn.net/projects/mingw로 마이그레이션되는 중입니다. 계속해서 그곳에서 우리를 팔로우할 수 있습니다. MinGW: GCC(GNU Compiler Collection)의 기본 Windows 포트로, 기본 Windows 애플리케이션을 구축하기 위한 무료 배포 가능 가져오기 라이브러리 및 헤더 파일로 C99 기능을 지원하는 MSVC 런타임에 대한 확장이 포함되어 있습니다. 모든 MinGW 소프트웨어는 64비트 Windows 플랫폼에서 실행될 수 있습니다.