import org.springframework.web.socket.PongMessage; //导入依赖的package包/类
@Override
public final void sendMessage(WebSocketMessage<?> message) throws IOException {

	checkNativeSessionInitialized();
	Assert.isTrue(isOpen(), "Cannot send message after connection closed.");

	if (logger.isTraceEnabled()) {
		logger.trace("Sending " + message + ", " + this);
	}

	if (message instanceof TextMessage) {
		sendTextMessage((TextMessage) message);
	}
	else if (message instanceof BinaryMessage) {
		sendBinaryMessage((BinaryMessage) message);
	}
	else if (message instanceof PingMessage) {
		sendPingMessage((PingMessage) message);
	}
	else if (message instanceof PongMessage) {
		sendPongMessage((PongMessage) message);
	}
	else {
		throw new IllegalStateException("Unexpected WebSocketMessage type: " + message);
	}
}
 

import org.springframework.web.socket.PongMessage; //导入依赖的package包/类
@Override
public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
    if (message instanceof TextMessage) {
        handleTextMessage(session, (TextMessage) message);

    } else if (message instanceof PongMessage) {
        handlePongMessage(session);

    } else if (message instanceof BinaryMessage) {
        session.close(CloseStatus.NOT_ACCEPTABLE.withReason("Binary messages not supported"));

    } else {
        throw new IllegalStateException("Unexpected WebSocket message type: " + message);
    }
}
 

import org.springframework.web.socket.PongMessage; //导入依赖的package包/类
@Override
public void handleMessage(WebSocketSession session, WebSocketMessage<?> message) throws Exception {
	if (message instanceof TextMessage) {
		handleTextMessage(session, (TextMessage) message);
	}
	else if (message instanceof BinaryMessage) {
		handleBinaryMessage(session, (BinaryMessage) message);
	}
	else if (message instanceof PongMessage) {
		handlePongMessage(session, (PongMessage) message);
	}
	else {
		throw new IllegalStateException("Unexpected WebSocket message type: " + message);
	}
}
 

import org.springframework.web.socket.PongMessage; //导入依赖的package包/类
private void handlePongMessage(javax.websocket.Session session, ByteBuffer payload) {
	PongMessage pongMessage = new PongMessage(payload);
	try {
		this.handler.handleMessage(this.wsSession, pongMessage);
	}
	catch (Throwable ex) {
		ExceptionWebSocketHandlerDecorator.tryCloseWithError(this.wsSession, ex, logger);
	}
}
 

import org.springframework.web.socket.PongMessage; //导入依赖的package包/类
@OnWebSocketFrame
public void onWebSocketFrame(Frame frame) {
	if (OpCode.PONG == frame.getOpCode()) {
		ByteBuffer payload = frame.getPayload() != null ? frame.getPayload() : EMPTY_PAYLOAD;
		PongMessage message = new PongMessage(payload);
		try {
			this.webSocketHandler.handleMessage(this.wsSession, message);
		}
		catch (Throwable ex) {
			ExceptionWebSocketHandlerDecorator.tryCloseWithError(this.wsSession, ex, logger);
		}
	}
}
 

import org.springframework.web.socket.PongMessage; //导入依赖的package包/类
protected void handlePongMessage(WebSocketSession session, PongMessage message) throws Exception {
}
 

import org.springframework.web.socket.PongMessage; //导入依赖的package包/类
@Override
protected void sendPongMessage(PongMessage message) throws IOException {
	getNativeSession().getBasicRemote().sendPong(message.getPayload());
}
 

import org.springframework.web.socket.PongMessage; //导入依赖的package包/类
@Override
protected void sendPongMessage(PongMessage message) throws IOException {
	getNativeSession().getRemote().sendPong(message.getPayload());
}
 

import org.springframework.web.socket.PongMessage; //导入依赖的package包/类
@Test
public void handleWebSocketMessagePong() throws Exception {
	connect().handleMessage(this.webSocketSession, new PongMessage());
	verifyNoMoreInteractions(this.stompSession);
}
 

import org.springframework.web.socket.PongMessage; //导入依赖的package包/类
@Override
protected void handlePongMessage(WebSocketSession session, PongMessage message) throws Exception {
	// TODO Auto-generated method stub
	super.handlePongMessage(session, message);
}
 

import org.springframework.web.socket.PongMessage; //导入依赖的package包/类
@Override
protected void handlePongMessage(WebSocketSession session, PongMessage message) throws Exception {
    logger.debug("Pong received for session {}", session.getId());
}
 

import org.springframework.web.socket.PongMessage; //导入依赖的package包/类
/**
 * ping-pong
 *
 * @param session
 * @param message
 * @throws Exception
 */
@Override
protected void handlePongMessage(WebSocketSession session, PongMessage message) throws Exception {

}
 

import org.springframework.web.socket.PongMessage; //导入依赖的package包/类
protected abstract void sendPongMessage(PongMessage message) throws IOException;