【方向盘】版本历史&代码示例之：WebSocket、JSTL

<!-- javax命名空间版本（Tomcat 9.x及以下版本支持） -->
<dependency>
    <groupId>javax.websocket</groupId>
    <artifactId>javax.websocket-api</artifactId>
    <version>1.1</version>
    <scope>provided</scope>
</dependency>

<!-- jakarta命名空间版本（Tomcat 10.x及以上版本支持） -->
<dependency>
    <groupId>jakarta.websocket</groupId>
    <artifactId>jakarta.websocket-api</artifactId>
    <version>2.0.0</version>
    <!-- <version>1.1.2</version> 此版本命名空间同javax -->
    <scope>provided</scope>
</dependency>

除此之外，一般情况下我们直接使用Web容器提供的Jar即可，如Tomcat
<dependency>
    <groupId>org.apache.tomcat.embed</groupId>
    <artifactId>tomcat-embed-websocket</artifactId>
    <version>Tomcat版本号</version>
</dependency>
<dependency>
    <groupId>org.apache.tomcat</groupId>
    <artifactId>tomcat-websocket</artifactId>
    <version>Tomcat版本号</version>
</dependency>

<T> void addMessageHandler(Class<T> clazz, MessageHandler.Partial<T> handler) throws IllegalStateException;
<T> void addMessageHandler(Class<T> clazz, MessageHandler.Whole<T> handler) throws IllegalStateException;

/**
 * 在此处添加备注信息
 *
 * @author YourBatman. <a href=mailto:yourbatman@aliyun.com>Send email to me</a>
 * @site https://yourbatman.cn
 * @date 2021/9/12 15:29
 * @since 0.0.1
 */
@ServerEndpoint("/websocket/chat")
public class WsServer {

    // 当前连接上来的连接们（每一个连接都是一个WsServerDemo实例，包含一个Session会话）
    private static Set<WsServer> webSocketSet = new CopyOnWriteArraySet<>();
    // 会话
    private Session session;

    /**
     * 建连成功的回调
     */
    @OnOpen
    public void onOpen(Session session) {
        this.session = session;
        webSocketSet.add(this); // 保存当前连接
        System.out.println("Server有新连接加入！当前在线人数为" + webSocketSet.size());
    }

    /**
     * 连接关闭调用的方法
     */
    @OnClose
    public void onClose() {
        webSocketSet.remove(this);
        System.out.println("Server有一连接关闭！当前在线人数为" + webSocketSet.size());
    }

    /**
     * 收到客户端消息后调用的方法
     */
    @OnMessage
    public void onMessage(String message) throws IOException {
        System.out.println("Server来自客户端的消息:" + message);
        sendMessage("会话[" + session.getId() + "]的消息已经收到，内容为：" + message);
        // // =======群发消息=========
        // for (WsServerDemo item : webSocketSet) {
        //     try {
        //         item.sendMessage(message);
        //     } catch (IOException e) {
        //         continue;
        //     }
        // }
    }

    /**
     * 发生错误时调用
     */
    @OnError
    public void onError(Throwable error) {
        System.out.println("Server发生错误：" + error.getMessage());
    }

    /**
     * 发送消息
     */
    public void sendMessage(String message) throws IOException {
        this.session.getBasicRemote().sendText(message);
    }

}

/**
 * 在此处添加备注信息
 *
 * @author YourBatman. <a href=mailto:yourbatman@aliyun.com>Send email to me</a>
 * @site https://yourbatman.cn
 * @date 2021/9/12 15:31
 * @since 0.0.1
 */
@ClientEndpoint
public class WsClient {

    // 会话（与服务端建立的会话）
    private Session session;

    /**
     * 建连成功的回调
     */
    @OnOpen
    public void onOpen(Session session) throws IOException {
        this.session = session;
        System.out.println("Client连接到服务端成功，会话ID：" + session.getId());
        sendMessage("这是一条来自Client端，会话["+session.getId()+"]的消息");
    }

    @OnMessage
    public void onMessage(String message) {
        System.out.println("Client端收到消息: " + message);
    }

    @OnClose
    public void onClose() {
        System.out.println("Client会话" + session.getId() + "已断开");
    }

    /**
     * 发送消息
     */
    public void sendMessage(String message) throws IOException {
        this.session.getBasicRemote().sendText(message);
    }
}

public class ClientApp {

    private static URI uri = URI.create("ws://localhost:8080/websocket/chat");
    private static Session session;

    public static void main(String[] args) throws DeploymentException, IOException, InterruptedException {
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();

        // 顺序执行5次会话，端口后再建立新会话
        for (int i = 0; i < 5; i++) {
            session = container.connectToServer(WsClient.class, uri);
            session.close();
            TimeUnit.SECONDS.sleep(2);
        }
    }
}

Client连接到服务端成功，会话ID：1
Client端收到消息: 会话[0]的消息已经收到，内容为：这是一条来自Client端，会话[1]的消息
Client会话1已断开
Client连接到服务端成功，会话ID：2
Client端收到消息: 会话[1]的消息已经收到，内容为：这是一条来自Client端，会话[2]的消息
Client会话2已断开
Client连接到服务端成功，会话ID：3
Client端收到消息: 会话[2]的消息已经收到，内容为：这是一条来自Client端，会话[3]的消息
Client会话3已...

Server有新连接加入！当前在线人数为1
Server来自客户端的消息:这是一条来自Client端，会话[1]的消息
Server有一连接关闭！当前在线人数为0
Server有新连接加入！当前在线人数为1
Server来自客户端的消息:这是一条来自Client端，会话[2]的消息
Server有一连接关闭！当前在线人数为0
Server有新连接加入！当前在线人数为1
Server来自客户端的消息:这是一条来自Client端，会话[3]的消息
Server有一连接关闭！当前在线人数为0

1. <c:out>：用于在页面输出
	- <c:out value="expression" default="expression" escapeXml="boolean"/>
2. <c:if>：逻辑判断
	- <c:if test="expression" var="name" scope="scope">  
	      body content  
	  </c:if>
3. <c:choose>：逻辑判断。when和otherwise的父标签
4. <c:when>： <c:otherwise>：
	- <c:choose>  
	    <c:when test="expression">  
	        body content  
	    </c:when>  
		...
	    <c:otherwise>  
		    body content  
		</c:otherwise>  
	  </c:choose>
	
5. <c:foreach>：
	- <c:forEach var="name" items="expression" varStatus="name" begin="expression" end="expression" step="expression">  
	      body content  
	  </c:forEach>

6. <c:url>：使用可选的查询参数创造一个URL地址
7. <c:set>：设置数据
8. <c:remove>：删除数据

1. <fmt:formatNumber>：格式化数字
2. <fmt:parseNumber>：解析字符串到数字、货币、百分比
3. <fmt:formatDate>：
4. <fmt:parseData>：

1. fn:contains：判断字符串是否包含另外一个字符串	
	- <c:if test="${fn:contains(name, searchString)}">
2. fn:indexOf：子字符串在母字符串中出现的位置	
	- ${fn:indexOf(name, '-')}
3. fn:toLowerCase：转为小写
	- ${fn.toLowerCase(product.name)}

1. <sql:setDataSource>、<sql:query>、<sql:update>

1. <x:parse>、<x:if>、<x:forEach>

<!-- javax命名空间版本（Tomcat 9.x及以下版本支持） -->
<dependency>
    <groupId>javax.servlet.jsp.jstl</groupId>
    <artifactId>jstl-api</artifactId>
    <version>1.2</version>
</dependency>

<!-- jakarta命名空间版本（Tomcat 10.x及以上版本支持） -->
<dependency>
    <groupId>jakarta.servlet.jsp.jstl</groupId>
    <artifactId>jakarta.servlet.jsp.jstl-api</artifactId>
    <version>2.0.0</version>
    <!-- <version>1.2.7</version> 此版本命名空间同javax -->
</dependency>