本文整理了Java中org.glassfish.grizzly.websockets.WebSocketAddOn
类的一些代码示例,展示了WebSocketAddOn
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WebSocketAddOn
类的具体详情如下:
包路径:org.glassfish.grizzly.websockets.WebSocketAddOn
类名称:WebSocketAddOn
[英]WebSockets AddOn for the HttpServer.
[中]HttpServer的WebSockets插件。
代码示例来源:origin: org.glassfish.grizzly/grizzly-websockets-server
/**
* {@inheritDoc}
*/
@Override
public void setup(NetworkListener networkListener, FilterChainBuilder builder) {
// Get the index of HttpServerFilter in the HttpServer filter chain
final int httpServerFilterIdx = builder.indexOfType(HttpServerFilter.class);
if (httpServerFilterIdx >= 0) {
// Insert the WebSocketFilter right before HttpServerFilter
builder.add(httpServerFilterIdx, createWebSocketFilter());
}
}
代码示例来源:origin: org.glassfish.websocket/websocket-impl
server.getListener("grizzly").registerAddOn(new WebSocketAddOn());
代码示例来源:origin: org.glassfish.tyrus/websocket-impl
/**
* Start the server.
*/
public synchronized void start(){
try {
if(server == null){
server = HttpServer.createSimpleServer(this.rootPath, this.port);
server.getListener("grizzly").registerAddOn(new WebSocketAddOn());
server.start();
beanServer = new BeanServer(ENGINE_PROVIDER_CLASSNAME);
try {
beanServer.initWebSocketServer(this.rootPath, this.port, beans);
} catch (Exception e) {
e.printStackTrace();
}
LOGGER.info("WebSocket Registered apps: URLs all start with ws://" + this.hostName + ":" + this.port);
LOGGER.info("WebSocket server started.");
}
} catch (IOException e) {
e.printStackTrace();
}
}
代码示例来源:origin: javaee/grizzly
/**
* {@inheritDoc}
*/
@Override
public void setup(NetworkListener networkListener, FilterChainBuilder builder) {
// Get the index of HttpServerFilter in the HttpServer filter chain
final int httpServerFilterIdx = builder.indexOfType(HttpServerFilter.class);
if (httpServerFilterIdx >= 0) {
// Insert the WebSocketFilter right before HttpServerFilter
builder.add(httpServerFilterIdx, createWebSocketFilter());
}
}
代码示例来源:origin: ch.squaredesk.nova/websockets
private WebSocketAdapter(Builder builder) {
super(builder.messageTranscriber, builder.metrics);
this.metricsCollector = new MetricsCollector(builder.metrics);
this.httpServer = builder.httpServer;
if (httpServer !=null) {
// if (httpServer.isStarted()) {
// throw new IllegalArgumentException("HttpServer MUST NOT BE STARTED before WebSocketAdapter is created");
// }
// TODO: would be cool, if we could somehow find out whether this was already done
WebSocketAddOn addon = new WebSocketAddOn();
for (NetworkListener listener : httpServer.getListeners()) {
listener.registerAddOn(addon);
}
}
this.httpClient = builder.httpClient;
this.serverEndpointFactory = new ServerEndpointFactory(builder.messageTranscriber);
this.clientEndpointFactory = new ClientEndpointFactory(builder.messageTranscriber);
}
代码示例来源:origin: javaee/grizzly
/**
* {@inheritDoc}
*/
@Override
public void setup(NetworkListener networkListener, FilterChainBuilder builder) {
// Get the index of HttpServerFilter in the HttpServer filter chain
final int httpServerFilterIdx = builder.indexOfType(HttpServerFilter.class);
if (httpServerFilterIdx >= 0) {
// Insert the WebSocketFilter right before HttpServerFilter
builder.add(httpServerFilterIdx, createWebSocketFilter());
}
}
代码示例来源:origin: javaee/grizzly
/**
* Starts the {@link HttpServer}.
*
* @param port Port to listen on.
* @param cometEnabled If comet should be enabled.
* @param cometEnabled If websockets should be enabled.
* @throws IOException Couldn't start the {@link HttpServer}.
*/
private void startGrizzly(int port, boolean cometEnabled,
boolean websocketsEnabled) throws IOException {
httpServer = new HttpServer();
NetworkListener networkListener = new NetworkListener("osgi-listener",
"0.0.0.0", port);
System.out.println("PORT=" + port);
if (cometEnabled) {
logger.info("Enabling Comet.");
networkListener.registerAddOn(new CometAddOn());
}
if (websocketsEnabled) {
logger.info("Enabling WebSockets.");
networkListener.registerAddOn(new WebSocketAddOn());
}
httpServer.addListener(networkListener);
httpServer.start();
}
代码示例来源:origin: javaee/grizzly
/**
* {@inheritDoc}
*/
@Override
public void setup(NetworkListener networkListener, FilterChainBuilder builder) {
// Get the index of HttpServerFilter in the HttpServer filter chain
final int httpServerFilterIdx = builder.indexOfType(HttpServerFilter.class);
if (httpServerFilterIdx >= 0) {
// Insert the WebSocketFilter right before HttpServerFilter
builder.add(httpServerFilterIdx, createWebSocketFilter());
}
}
代码示例来源:origin: javaee/grizzly
/**
* Starts the {@link HttpServer}.
*
* @param port Port to listen on.
* @param cometEnabled If comet should be enabled.
* @param cometEnabled If websockets should be enabled.
* @throws IOException Couldn't start the {@link HttpServer}.
*/
private void startGrizzly(int port, boolean cometEnabled,
boolean websocketsEnabled) throws IOException {
httpServer = new HttpServer();
NetworkListener networkListener = new NetworkListener("osgi-listener",
"0.0.0.0", port);
System.out.println("PORT=" + port);
if (cometEnabled) {
logger.info("Enabling Comet.");
networkListener.registerAddOn(new CometAddOn());
}
if (websocketsEnabled) {
logger.info("Enabling WebSockets.");
networkListener.registerAddOn(new WebSocketAddOn());
}
httpServer.addListener(networkListener);
httpServer.start();
}
代码示例来源:origin: javaee/grizzly
/**
* {@inheritDoc}
*/
@Override
public void setup(NetworkListener networkListener, FilterChainBuilder builder) {
// Get the index of HttpServerFilter in the HttpServer filter chain
final int httpServerFilterIdx = builder.indexOfType(HttpServerFilter.class);
if (httpServerFilterIdx >= 0) {
// Insert the WebSocketFilter right before HttpServerFilter
builder.add(httpServerFilterIdx, createWebSocketFilter());
}
}
代码示例来源:origin: org.mule.glassfish.grizzly/grizzly-websockets
/**
* {@inheritDoc}
*/
@Override
public void setup(NetworkListener networkListener, FilterChainBuilder builder) {
// Get the index of HttpServerFilter in the HttpServer filter chain
final int httpServerFilterIdx = builder.indexOfType(HttpServerFilter.class);
if (httpServerFilterIdx >= 0) {
// Insert the WebSocketFilter right before HttpServerFilter
builder.add(httpServerFilterIdx, createWebSocketFilter());
}
}
内容来源于网络,如有侵权,请联系作者删除!