javax.websocket与jackson

javax.websocket（SpringBoot）

@ServerEndpoint(value="/username")
public class MessageSocket {
    
    // 链接打开
    @OnOpen
    public void OnOpen(){
        System.out.println("链接被打开...");
    }
    
    //链接关闭
    @OnClose
    public void OnClose(){
        System.out.println("链接被关闭...");
    }
    
    // 发送消息
    @OnMessage
    public void OnMessage(String roomVo, Session session){
        System.out.println(roomVo);
        session.getAsyncRemote().sendText(roomVo);
    }


}

• 注册进spring ioc容器中

@Configuration
@EnableWebSocket
public class WebSocketConfig {

    @Bean
    public ServerEndpointExporter serverEndpointExporter(){
        return new ServerEndpointExporter();
    }

}

• 消息类型（也可以将消息进行加密或者二进制方式发送）

@Component
public class WebSocketMessage {

    /**
     * 单聊
     * @param session
     * @param Message
     */
    public static void OneMessage(Session session,String Message){
         session.getAsyncRemote().sendText(Message);
    }

    /**
     * 群聊
     * @param session
     * @param Message
     */
    public static void EveryOne(Session session,String Message){
        // 群聊本身就是一个高并发，多线程场景，所以必须用这个
        ConcurrentHashMap<String, Session> map = new ConcurrentHashMap<>();
        for (Session sessions : map.values()){
            session.getAsyncRemote().sendText(Message);
        }

    }

    // 订单通知，官方消息
}

jackson

• 实体类转JSON

ObjectMapper mapper = new ObjectMapper();
String result = mapper.writeValueAsString(实体类);

• JSON转实体类

ObjectMapper mapper = new ObjectMapper();
mapper.readValue(JSON数据, 实体类反射类型);

Jackson常用注解

• JsonProperty 属性映射
• JsonIgnore忽略字段

下一期，MyBatisPlus分页查询与myBatisPlus多租户Saas系统