com.facebook.swift.service

Class ThriftServerService

java.lang.Object

com.google.common.util.concurrent.AbstractIdleService

com.facebook.swift.service.ThriftServerService

All Implemented Interfaces:

com.google.common.util.concurrent.Service

public class ThriftServerService
extends com.google.common.util.concurrent.AbstractIdleService

创建thrift服务实例ThriftServer,封装为Service

Author:

guyadong

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ThriftServerService.Builder

Nested classes/interfaces inherited from interface com.google.common.util.concurrent.Service

com.google.common.util.concurrent.Service.Listener, com.google.common.util.concurrent.Service.State

Field Summary

Fields

Modifier and Type	Field and Description
static com.google.common.collect.ImmutableMap<java.lang.String,com.facebook.nifty.codec.ThriftFrameCodecFactory>	DEFAULT_FRAME_CODEC_FACTORIES 在ThriftServer.DEFAULT_FRAME_CODEC_FACTORIES基础上增加'http'支持
static com.google.common.collect.ImmutableMap<java.lang.String,com.facebook.nifty.duplex.TDuplexProtocolFactory>	DEFAULT_PROTOCOL_FACTORIES 在ThriftServer.DEFAULT_PROTOCOL_FACTORIES基础上增加'json'支持
static java.lang.String	HTTP_TRANSPORT
static java.lang.String	JSON_PROTOCOL
protected com.facebook.swift.service.ThriftServiceProcessor	processor
protected java.lang.String	serviceName
protected com.facebook.swift.service.ThriftServer	thriftServer
protected com.facebook.swift.service.ThriftServerConfig	thriftServerConfig

Constructor Summary

Constructors

Constructor and Description
ThriftServerService(java.util.List<?> services, java.util.List<com.facebook.swift.service.ThriftEventHandler> eventHandlers, com.facebook.swift.service.ThriftServerConfig thriftServerConfig) 构造函数

Method Summary

Modifier and Type	Method and Description
protected void	addCorsHandlerIfHttp() 添加CORS Handler和XHR编解码器
static ThriftServerService.Builder	bulider()
static void	logThriftServerConfig(com.facebook.swift.service.ThriftServerConfig config) log 输出config中的关键参数
protected java.lang.String	serviceName()
protected void	shutDown()
protected void	startUp()

Methods inherited from class com.google.common.util.concurrent.AbstractIdleService

addListener, awaitRunning, awaitRunning, awaitTerminated, awaitTerminated, executor, failureCause, isRunning, startAsync, state, stopAsync, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

HTTP_TRANSPORT

public static final java.lang.String HTTP_TRANSPORT

See Also:

Constant Field Values

JSON_PROTOCOL

public static final java.lang.String JSON_PROTOCOL

See Also:

Constant Field Values

DEFAULT_PROTOCOL_FACTORIES

public static final com.google.common.collect.ImmutableMap<java.lang.String,com.facebook.nifty.duplex.TDuplexProtocolFactory> DEFAULT_PROTOCOL_FACTORIES

在ThriftServer.DEFAULT_PROTOCOL_FACTORIES基础上增加'json'支持

DEFAULT_FRAME_CODEC_FACTORIES

public static final com.google.common.collect.ImmutableMap<java.lang.String,com.facebook.nifty.codec.ThriftFrameCodecFactory> DEFAULT_FRAME_CODEC_FACTORIES

在ThriftServer.DEFAULT_FRAME_CODEC_FACTORIES基础上增加'http'支持

thriftServer

protected final com.facebook.swift.service.ThriftServer thriftServer

processor

protected final com.facebook.swift.service.ThriftServiceProcessor processor

thriftServerConfig

protected final com.facebook.swift.service.ThriftServerConfig thriftServerConfig

serviceName

protected final java.lang.String serviceName

Constructor Detail

ThriftServerService

public ThriftServerService(java.util.List<?> services,
                           java.util.List<com.facebook.swift.service.ThriftEventHandler> eventHandlers,
                           com.facebook.swift.service.ThriftServerConfig thriftServerConfig)

构造函数

Parameters:

services - 服务对象列表

eventHandlers - 事件侦听器列表

thriftServerConfig - 服务配置对象

See Also:

ThriftServiceProcessor.ThriftServiceProcessor(ThriftCodecManager, List, List), ThriftServer.ThriftServer(com.facebook.nifty.processor.NiftyProcessor, ThriftServerConfig)

Method Detail

bulider

public static final ThriftServerService.Builder bulider()

addCorsHandlerIfHttp

protected void addCorsHandlerIfHttp()

添加CORS Handler和XHR编解码器

serviceName

protected java.lang.String serviceName()

Overrides:

serviceName in class com.google.common.util.concurrent.AbstractIdleService

startUp

protected final void startUp()
                      throws java.lang.Exception

Specified by:

startUp in class com.google.common.util.concurrent.AbstractIdleService

Throws:

java.lang.Exception

shutDown

protected final void shutDown()

Specified by:

shutDown in class com.google.common.util.concurrent.AbstractIdleService

logThriftServerConfig

public static final void logThriftServerConfig(com.facebook.swift.service.ThriftServerConfig config)

log 输出config中的关键参数