本文整理了Java中org.simpleframework.http.Request.getChannel方法的一些代码示例，展示了Request.getChannel的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Request.getChannel方法的具体详情如下：
包路径：org.simpleframework.http.Request
类名称：Request
方法名：getChannel

Request.getChannel介绍

[英]This provides the underlying channel for the request. It contains the TCP socket channel and various other low level components. Typically this will only ever be needed when there is a need to switch protocols.
[中]这为请求提供了底层通道。它包含TCP套接字通道和各种其他低级组件。通常，只有在需要切换协议时才需要这样做。

代码示例

代码示例来源：origin: org.simpleframework/simple-http

/**
* This provides the underlying channel for the request. It
* contains the TCP socket channel and various other low level
* components. Typically this will only ever be needed when
* there is a need to switch protocols.  
* 
* @return the underlying channel for this request 
*/
public Channel getChannel() {
 return request.getChannel();
}

代码示例来源：origin: ngallagher/simpleframework

/**
* This provides the underlying channel for the request. It
* contains the TCP socket channel and various other low level
* components. Typically this will only ever be needed when
* there is a need to switch protocols.  
* 
* @return the underlying channel for this request 
*/
public Channel getChannel() {
 return request.getChannel();
}

代码示例来源：origin: ngallagher/simpleframework

/**
* Constructor for the <code>OutputBarrier</code> object. This
* is used to ensure that if there is currently a blocking write
* in place that the <code>SessionChecker</code> will not end up
* being blocked if it attempts to send a control frame.
* 
* @param request this is the request to get the TCP channel from
* @param duration this is the length of time to wait for the lock
*/
public OutputBarrier(Request request, long duration) {
 this.lock = new ReentrantLock();      
 this.channel = request.getChannel();
 this.writer = channel.getWriter();
 this.duration = duration;
}

代码示例来源：origin: org.simpleframework/simple-http

/**
* Constructor for the <code>OutputBarrier</code> object. This
* is used to ensure that if there is currently a blocking write
* in place that the <code>SessionChecker</code> will not end up
* being blocked if it attempts to send a control frame.
* 
* @param request this is the request to get the TCP channel from
* @param duration this is the length of time to wait for the lock
*/
public OutputBarrier(Request request, long duration) {
 this.lock = new ReentrantLock();      
 this.channel = request.getChannel();
 this.writer = channel.getWriter();
 this.duration = duration;
}

代码示例来源：origin: ngallagher/simpleframework

/**
* Constructor for the <code>FrameEncoder</code> object. This is 
* used to create an encoder to sending frames over the provided
* channel. Frames send remain unflushed so they can be batched
* on a single output buffer.
* 
* @param request contains the opening handshake information
* @param charset this is the character encoding to encode with
*/
public FrameEncoder(Request request, String charset) {
 this.barrier = new OutputBarrier(request, 5000);
 this.channel = request.getChannel();
 this.trace = channel.getTrace();      
 this.charset = charset;
}

代码示例来源：origin: org.simpleframework/simple-http

/**
* Constructor for the <code>FrameEncoder</code> object. This is 
* used to create an encoder to sending frames over the provided
* channel. Frames send remain unflushed so they can be batched
* on a single output buffer.
* 
* @param request contains the opening handshake information
* @param charset this is the character encoding to encode with
*/
public FrameEncoder(Request request, String charset) {
 this.barrier = new OutputBarrier(request, 5000);
 this.channel = request.getChannel();
 this.trace = channel.getTrace();      
 this.charset = charset;
}

代码示例来源：origin: org.simpleframework/simple-http

/**
* Constructor for the <code>FrameCollector</code> object. This is
* used to create a collector that will process and dispatch web 
* socket frames as defined by RFC 6455.
* 
* @param encoder this is the encoder used to send messages
* @param session this is the web socket session
* @param channel this is the underlying TCP communication channel
* @param reactor this is the reactor used for read notifications
*/
public FrameCollector(FrameEncoder encoder, Session session, Request request, Reactor reactor) {
 this.processor = new FrameProcessor(encoder, session, request);
 this.channel = request.getChannel();
 this.cursor = channel.getCursor();
 this.trace = channel.getTrace();
 this.reactor = reactor;
}

代码示例来源：origin: ngallagher/simpleframework

/**
* Constructor for the <code>FrameCollector</code> object. This is
* used to create a collector that will process and dispatch web 
* socket frames as defined by RFC 6455.
* 
* @param encoder this is the encoder used to send messages
* @param session this is the web socket session
* @param channel this is the underlying TCP communication channel
* @param reactor this is the reactor used for read notifications
*/
public FrameCollector(FrameEncoder encoder, Session session, Request request, Reactor reactor) {
 this.processor = new FrameProcessor(encoder, session, request);
 this.channel = request.getChannel();
 this.cursor = channel.getCursor();
 this.trace = channel.getTrace();
 this.reactor = reactor;
}

代码示例来源：origin: org.simpleframework/simple-http

/**
* Constructor for the <code>FrameProcessor</code> object. This is
* used to create a processor that can consume and dispatch frames
* as defined by RFC 6455 to a set of registered listeners. 
* 
* @param encoder this is the encoder used to send control frames
* @param session this is the session associated with the channel
* @param channel this is the channel to read frames from
*/
public FrameProcessor(FrameEncoder encoder, Session session, Request request) {
 this.listeners = new CopyOnWriteArraySet<FrameListener>();
 this.normal = new Reason(NORMAL_CLOSURE);
 this.extractor = new ReasonExtractor();
 this.consumer = new FrameConsumer();
 this.closed = new AtomicBoolean();
 this.channel = request.getChannel();
 this.cursor = channel.getCursor();
 this.trace = channel.getTrace();
 this.encoder = encoder;
 this.session = session;
}

代码示例来源：origin: ngallagher/simpleframework

/**
* Constructor for the <code>FrameProcessor</code> object. This is
* used to create a processor that can consume and dispatch frames
* as defined by RFC 6455 to a set of registered listeners. 
* 
* @param encoder this is the encoder used to send control frames
* @param session this is the session associated with the channel
* @param channel this is the channel to read frames from
*/
public FrameProcessor(FrameEncoder encoder, Session session, Request request) {
 this.listeners = new CopyOnWriteArraySet<FrameListener>();
 this.normal = new Reason(NORMAL_CLOSURE);
 this.extractor = new ReasonExtractor();
 this.consumer = new FrameConsumer();
 this.closed = new AtomicBoolean();
 this.channel = request.getChannel();
 this.cursor = channel.getCursor();
 this.trace = channel.getTrace();
 this.encoder = encoder;
 this.session = session;
}

代码示例来源：origin: org.simpleframework/simple-http

/**
* Constructor for the <code>ResponseBuilder</code> object. In order
* to process the WebSocket handshake this requires the original 
* request and the response as well as the underlying TCP channel
* which forms the basis of the WebSocket connection.
* 
* @param request this is the request that initiated the handshake
* @param response this is the response for the handshake
*/
public ResponseBuilder(Request request, Response response) throws Exception {
 this.validator = new RequestValidator(request);
 this.token = new AcceptToken(request); 
 this.channel = request.getChannel();
 this.writer = channel.getWriter();
 this.trace = channel.getTrace();
 this.response = response;
}

代码示例来源：origin: ngallagher/simpleframework

/**
* Constructor for the <code>ResponseBuilder</code> object. In order
* to process the WebSocket handshake this requires the original 
* request and the response as well as the underlying TCP channel
* which forms the basis of the WebSocket connection.
* 
* @param request this is the request that initiated the handshake
* @param response this is the response for the handshake
*/
public ResponseBuilder(Request request, Response response) throws Exception {
 this.validator = new RequestValidator(request);
 this.token = new AcceptToken(request); 
 this.channel = request.getChannel();
 this.writer = channel.getWriter();
 this.trace = channel.getTrace();
 this.response = response;
}

代码示例来源：origin: org.simpleframework/simple-http

/**
* Constructor for the <code>StatusChecker</code> object. This
* is used to create a pinger that will send out ping frames at
* a specified interval. If a session does not respond within 
* three times the duration of the ping the connection is reset.
* 
* @param connection this is the WebSocket to send the frames
* @param request this is the associated request
* @param scheduler this is the scheduler used to execute this     
* @param frequency this is the frequency with which to ping
*/
public StatusChecker(FrameConnection connection, Request request, Scheduler scheduler, long frequency) {
 this.listener = new StatusResultListener(this);
 this.error = new Reason(INTERNAL_SERVER_ERROR);
 this.normal = new Reason(NORMAL_CLOSURE);      
 this.frame = new DataFrame(PING);
 this.counter = new AtomicLong();
 this.channel = request.getChannel();
 this.trace = channel.getTrace();
 this.connection = connection;       
 this.scheduler = scheduler;
 this.frequency = frequency;        
}

代码示例来源：origin: ngallagher/simpleframework

/**
* Constructor for the <code>StatusChecker</code> object. This
* is used to create a pinger that will send out ping frames at
* a specified interval. If a session does not respond within 
* three times the duration of the ping the connection is reset.
* 
* @param connection this is the WebSocket to send the frames
* @param request this is the associated request
* @param scheduler this is the scheduler used to execute this     
* @param frequency this is the frequency with which to ping
*/
public StatusChecker(FrameConnection connection, Request request, Scheduler scheduler, long frequency) {
 this.listener = new StatusResultListener(this);
 this.error = new Reason(INTERNAL_SERVER_ERROR);
 this.normal = new Reason(NORMAL_CLOSURE);      
 this.frame = new DataFrame(PING);
 this.counter = new AtomicLong();
 this.channel = request.getChannel();
 this.trace = channel.getTrace();
 this.connection = connection;       
 this.scheduler = scheduler;
 this.frequency = frequency;        
}

代码示例来源：origin: ngallagher/simpleframework

/**
  * This method is used to terminate the connection and commit the
  * response. Terminating the session before it has been dispatched
  * is done when there is a protocol or an unexpected I/O error with
  * the underlying TCP channel. 
  * 
  * @param request this is the session initiating request
  * @param response this is the session initiating response
  */
  public void terminate(Request request, Response response) {
   Channel channel = request.getChannel();
   Trace trace = channel.getTrace();
   
   try {
     response.close();
     channel.close();
     trace.trace(TERMINATE_SOCKET);
   } catch(Exception cause) {
     trace.trace(ERROR, cause);
   }
  }
}

代码示例来源：origin: org.simpleframework/simple-http

/**
  * This method is used to terminate the connection and commit the
  * response. Terminating the session before it has been dispatched
  * is done when there is a protocol or an unexpected I/O error with
  * the underlying TCP channel. 
  * 
  * @param request this is the session initiating request
  * @param response this is the session initiating response
  */
  public void terminate(Request request, Response response) {
   Channel channel = request.getChannel();
   Trace trace = channel.getTrace();
   
   try {
     response.close();
     channel.close();
     trace.trace(TERMINATE_SOCKET);
   } catch(Exception cause) {
     trace.trace(ERROR, cause);
   }
  }
}

代码示例来源：origin: ngallagher/simpleframework

/**
* Constructor for the <code>FrameConnection</code> object. This is used
* to create a channel that can read and write frames over a TCP
* channel. For asynchronous read and dispatch operations this will
* produce an operation to collect and process RFC 6455 frames.
* 
* @param request this is the initiating request for the WebSocket
* @param response this is the initiating response for the WebSocket
* @param reactor this is the reactor used to process frames
*/
public FrameConnection(Request request, Response response, Reactor reactor) {
 this.encoder = new FrameEncoder(request);  
 this.session = new ServiceSession(this, request, response);
 this.operation = new FrameCollector(encoder, session, request, reactor);
 this.reason = new Reason(NORMAL_CLOSURE);
 this.channel = request.getChannel();
 this.writer = channel.getWriter();
 this.trace = channel.getTrace();
}

代码示例来源：origin: org.simpleframework/simple-http

/**
* Constructor for the <code>FrameConnection</code> object. This is used
* to create a channel that can read and write frames over a TCP
* channel. For asynchronous read and dispatch operations this will
* produce an operation to collect and process RFC 6455 frames.
* 
* @param request this is the initiating request for the WebSocket
* @param response this is the initiating response for the WebSocket
* @param reactor this is the reactor used to process frames
*/
public FrameConnection(Request request, Response response, Reactor reactor) {
 this.encoder = new FrameEncoder(request);  
 this.session = new ServiceSession(this, request, response);
 this.operation = new FrameCollector(encoder, session, request, reactor);
 this.reason = new Reason(NORMAL_CLOSURE);
 this.channel = request.getChannel();
 this.writer = channel.getWriter();
 this.trace = channel.getTrace();
}

代码示例来源：origin: org.simpleframework/simple-http

/**
* This method is used to create a dispatch a <code>Session</code> to
* a specific service selected by a router. If the session initiating
* handshake fails for any reason this will close the underlying TCP
* connection and send a HTTP 400 response back to the client. 
* 
* @param request this is the session initiating request
* @param response this is the session initiating response
*/
public void dispatch(Request request, Response response) {
 Channel channel = request.getChannel();
 Trace trace = channel.getTrace();
 
 try {
   Service service = router.route(request, response);
   Session session = builder.create(request, response);      
  
   trace.trace(DISPATCH_SOCKET);
   service.connect(session);
 } catch(Exception cause) {
   trace.trace(ERROR, cause);
   terminate(request, response);
 }
}

代码示例来源：origin: ngallagher/simpleframework

/**
* This method is used to create a dispatch a <code>Session</code> to
* a specific service selected by a router. If the session initiating
* handshake fails for any reason this will close the underlying TCP
* connection and send a HTTP 400 response back to the client. 
* 
* @param request this is the session initiating request
* @param response this is the session initiating response
*/
public void dispatch(Request request, Response response) {
 Channel channel = request.getChannel();
 Trace trace = channel.getTrace();
 
 try {
   Service service = router.route(request, response);
   Session session = builder.create(request, response);      
  
   trace.trace(DISPATCH_SOCKET);
   service.connect(session);
 } catch(Exception cause) {
   trace.trace(ERROR, cause);
   terminate(request, response);
 }
}