@Singleton // 单例
@Component(modules = ApplicationModule.class) // 向该组件注入的对象的实例的实现在ApplicationModule当中。
public interface ApplicationComponent {
    /**
     * 向Application的组件注入自身的方法
     *
     * @param activity 注入方,注意这里传参调整为BaseActivity的原因是为了将Navigator注入组件当中去，这是嵌套注入的一个实现
     */
    void inject(BaseActivity activity);

    /**
     * @return 返回Application的实例
     */
    Context getContext();

    /**
     * @return 返回线程池的实例，如果能习惯使用，这会是个好帮手
     */
    ThreadExecutor getThreadExecutor();

    /**
     * @return 返回UI主线程的实例,这个主要是配合RxJava一起使用的。
     */
    PostExecutionThread getPostExecutionThread();

  
    /**
     * 这里是个很有趣，也非常值得研究的地方。
     * 如果你把这段话注释掉，然后编译，观察以下DaggerApplicationComponent类
     * 然后在把注释放开，再编译，如果你能了解到这两者之间的区别和原因，@Inject这部分基本就能明确了
     *
     * @return 返回仓储
     */
    UserRepository userRepository();
}

@Module
public class ApplicationModule { // module的方法命名方式多数采用provide+类名的形式，当然这不是强求

    private final Application mApplication;

    public ApplicationModule(Application mApplication) {
        this.mApplication = mApplication;
    }

    /**
     * @return 返回Application的实例
     */
    @Provides
    @Singleton
    Context provideApplication() {
        return mApplication;
    }

    /**
     * 向Dagger声明，将JobExecutor的实例绑定到ThreadExecutor的调用方去
     *
     * @param executor 修改指向，将ThreadExecutor的实例绑定为JobExecutor 
     * @return 线程池对象
     */
    @Provides
    @Singleton
    ThreadExecutor provideThreadExecutor(JobExecutor executor) {
        return executor;
    }

    /**
     * 向Dagger声明，将UIThread的实例绑定到PostExecutionThread的调用方上去
     *
     * @param mainThread 改变指向，将PostExecutionThread的指向转变为UIThread
     * @return 返回实例
     */
    @Provides
    @Singleton
    PostExecutionThread provideExecutionThread(UIThread mainThread) {
        return mainThread;
    }

    /**
     * @return 返回Navigator导航的实例
     */
    @Provides
    @Singleton
    Navigator provideNavigator() {
        return new Navigator();
    }
    
      /**
     * 这是段非常精髓的代码，就这样一句话，就将domain和data层联系了起来，让原本只和domain有联系的presentation层
     * 间接指向了data层，并且进行数据交互。
     *
     * @param userDataRepository data层仓储
     * @return 返回domain的仓储
     */
	@Provides
    @Singleton
    UserRepository provideUserRepository(UserDataRepository userDataRepository) {
        return userDataRepository;
    }

}

/**
 * author: Sola
 * 2015/10/30
 */
public class ApiConnection {
    // ===========================================================
    // Constants
    // ===========================================================

    // ===========================================================
    // Fields
    // ===========================================================

    private static OkHttpClient httpClient; //创建OKHttpClient类
    private static Gson gson = new GsonBuilder() //创建Gson解析实例
            .setDateFormat("yyyy-MM-dd'T'HH:mm:ssZ")
            .create();

	/** 这个builder可以有很多个，可以根据具体服务的情况进行不同的匹配 **/
    private static Retrofit.Builder builder =
            new Retrofit.Builder()
                    //添加对于RxJava的适用，致使可以在Api接口当中直接使用Rxjava，这个类是在"com.squareup.retrofit:adapter-rxjava"jar包当中的
                    .addCallAdapterFactory(RxJavaCallAdapterFactory.create())
                    //直接使用Gson转换进行对于参数的适配，这个类是在"com.squareup.retrofit:converter-gson"jar包当中的
                    .addConverterFactory(GsonConverterFactory.create(gson));

    // ===========================================================
    // Constructors
    // ===========================================================

    // ===========================================================
    // Getter & Setter
    // ===========================================================

    // ===========================================================
    // Methods for/from SuperClass/Interfaces
    // ===========================================================

    // ===========================================================
    // Methods
    // ===========================================================

    /**
     * @param baseUrl 注意这里的基础Url为域名或者Ip地址
     * @param serviceClass 实现服务接口的类
     * @param <S> 返回的服务接口
     * @return 服务接口对象
     */
    public static <S> S createService(String baseUrl, Class<S> serviceClass) {
        if (httpClient == null) { //懒加载模式添加Client对象
            httpClient = new OkHttpClient();
            httpClient.interceptors().add(new LoggingInterceptor());//为OKHttp添加一个日志监听的类
        }
        Retrofit retrofit = builder.baseUrl(baseUrl).client(httpClient).build();//创建Retrofit，并且配置访问的Client
        return retrofit.create(serviceClass);
    }

    // ===========================================================
    // Inner and Anonymous Classes
    // ===========================================================

    /**
     * 监听请求日志用的类
     */
    static class LoggingInterceptor implements Interceptor {
        @Override
        public Response intercept(Chain chain) throws IOException {
            Request request = chain.request();
            long t1 = System.nanoTime();
            Log.d("OkHttp", String.format("Sending request %s on %s%n%s body [%s]",
                    request.url(), chain.connection(), request.headers(), request.body()));
            Response response = chain.proceed(request);
            long t2 = System.nanoTime();
            Log.d("OkHttp", String.format("Received response for %s in %.1fms%n%s ",
                    response.request().url(),
                    (t2 - t1) / 1e6d,
                    response.headers()));
            return response;
        }
    }
}

/**
 * 这个类可以不是个接口，可以是个class，这里很随意，个人比较喜欢interface的形式
 * 
 * author: Sola
 * 2015/11/13
 */
public interface BaseService {
    // ===========================================================
    // Constants
    // ===========================================================

    // ===========================================================
    // Fields
    // ===========================================================

    String BASE_URL = RestConfig.BASE_URL;
    
	String SERVICE_PATH = "service";
	
    String SERVICE_CLASS = "class";
	
    // ===========================================================
    // Methods
    // ===========================================================
	
    /**
     * 登录的接口
     *
     * @param service   对应登录的服务名，由于服务器可能会变，这个参数这里就设定成可变动的
     * @param className 对应登录的服务的具体方法名，同上
     * @param data      接口所需要传入的参数
     * @return 返回接口的响应，并且通过Gson转成对应的参数
     */
	@POST("/{service}/{className}/login")
    Observable<LoginResult> login(@Path("service") String service,
                                  @Path("className") String className,
                                  @Query("paramList") String data);

}

 ApiConnection.createService(
                BaseService.BASE_URL, BaseService.class) // 创建Client的过程
                .login(BaseService.SERVICE_PATH,
                        BaseService.SERVICE_CLASS,
                        request.toString())//这里的request可以变成对应服务所需要的传参
                .observeOn(AndroidSchedulers.mainThread())// 这行代码，表示Observable的回调是运行在Android的UI主线程里面。
                .subscribeOn(Schedulers.from(JobExecutor.getInstance()))// 这行代码表示，整个Observable是运行在一个线程池当中。
                .subscribe(resp -> {
	                // 对于返回的结果进行处理，这里已经直接转成对象了，可以直接处理
	                // 并且由于前面已经配置了，UiThread，所以这里可以放心的写界面刷新代码。
                },Throwable::printStackTrace);

// 三个回调函数
def myOnNext = { item -> /* do something useful with item */ };
def myError = { throwable -> /* react sesibly to a failed call */};
def myComplete = { /* clean up after the final response */ };

// 一个观察者对象
def myObservable = someMethod(itesParameters);
// 调用
myObservable.subscribe(myOnNext,myError,myComplete);

// 获得取消订阅的对象
Subscription subscription = Observable.just()               .subscribe();

// Observable会停止发送新的数据项
subscription.unsubscribe();