比较文本

查找两个文本文件之间的差异

实时编辑器

隐藏空白更改

折叠未更改行

关闭换行

视图

比对精度

文本样式

语法高亮

Diffchecker Desktop 运行Diffchecker最安全的方式。获取Diffchecker桌面应用：您的差异永远不会离开您的电脑！获取桌面版

Diff

创建于 6年前差异永不过期

69 删除

行
总计
删除

字符
总计
删除

要继续使用此功能，请升级到 Diffchecker Pro 查看价格

205 行

84 添加

行
总计
添加

字符
总计
添加

要继续使用此功能，请升级到 Diffchecker Pro 查看价格

230 行

package com.pubnub.api.managers;

import com.pubnub.api.PNConfiguration;

import com.pubnub.api.PubNub;

import com.pubnub.api.endpoints.vendor.AppEngineFactory;

import com.pubnub.api.enums.PNLogVerbosity;

import com.pubnub.api.interceptors.SignatureInterceptor;

import com.pubnub.api.services.AccessManagerService;

import com.pubnub.api.services.ChannelGroupService;

import com.pubnub.api.services.HistoryService;

import com.pubnub.api.services.MemberService;

import com.pubnub.api.services.MembershipService;

import com.pubnub.api.services.MessageActionService;

import com.pubnub.api.services.PresenceService;

import com.pubnub.api.services.PublishService;

import com.pubnub.api.services.PushService;

import com.pubnub.api.services.SignalService;

import com.pubnub.api.services.SpaceService;

import com.pubnub.api.services.SubscribeService;

import com.pubnub.api.services.TimeService;

import com.pubnub.api.services.UserService;

import lombok.Getter;

import okhttp3.OkHttpClient;

import okhttp3.logging.HttpLoggingInterceptor;

import retrofit2.Retrofit;

import java.util.Collections;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.TimeUnit;

public class RetrofitManager {

private PubNub pubnub;

private SignatureInterceptor signatureInterceptor;

private OkHttpClient transactionClientInstance;

private OkHttpClient subscriptionClientInstance;

// services

@Getter

private PresenceService presenceService;

@Getter

private HistoryService historyService;

@Getter

private PushService pushService;

@Getter

private AccessManagerService accessManagerService;

@Getter

private ChannelGroupService channelGroupService;

@Getter

private TimeService timeService;

@Getter

private PublishService publishService;

@Getter

private SubscribeService subscribeService;

@Getter

private SignalService signalService;

@Getter

private UserService userService;

@Getter

private SpaceService spaceService;

@Getter

private MembershipService membershipService;

@Getter

private MemberService memberService;

@Getter

private MessageActionService messageActionService;

@Getter

private Retrofit transactionInstance;

@Getter

private Retrofit subscriptionInstance;

public RetrofitManager(PubNub pubNubInstance) {

this.pubnub = pubNubInstance;

this.signatureInterceptor = new SignatureInterceptor(pubNubInstance);

if (!pubNubInstance.getConfiguration().isGoogleAppEngineNetworking()) {

this.transactionClientInstance = createOkHttpClient(

this.transactionClientInstance = createOkHttpClient(this.pubnub.getConfiguration().getNonSubscribeRequestTimeout(), this.pubnub.getConfiguration().getConnectTimeout());

this.pubnub.getConfiguration().getNonSubscribeRequestTimeout(),

this.subscriptionClientInstance = createOkHttpClient(this.pubnub.getConfiguration().getSubscribeTimeout(), this.pubnub.getConfiguration().getConnectTimeout());

this.pubnub.getConfiguration().getConnectTimeout()

);

this.subscriptionClientInstance = createOkHttpClient(

this.pubnub.getConfiguration().getSubscribeTimeout(),

this.pubnub.getConfiguration().getConnectTimeout()

);

}

this.transactionInstance = createRetrofit(this.transactionClientInstance);

this.subscriptionInstance = createRetrofit(this.subscriptionClientInstance);

this.presenceService = transactionInstance.create(PresenceService.class);

this.historyService = transactionInstance.create(HistoryService.class);

this.pushService = transactionInstance.create(PushService.class);

this.accessManagerService = transactionInstance.create(AccessManagerService.class);

this.channelGroupService = transactionInstance.create(ChannelGroupService.class);

this.publishService = transactionInstance.create(PublishService.class);

this.subscribeService = subscriptionInstance.create(SubscribeService.class);

this.timeService = transactionInstance.create(TimeService.class);

this.signalService = transactionInstance.create(SignalService.class);

this.userService = transactionInstance.create(UserService.class);

this.spaceService = transactionInstance.create(SpaceService.class);

this.membershipService = transactionInstance.create(MembershipService.class);

this.memberService = transactionInstance.create(MemberService.class);

this.messageActionService = transactionInstance.create(MessageActionService.class);

}

private OkHttpClient createOkHttpClient(int requestTimeout, int connectTimeOut) {

PNConfiguration pnConfiguration = pubnub.getConfiguration();

OkHttpClient.Builder httpClient = new OkHttpClient.Builder();

httpClient.retryOnConnectionFailure(false);

httpClient.retryOnConnectionFailure(true);

httpClient.readTimeout(requestTimeout, TimeUnit.SECONDS);

httpClient.connectTimeout(connectTimeOut, TimeUnit.SECONDS);

if (pubnub.getConfiguration().getLogVerbosity() == PNLogVerbosity.BODY) {

HttpLoggingInterceptor logging = new HttpLoggingInterceptor();

logging.setLevel(HttpLoggingInterceptor.Level.BODY);

httpClient.addInterceptor(logging);

}

if (pubnub.getConfiguration().getHttpLoggingInterceptor() != null) {

httpClient.addInterceptor(pubnub.getConfiguration().getHttpLoggingInterceptor());

}

if (pnConfiguration.getSslSocketFactory() != null && pnConfiguration.getX509ExtendedTrustManager() != null) {

httpClient.sslSocketFactory(pnConfiguration.getSslSocketFactory(),

httpClient.sslSocketFactory(pnConfiguration.getSslSocketFactory(), pnConfiguration.getX509ExtendedTrustManager());

pnConfiguration.getX509ExtendedTrustManager());

}

if (pnConfiguration.getConnectionSpec() != null) {

httpClient.connectionSpecs(Collections.singletonList(pnConfiguration.getConnectionSpec()));

}

if (pnConfiguration.getHostnameVerifier() != null) {

httpClient.hostnameVerifier(pnConfiguration.getHostnameVerifier());

}

if (pubnub.getConfiguration().getProxy() != null) {

httpClient.proxy(pubnub.getConfiguration().getProxy());

}

if (pubnub.getConfiguration().getProxySelector() != null) {

httpClient.proxySelector(pubnub.getConfiguration().getProxySelector());

}

if (pubnub.getConfiguration().getProxyAuthenticator() != null) {

httpClient.proxyAuthenticator(pubnub.getConfiguration().getProxyAuthenticator());

}

if (pubnub.getConfiguration().getCertificatePinner() != null) {

httpClient.certificatePinner(pubnub.getConfiguration().getCertificatePinner());

}

httpClient.addInterceptor(this.signatureInterceptor);

OkHttpClient constructedClient = httpClient.build();

if (pubnub.getConfiguration().getMaximumConnections() != null) {

constructedClient.dispatcher().setMaxRequestsPerHost(pubnub.getConfiguration().getMaximumConnections());

}

return constructedClient;

}

private Retrofit createRetrofit(OkHttpClient client) {

Retrofit.Builder retrofitBuilder = new Retrofit.Builder();

if (pubnub.getConfiguration().isGoogleAppEngineNetworking()) {

retrofitBuilder.callFactory(new AppEngineFactory.Factory(pubnub));

}

retrofitBuilder = retrofitBuilder.baseUrl(pubnub.getBaseUrl()).addConverterFactory(this.pubnub.getMapper().getConverterFactory());

retrofitBuilder = retrofitBuilder

.baseUrl(pubnub.getBaseUrl())

.addConverterFactory(this.pubnub.getMapper().getConverterFactory());

if (!pubnub.getConfiguration().isGoogleAppEngineNetworking()) {

retrofitBuilder = retrofitBuilder.client(client);

}

return retrofitBuilder.build();

}

public void destroy(boolean force) {

if (this.transactionClientInstance != null) {

closeExecutor(this.transactionClientInstance, force);

}

if (this.subscriptionClientInstance != null) {

closeExecutor(this.subscriptionClientInstance, force);

}

private void closeExecutor(OkHttpClient client, boolean force) {

client.dispatcher().cancelAll();

if (force) {

client.connectionPool().evictAll();

ExecutorService executorService = client.dispatcher().executorService();

executorService.shutdown();

}