- 相關(guān)推薦
如何開(kāi)發(fā)部署websocket端點(diǎn)
下面YJBYS小編為大家整理了關(guān)于如何利用Java Websocket API的編程式版本開(kāi)發(fā)并部署(服務(wù)器與客戶(hù)端)websocket端點(diǎn)的文章，希望對你有所幫助。
第一步——擴展javax.websocket.Endpoint類(lèi)
public class ProgrammaticEchoEnpoint extends Endpoint {
@Override
public void onOpen(Session session, EndpointConfig config) {
System.out.println("Peer " + session.getId() + " connected");
session.addMessageHandler(new MessageHandler.Whole() {
@Override
public void onMessage(String message) {
try {
session.getBasicRemote().sendText("Got message from " + session.getId() + "\n" + message);
} catch (IOException ex) {
}
}
});
}
@Override
public void onClose(Session session, CloseReason closeReason) {
System.out.println("Peer " + session.getId() + " disconnected due to " + closeReason.getReasonPhrase());
}
@Override
public void onError(Session session, Throwable error) {
System.out.println("Error communicating with peer " + session.getId() + ". Detail: "+ error.getMessage());
}
}
接下來(lái)我們還要編寫(xiě)客戶(hù)端端點(diǎn)(使用同樣的API組合)：
public class ProgrammaticEchoClient extends Endpoint {
@Override
public void onOpen(Session session, EndpointConfig config) {
System.out.println("Connected to server");
}
//a message handler and other life cycle implementations have been skipped on purpose...
}
第二步——實(shí)現ServerApplicationConfig接口
該接口屬于javax.websocket.server包的組成部分，且能夠通過(guò)覆寫(xiě)以實(shí)現端點(diǎn)部署中的定制化邏輯(適用于注釋以及編程式端點(diǎn))。
public class CustomServerAppConfigProvider implements ServerApplicationConfig {
@Override
public Set getEndpointConfigs(Set> endpointClasses) {
Set result = new HashSet<>();
for (Class epClass : endpointClasses) {
//need to ignore Client endpoint class
if (epClass.equals(ProgrammaticChatEndpoint.class)) {
ServerEndpointConfig sec = ServerEndpointConfig.Builder.create(epClass, "/letschat").build();
result.add(sec);
}
}
return result;
}
@Override
public Set> getAnnotatedEndpointClasses(Set> scanned) {
return Collections.emptySet();
}
}
怎樣處理Client端點(diǎn)?
如果有必要，大家也可以創(chuàng )建自己的ClientEndpointConfig實(shí)例，并利用它對指向websocket服務(wù)器端點(diǎn)的連接進(jìn)行初始化。
WebSocketContainer webSocketContainer = ContainerProvider.getWebSocketContainer();
ClientEndpointConfig config = ClientEndpointConfig.Builder.create().decoders(StockTickDecoder.class).build();
Session session = webSocketContainer.connectToServer(StockTickerClient().class, config,
new URI("ws://hotstocks.com/ticker"));
注意事項：
客戶(hù)端以及服務(wù)器端的config對象只能為等同于(編程式)對象的@ServerEndpoint以及@ClientEndpoint注釋元素(例如值、編碼器、解碼器以及配置器等等)。
各獨立builder類(lèi)(ServerEndpointConfig.Builder與ClientEndpointConfig.Builder)用于分別創(chuàng )建服務(wù)器與客戶(hù)端配置實(shí)例。
ServerEndpointConfig實(shí)例的創(chuàng )建屬于mandatory，因為服務(wù)器端點(diǎn)無(wú)法在不配合URI的前提下進(jìn)行部署。不過(guò)這種情況在客戶(hù)端端點(diǎn)方面不會(huì )出現——因為其全部作用就是接入現有服務(wù)器端點(diǎn)。
端點(diǎn)config(服務(wù)器&客戶(hù)端)擁有configurator概念，其可通過(guò)對應builder方法進(jìn)行創(chuàng )建與設置。
【如何開(kāi)發(fā)部署websocket端點(diǎn)】相關(guān)文章：
Java開(kāi)發(fā)Tomcat部署項目方法10-13
如何開(kāi)發(fā)幼兒智力06-21
如何開(kāi)發(fā)幼兒的右腦07-05
如何開(kāi)發(fā)企業(yè)高層客戶(hù)09-13
如何開(kāi)發(fā)兒童智力07-13
如何面試Web前端開(kāi)發(fā)10-10
如何開(kāi)發(fā)中層管理者07-04