标签 websocket 下的文章

2024-09-05




import javax.websocket.*;
import javax.websocket.server.ServerEndpoint;
import java.io.IOException;
import java.util.concurrent.CopyOnWriteArraySet;
 
@ServerEndpoint("/websocket")
public class WebSocketTest {
    private static final CopyOnWriteArraySet<Session> sessions = new CopyOnWriteArraySet<>();
 
    @OnOpen
    public void onOpen(Session session) {
        sessions.add(session);
        System.out.println("Connected ... " + session.getId());
    }
 
    @OnClose
    public void onClose(Session session) {
        sessions.remove(session);
        System.out.println("Disconnected ... " + session.getId());
    }
 
    @OnError
    public void onError(Session session, Throwable throwable) {
        System.out.println("Error ... " + session.getId());
        throwable.printStackTrace();
    }
 
    @OnMessage
    public void onMessage(String message, Session session) {
        System.out.println("Received message ... " + session.getId() + " " + message);
        for (Session peer : sessions) {
            if (!peer.equals(session)) {
                try {
                    peer.getBasicRemote().sendText(message);
                } catch (IOException e) {
                    onError(peer, e);
                }
            }
        }
    }
}

这段代码使用Java定义了一个简单的WebSocket服务端点，它可以处理多个客户端的连接，并将接收到的消息广播到所有其他的客户端。这个例子展示了如何使用Java EE的WebSocket API，并且如何处理连接、消息接收、错误以及关闭事件。

System

2024-09-05

所有,java

以下是一个使用Spring Boot整合WebSocket的简单示例。

首先，添加依赖到你的pom.xml文件：




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

然后，配置WebSocket：




import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
 
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
 
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws").withSockJS();
    }
 
    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.enableSimpleBroker("/topic");
        registry.setApplicationDestinationPrefixes("/app");
    }
}

接下来，创建一个控制器来处理WebSocket消息：




import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
 
@Controller
public class WebSocketController {
 
    @Autowired
    private SimpMessagingTemplate simpMessagingTemplate;
 
    @MessageMapping("/hello")
    @SendTo("/topic/greetings")
    public String greeting(String message) {
        return "Hello, " + message + "!";
    }
 
    @RequestMapping("/sendMessage")
    @ResponseBody
    public String sendMessage(String message) {
        simpMessagingTemplate.convertAndSend("/topic/greetings", "Hello, " + message + "!");
        return "Message sent";
    }
}

最后，在HTML页面中使用WebSocket：




<!DOCTYPE html>
<html>
<head>
    <title>WebSocket Test</title>
    <script src="https://cdn.jsdelivr.net/npm/sockjs-client@1.7.0/dist/sockjs.min.js"></script>
    <script src="https://cdn.jsdelivr.net/npm/s

- 阅读更多 -

springboot基于netty加websocket实现高性能IM系统案例

System

2024-09-05

所有,java

在这个案例中，我们将实现WebSocket的处理器和初始化配置。




import io.netty.buffer.ByteBuf;
import io.netty.buffer.Unpooled;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.http.DefaultFullHttpResponse;
import io.netty.handler.codec.http.FullHttpRequest;
import io.netty.handler.codec.http.HttpResponseStatus;
import io.netty.handler.codec.http.websocketx.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
 
import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;
 
@Component
public class WebSocketHandler extends SimpleChannelInboundHandler<WebSocketFrame> {
 
    private static final Map<String, ChannelHandlerContext> clients = new ConcurrentHashMap<>();
 
    @Autowired
    private TextWebSocketHandler textWebSocketHandler;
 
    @Override
    protected void channelRead0(ChannelHandlerContext ctx, WebSocketFrame frame) throws Exception {
        // 判断是否WebSocket握手请求
        if (frame instanceof FullHttpRequest) {
            handleHttpRequest(ctx, (FullHttpRequest) frame);
        } else if (frame instanceof CloseWebSocketFrame) {
            // 关闭WebSocket连接
            handshaker.close(ctx.channel(), (CloseWebSocketFrame) frame.retain());
        } else if (frame instanceof PingWebSocketFrame) {
            // 发送Pong消息
            ctx.channel().write(new PongWebSocketFrame(frame.content().retain()));
        } else if (frame instanceof TextWebSocketFrame) {
            // 处理文本消息
            String message = ((TextWebSocketFrame) frame).text();
            textWebSocketHandler.handleTextMessage(ctx, message);
        } else {
            throw new UnsupportedOperationException("Unsupported frame type: " + frame.getClass().getName());
        }
    }
 
    private void handleHttpRequest(ChannelHandlerContext ctx, FullHttpRequest req) {
        // 如果HTTP请求不是WebSocket握手请求，则返回HTTP响应
        if (!handshaker.isWebSocketUpgradeRequest(req)) {
            sendHttpResponse(ctx, req, new DefaultFullHttpResponse(req.protocolVersion(), HttpResponseStatus.BAD_REQUEST));
            return;
        }
 
        // 构造握手响应返回
        handshaker.handshake(ctx.channel(), req);
    }
 
    private void sendHttpResponse(ChannelHandlerContext ctx, FullHttpRequest req, DefaultFullHttpResponse res) {
        // 发送HTTP响应
        if (res.status().code() != 200) {
            ByteBuf byteBuf = Unpooled.copiedBuff

- 阅读更多 -

在Spring Boot中实现WebSocket实时通信

System

2024-09-04

所有,java




import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.config.annotation.*;
 
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(myHandler(), "/my-websocket-endpoint")
            .setAllowedOrigins("*");
    }
 
    @Bean
    public WebSocketHandler myHandler() {
        // 实现自定义的WebSocketHandler
        return new MyCustomWebSocketHandler();
    }
}

在这个例子中，我们定义了一个配置类WebSocketConfig，实现了WebSocketConfigurer接口。我们注册了一个名为/my-websocket-endpoint的WebSocket处理器，并且设置了允许来自任何源的连接（通常在生产环境中应当限制允许的源）。我们还定义了一个Bean方法myHandler()来提供我们自定义的WebSocket处理器MyCustomWebSocketHandler。这个处理器需要你自己实现org.springframework.web.socket.WebSocketHandler接口。

- 阅读更多 -

SpringBoot 集成 WebSocket

System

2024-09-04

所有,java

在Spring Boot中集成WebSocket，你可以使用Spring的@EnableWebSocketMessageBroker注解来配置一个WebSocket消息代理。以下是一个简单的例子：

添加依赖到你的pom.xml：




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

配置WebSocketMessageBroker：




import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
 
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
    
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws").withSockJS();
    }
 
    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.enableSimpleBroker("/topic");
        registry.setApplicationDestinationPrefixes("/app");
    }
}

创建一个控制器来处理WebSocket消息：




import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
 
@Controller
public class WebSocketController {
 
    @MessageMapping("/hello")
    @SendTo("/topic/greetings")
    public String greeting(String message) {
        return "Hello, " + message + "!";
    }
}

前端使用SockJS和STOMP：




<script src="https://cdn.jsdelivr.net/npm/sockjs-client@1.7.0/dist/sockjs.min.js"></script>
<script src="https://cdn.jsdelivr.net/npm/stompjs@2.3.3/stomp.min.js"></script>
<script>
    var socket = new WebSocket('ws://localhost:8080/ws');
    var stompClient = Stomp.over(socket);
    stompClient.connect({}, function(frame) {
        console.log('Connected: ' + frame);
        stompClient.subscribe('/

System

2024-09-04

所有,数据库




using System;
using System.Data.SQLite;
using System.Windows.Forms;
using WebSocket4Net;
 
public partial class MainForm : Form
{
    private WebSocket webSocket;
    private readonly string sqliteConnectionString = "Data Source=your_database_path;Version=3;";
 
    public MainForm()
    {
        InitializeComponent();
        InitializeWebSocket();
    }
 
    private void InitializeWebSocket()
    {
        webSocket = new WebSocket("ws://your_websocket_server_address");
        webSocket.Opened += WebSocket_Opened;
        webSocket.Closed += WebSocket_Closed;
        webSocket.MessageReceived += WebSocket_MessageReceived;
        webSocket.Error += WebSocket_Error;
    }
 
    private void StartButton_Click(object sender, EventArgs e)
    {
        webSocket.Open();
    }
 
    private void StopButton_Click(object sender, EventArgs e)
    {
        webSocket.Close();
    }
 
    private void WebSocket_Opened(object sender, EventArgs e)
    {
        // WebSocket连接打开时的操作
    }
 
    private void WebSocket_Closed(object sender, EventArgs e)
    {
        // WebSocket连接关闭时的操作
    }
 
    private void WebSocket_MessageReceived(object sender, MessageReceivedEventArgs e)
    {
        // 接收到消息时的操作
        var message = e.Message;
 
        // 将接收到的消息存储到SQLite数据库中
        using (var connection = new SQLiteConnection(sqliteConnectionString))
        {
            connection.Open();
            using (var command = connection.CreateCommand())
            {
                command.CommandText = "INSERT INTO your_table_name (column_name) VALUES (@message)";
                command.Parameters.AddWithValue("@message", message);
                command.ExecuteNonQuery();
            }
        }
    }
 
    private void WebSocket_Error(object sender, EventArgs e)
    {
        // 处理错误
    }
}

在这个代码实例中，我们创建了一个WebSocket客户端，并在连接打开、关闭以及接收到消息时的相关操作。我们还演示了如何将接收到的消息存储到SQLite数据库中。这个例子提供了一个简单的框架，可以根据实际需求进行扩展和定制。

- 阅读更多 -

如何在Spring Boot中使用WebSocket

System

2024-09-04

所有,java

在Spring Boot中使用WebSocket，你可以利用Spring的@EnableWebSocketMessageBroker注解来配置一个WebSocket消息代理。以下是一个简单的例子：

添加依赖到你的pom.xml：




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

配置WebSocket消息代理：




import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
 
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
    
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws").withSockJS();
    }
 
    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.enableSimpleBroker("/topic");
        registry.setApplicationDestinationPrefixes("/app");
    }
}

创建一个控制器来处理WebSocket消息：




import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
 
@Controller
public class WebSocketController {
 
    @MessageMapping("/hello")
    @SendTo("/topic/greetings")
    public String greeting(String message) {
        return "Hello, " + message + "!";
    }
}

前端使用WebSocket的例子（使用SockJS和STOMP）：




<script src="https://cdn.jsdelivr.net/npm/sockjs-client@1.7.0/dist/sockjs.min.js"></script>
<script src="https://cdn.jsdelivr.net/npm/stompjs@2.3.3/stomp.min.js"></script>
<script type="text/javascript">
    var socket = new SockJS('/ws');
    var stompClient = Stomp.over(socket);
    stompClient.connect({}, function(frame) {
        console.log('Connected: ' + frame);
        stompClient.subscribe('/topic/greetings', function(greeting){
            console.log(greeting.body);
        });
    });
    
    function sendN

- 阅读更多 -

SpringBoot之WebSocket服务搭建

System

2024-09-04

所有,java

以下是一个简单的Spring Boot WebSocket服务的示例代码：




import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.config.annotation.*;
 
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
 
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(myHandler(), "/ws/echo")
                .setAllowedOrigins("*");
    }
 
    @Bean
    public WebSocketHandler myHandler() {
        // 实现WebSocketHandler接口或使用默认实现，例如TextWebSocketHandler
        return new TextWebSocketHandler() {
            @Override
            public void handleTextMessage(WebSocketSession session, TextMessage message) {
                // 接收消息并处理，发送响应
                session.sendMessage(new TextMessage("Echo: " + message.getPayload()));
            }
        };
    }
}

在这个例子中，我们定义了一个WebSocket的配置类WebSocketConfig，实现了WebSocketConfigurer接口。在registerWebSocketHandlers方法中，我们添加了一个处理器myHandler，它的URL映射是/ws/echo。这个处理器是一个TextWebSocketHandler，它会在收到文本消息时回显这些消息。最后，我们通过setAllowedOrigins("*")允许所有源的WebSocket连接。

这个简单的例子展示了如何在Spring Boot应用程序中设置和配置WebSocket服务。在实际应用中，你可能需要扩展WebSocketHandler以处理更复杂的逻辑，并添加额外的配置来满足特定的安全需求或其他性能要求。

System

2024-09-04

所有,java

在Spring Boot中整合WebSocket服务，你可以使用Spring的@EnableWebSocketMessageBroker注解来配置一个WebSocket消息代理。以下是一个简单的例子：

添加依赖到你的pom.xml：




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

配置WebSocket消息代理：




import org.springframework.context.annotation.Configuration;
import org.springframework.messaging.simp.config.MessageBrokerRegistry;
import org.springframework.web.socket.config.annotation.EnableWebSocketMessageBroker;
import org.springframework.web.socket.config.annotation.StompEndpointRegistry;
import org.springframework.web.socket.config.annotation.WebSocketMessageBrokerConfigurer;
 
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
    
    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
        registry.addEndpoint("/ws").withSockJS();
    }
 
    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
        registry.enableSimpleBroker("/topic");
        registry.setApplicationDestinationPrefixes("/app");
    }
}

创建一个控制器来处理WebSocket请求：




import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.handler.annotation.MessageMapping;
import org.springframework.messaging.handler.annotation.SendTo;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RestController;
 
@RestController
public class WebSocketController {
 
    @MessageMapping("/hello")
    @SendTo("/topic/greetings")
    public String greeting(String message) {
        return "Hello, " + message + "!";
    }
}

在上述配置中，客户端可以通过/ws端点连接到WebSocket服务。服务端通过/app/hello路径接收消息，并通过@SendTo注解将消息广播到所有订阅了/topic/greetings的客户端。

确保你的Spring Boot应用程序有一个启动类，并且已经配置了必要的组件扫描，以便Spring能够发现上述配置的WebSocket组件。

- 阅读更多 -

Springboot3.X集成WebSocket完整流程

System

2024-09-04

所有,java




import org.springframework.context.annotation.Configuration;
import org.springframework.web.socket.config.annotation.*;
 
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
 
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(myHandler(), "/my-websocket-endpoint")
            .setAllowedOrigins("*"); // 允许所有域进行WebSocket连接
    }
 
    @Bean
    public WebSocketHandler myHandler() {
        // 实现WebSocketHandler接口或使用Spring提供的SimpleWebSocketHandler
        return new MyCustomWebSocketHandler();
    }
}
 
// 自定义的WebSocket处理器
public class MyCustomWebSocketHandler implements WebSocketHandler {
    // 实现WebSocketHandler所需的方法，例如：
    @Override
    public void afterConnectionEstablished(WebSocketSession session) {
        // 连接建立后的处理逻辑
    }
 
    // 其他方法的实现...
}

这个代码示例展示了如何在Spring Boot 3.X中配置和注册一个自定义的WebSocket处理器。首先，我们创建了一个实现了WebSocketConfigurer接口的配置类。在这个类中，我们注册了一个指定的WebSocket处理器和端点，并设置了允许跨域请求。然后，我们创建了一个实现了WebSocketHandler接口的自定义处理器类。在这个处理器中，你可以实现各种WebSocket会话的生命周期方法，如建立连接、接收消息、发送消息、出现错误以及会话关闭等。

- 阅读更多 -