mirror of
https://gitee.com/mirrors/Spring-Cloud-Alibaba.git
synced 2021-06-26 13:25:11 +08:00
Merge pull request #641 from slievrly/p3c_style
optimize code to match p3c check rules
This commit is contained in:
commit
8206a7714e
@ -60,6 +60,7 @@ public class DefaultHttpRequest implements HttpRequest {
|
|||||||
return HttpMethod.resolve(getMethodValue());
|
return HttpMethod.resolve(getMethodValue());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
public String getMethodValue() {
|
public String getMethodValue() {
|
||||||
return method;
|
return method;
|
||||||
}
|
}
|
||||||
|
@ -73,6 +73,7 @@ public class MutableHttpServerRequest implements HttpServerRequest {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Override method since Spring Framework 5.0
|
// Override method since Spring Framework 5.0
|
||||||
|
@Override
|
||||||
public String getMethodValue() {
|
public String getMethodValue() {
|
||||||
return httpMethod.name();
|
return httpMethod.name();
|
||||||
}
|
}
|
||||||
|
@ -44,8 +44,12 @@ public class DubboRestServiceMetadata {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean equals(Object o) {
|
public boolean equals(Object o) {
|
||||||
if (this == o) return true;
|
if (this == o) {
|
||||||
if (!(o instanceof DubboRestServiceMetadata)) return false;
|
return true;
|
||||||
|
}
|
||||||
|
if (!(o instanceof DubboRestServiceMetadata)) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
DubboRestServiceMetadata that = (DubboRestServiceMetadata) o;
|
DubboRestServiceMetadata that = (DubboRestServiceMetadata) o;
|
||||||
return Objects.equals(serviceRestMetadata, that.serviceRestMetadata) &&
|
return Objects.equals(serviceRestMetadata, that.serviceRestMetadata) &&
|
||||||
Objects.equals(restMethodMetadata, that.restMethodMetadata);
|
Objects.equals(restMethodMetadata, that.restMethodMetadata);
|
||||||
|
@ -77,8 +77,12 @@ public class DubboTransportedMethodMetadata {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean equals(Object o) {
|
public boolean equals(Object o) {
|
||||||
if (this == o) return true;
|
if (this == o) {
|
||||||
if (!(o instanceof DubboTransportedMethodMetadata)) return false;
|
return true;
|
||||||
|
}
|
||||||
|
if (!(o instanceof DubboTransportedMethodMetadata)) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
DubboTransportedMethodMetadata that = (DubboTransportedMethodMetadata) o;
|
DubboTransportedMethodMetadata that = (DubboTransportedMethodMetadata) o;
|
||||||
return Objects.equals(methodMetadata, that.methodMetadata) &&
|
return Objects.equals(methodMetadata, that.methodMetadata) &&
|
||||||
Objects.equals(attributes, that.attributes);
|
Objects.equals(attributes, that.attributes);
|
||||||
|
@ -110,8 +110,12 @@ public class MethodMetadata {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean equals(Object o) {
|
public boolean equals(Object o) {
|
||||||
if (this == o) return true;
|
if (this == o) {
|
||||||
if (o == null || getClass() != o.getClass()) return false;
|
return true;
|
||||||
|
}
|
||||||
|
if (o == null || getClass() != o.getClass()) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
MethodMetadata that = (MethodMetadata) o;
|
MethodMetadata that = (MethodMetadata) o;
|
||||||
return Objects.equals(name, that.name) &&
|
return Objects.equals(name, that.name) &&
|
||||||
Objects.equals(returnType, that.returnType) &&
|
Objects.equals(returnType, that.returnType) &&
|
||||||
|
@ -61,8 +61,12 @@ public class MethodParameterMetadata {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean equals(Object o) {
|
public boolean equals(Object o) {
|
||||||
if (this == o) return true;
|
if (this == o) {
|
||||||
if (o == null || getClass() != o.getClass()) return false;
|
return true;
|
||||||
|
}
|
||||||
|
if (o == null || getClass() != o.getClass()) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
MethodParameterMetadata that = (MethodParameterMetadata) o;
|
MethodParameterMetadata that = (MethodParameterMetadata) o;
|
||||||
return index == that.index &&
|
return index == that.index &&
|
||||||
Objects.equals(name, that.name) &&
|
Objects.equals(name, that.name) &&
|
||||||
|
@ -235,8 +235,12 @@ public class RequestMetadata {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean equals(Object o) {
|
public boolean equals(Object o) {
|
||||||
if (this == o) return true;
|
if (this == o) {
|
||||||
if (!(o instanceof RequestMetadata)) return false;
|
return true;
|
||||||
|
}
|
||||||
|
if (!(o instanceof RequestMetadata)) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
RequestMetadata that = (RequestMetadata) o;
|
RequestMetadata that = (RequestMetadata) o;
|
||||||
return Objects.equals(method, that.method) &&
|
return Objects.equals(method, that.method) &&
|
||||||
Objects.equals(path, that.path) &&
|
Objects.equals(path, that.path) &&
|
||||||
|
@ -183,8 +183,12 @@ public class RestMethodMetadata {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean equals(Object o) {
|
public boolean equals(Object o) {
|
||||||
if (this == o) return true;
|
if (this == o) {
|
||||||
if (!(o instanceof RestMethodMetadata)) return false;
|
return true;
|
||||||
|
}
|
||||||
|
if (!(o instanceof RestMethodMetadata)) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
RestMethodMetadata that = (RestMethodMetadata) o;
|
RestMethodMetadata that = (RestMethodMetadata) o;
|
||||||
return queryMapEncoded == that.queryMapEncoded &&
|
return queryMapEncoded == that.queryMapEncoded &&
|
||||||
Objects.equals(method, that.method) &&
|
Objects.equals(method, that.method) &&
|
||||||
|
@ -52,8 +52,12 @@ public class ServiceRestMetadata {
|
|||||||
|
|
||||||
@Override
|
@Override
|
||||||
public boolean equals(Object o) {
|
public boolean equals(Object o) {
|
||||||
if (this == o) return true;
|
if (this == o) {
|
||||||
if (!(o instanceof ServiceRestMetadata)) return false;
|
return true;
|
||||||
|
}
|
||||||
|
if (!(o instanceof ServiceRestMetadata)) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
ServiceRestMetadata that = (ServiceRestMetadata) o;
|
ServiceRestMetadata that = (ServiceRestMetadata) o;
|
||||||
return Objects.equals(url, that.url) &&
|
return Objects.equals(url, that.url) &&
|
||||||
Objects.equals(meta, that.meta);
|
Objects.equals(meta, that.meta);
|
||||||
|
@ -64,7 +64,7 @@ public abstract class AbstractSpringCloudRegistry extends FailbackRegistry {
|
|||||||
|
|
||||||
protected static final String DUBBO_METADATA_SERVICE_CLASS_NAME = DubboMetadataService.class.getName();
|
protected static final String DUBBO_METADATA_SERVICE_CLASS_NAME = DubboMetadataService.class.getName();
|
||||||
|
|
||||||
private static final Set<String> schedulerTasks = new HashSet<>();
|
private static final Set<String> SCHEDULER_TASKS = new HashSet<>();
|
||||||
|
|
||||||
protected final Logger logger = LoggerFactory.getLogger(getClass());
|
protected final Logger logger = LoggerFactory.getLogger(getClass());
|
||||||
|
|
||||||
@ -164,7 +164,7 @@ public abstract class AbstractSpringCloudRegistry extends FailbackRegistry {
|
|||||||
|
|
||||||
private void submitSchedulerTaskIfAbsent(URL url, NotifyListener listener) {
|
private void submitSchedulerTaskIfAbsent(URL url, NotifyListener listener) {
|
||||||
String taskId = url.toIdentityString();
|
String taskId = url.toIdentityString();
|
||||||
if (schedulerTasks.add(taskId)) {
|
if (SCHEDULER_TASKS.add(taskId)) {
|
||||||
schedule(() -> doSubscribeDubboServiceURLs(url, listener));
|
schedule(() -> doSubscribeDubboServiceURLs(url, listener));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -110,6 +110,7 @@ public class DubboGenericServiceFactory {
|
|||||||
dataBinder.registerCustomEditor(String.class, "listener", new StringTrimmerEditor(true));
|
dataBinder.registerCustomEditor(String.class, "listener", new StringTrimmerEditor(true));
|
||||||
dataBinder.registerCustomEditor(Map.class, "parameters", new PropertyEditorSupport() {
|
dataBinder.registerCustomEditor(Map.class, "parameters", new PropertyEditorSupport() {
|
||||||
|
|
||||||
|
@Override
|
||||||
public void setAsText(String text) throws java.lang.IllegalArgumentException {
|
public void setAsText(String text) throws java.lang.IllegalArgumentException {
|
||||||
// Trim all whitespace
|
// Trim all whitespace
|
||||||
String content = StringUtils.trimAllWhitespace(text);
|
String content = StringUtils.trimAllWhitespace(text);
|
||||||
|
@ -76,6 +76,7 @@ public class DubboGatewayServlet extends HttpServletBean {
|
|||||||
return serviceName;
|
return serviceName;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
public void service(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
|
public void service(HttpServletRequest request, HttpServletResponse response) throws IOException, ServletException {
|
||||||
|
|
||||||
String serviceName = resolveServiceName(request);
|
String serviceName = resolveServiceName(request);
|
||||||
|
@ -28,25 +28,25 @@ import java.util.concurrent.ConcurrentHashMap;
|
|||||||
*/
|
*/
|
||||||
public class NacosPropertySourceRepository {
|
public class NacosPropertySourceRepository {
|
||||||
|
|
||||||
private final static ConcurrentHashMap<String, NacosPropertySource> nacosPropertySourceRepository = new ConcurrentHashMap<>();
|
private final static ConcurrentHashMap<String, NacosPropertySource> NACOS_PROPERTY_SOURCE_REPOSITORY = new ConcurrentHashMap<>();
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* @return all nacos properties from application context
|
* @return all nacos properties from application context
|
||||||
*/
|
*/
|
||||||
public static List<NacosPropertySource> getAll() {
|
public static List<NacosPropertySource> getAll() {
|
||||||
List<NacosPropertySource> result = new ArrayList<>();
|
List<NacosPropertySource> result = new ArrayList<>();
|
||||||
result.addAll(nacosPropertySourceRepository.values());
|
result.addAll(NACOS_PROPERTY_SOURCE_REPOSITORY.values());
|
||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
|
|
||||||
public static void collectNacosPropertySources(
|
public static void collectNacosPropertySources(
|
||||||
NacosPropertySource nacosPropertySource) {
|
NacosPropertySource nacosPropertySource) {
|
||||||
nacosPropertySourceRepository.putIfAbsent(nacosPropertySource.getDataId(),
|
NACOS_PROPERTY_SOURCE_REPOSITORY.putIfAbsent(nacosPropertySource.getDataId(),
|
||||||
nacosPropertySource);
|
nacosPropertySource);
|
||||||
}
|
}
|
||||||
|
|
||||||
public static NacosPropertySource getNacosPropertySource(String dataId) {
|
public static NacosPropertySource getNacosPropertySource(String dataId) {
|
||||||
|
|
||||||
return nacosPropertySourceRepository.get(dataId);
|
return NACOS_PROPERTY_SOURCE_REPOSITORY.get(dataId);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -25,7 +25,7 @@ import feign.MethodMetadata;
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
*
|
*
|
||||||
* Using static field {@link SentinelContractHolder#metadataMap} to hold
|
* Using static field {@link SentinelContractHolder#METADATA_MAP} to hold
|
||||||
* {@link MethodMetadata} data
|
* {@link MethodMetadata} data
|
||||||
*
|
*
|
||||||
* @author <a href="mailto:fangjian0423@gmail.com">Jim</a>
|
* @author <a href="mailto:fangjian0423@gmail.com">Jim</a>
|
||||||
@ -38,7 +38,7 @@ public class SentinelContractHolder implements Contract {
|
|||||||
* map key is constructed by ClassFullName + configKey. configKey is constructed by
|
* map key is constructed by ClassFullName + configKey. configKey is constructed by
|
||||||
* {@link feign.Feign#configKey}
|
* {@link feign.Feign#configKey}
|
||||||
*/
|
*/
|
||||||
public final static Map<String, MethodMetadata> metadataMap = new HashMap();
|
public final static Map<String, MethodMetadata> METADATA_MAP = new HashMap<>();
|
||||||
|
|
||||||
public SentinelContractHolder(Contract delegate) {
|
public SentinelContractHolder(Contract delegate) {
|
||||||
this.delegate = delegate;
|
this.delegate = delegate;
|
||||||
@ -47,7 +47,7 @@ public class SentinelContractHolder implements Contract {
|
|||||||
@Override
|
@Override
|
||||||
public List<MethodMetadata> parseAndValidatateMetadata(Class<?> targetType) {
|
public List<MethodMetadata> parseAndValidatateMetadata(Class<?> targetType) {
|
||||||
List<MethodMetadata> metadatas = delegate.parseAndValidatateMetadata(targetType);
|
List<MethodMetadata> metadatas = delegate.parseAndValidatateMetadata(targetType);
|
||||||
metadatas.forEach(metadata -> metadataMap
|
metadatas.forEach(metadata -> METADATA_MAP
|
||||||
.put(targetType.getName() + metadata.configKey(), metadata));
|
.put(targetType.getName() + metadata.configKey(), metadata));
|
||||||
return metadatas;
|
return metadatas;
|
||||||
}
|
}
|
||||||
|
@ -90,7 +90,7 @@ public class SentinelInvocationHandler implements InvocationHandler {
|
|||||||
// only handle by HardCodedTarget
|
// only handle by HardCodedTarget
|
||||||
if (target instanceof Target.HardCodedTarget) {
|
if (target instanceof Target.HardCodedTarget) {
|
||||||
Target.HardCodedTarget hardCodedTarget = (Target.HardCodedTarget) target;
|
Target.HardCodedTarget hardCodedTarget = (Target.HardCodedTarget) target;
|
||||||
MethodMetadata methodMetadata = SentinelContractHolder.metadataMap
|
MethodMetadata methodMetadata = SentinelContractHolder.METADATA_MAP
|
||||||
.get(hardCodedTarget.type().getName()
|
.get(hardCodedTarget.type().getName()
|
||||||
+ Feign.configKey(hardCodedTarget.type(), method));
|
+ Feign.configKey(hardCodedTarget.type(), method));
|
||||||
// resource default is HttpMethod:protocol://url
|
// resource default is HttpMethod:protocol://url
|
||||||
|
@ -12,12 +12,12 @@ public class SmsProperties {
|
|||||||
/**
|
/**
|
||||||
* Product name.
|
* Product name.
|
||||||
*/
|
*/
|
||||||
public static final String smsProduct = "Dysmsapi";
|
public static final String SMS_PRODUCT = "Dysmsapi";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Product domain.
|
* Product domain.
|
||||||
*/
|
*/
|
||||||
public static final String smsDomain = "dysmsapi.aliyuncs.com";
|
public static final String SMS_DOMAIN = "dysmsapi.aliyuncs.com";
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Report queue name.
|
* Report queue name.
|
||||||
|
@ -60,7 +60,7 @@ public class SmsInitializerEventListener
|
|||||||
// 初始化acsClient,暂不支持region化
|
// 初始化acsClient,暂不支持region化
|
||||||
try {
|
try {
|
||||||
DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou",
|
DefaultProfile.addEndpoint("cn-hangzhou", "cn-hangzhou",
|
||||||
SmsProperties.smsProduct, SmsProperties.smsDomain);
|
SmsProperties.SMS_PRODUCT, SmsProperties.SMS_DOMAIN);
|
||||||
Collection<MessageListener> messageListeners = event.getApplicationContext()
|
Collection<MessageListener> messageListeners = event.getApplicationContext()
|
||||||
.getBeansOfType(MessageListener.class).values();
|
.getBeansOfType(MessageListener.class).values();
|
||||||
if (messageListeners.isEmpty()) {
|
if (messageListeners.isEmpty()) {
|
||||||
|
@ -85,8 +85,8 @@ public class DefaultAlicomMessagePuller {
|
|||||||
this.executorService = executorService;
|
this.executorService = executorService;
|
||||||
}
|
}
|
||||||
|
|
||||||
protected static final Map<String, Object> sLockObjMap = new HashMap<String, Object>();
|
protected static final Map<String, Object> S_LOCK_OBJ_MAP = new HashMap<>();
|
||||||
protected static Map<String, Boolean> sPollingMap = new ConcurrentHashMap<String, Boolean>();
|
protected static Map<String, Boolean> sPollingMap = new ConcurrentHashMap<>();
|
||||||
protected Object lockObj;
|
protected Object lockObj;
|
||||||
|
|
||||||
public boolean setPolling(String queueName) {
|
public boolean setPolling(String queueName) {
|
||||||
@ -309,11 +309,11 @@ public class DefaultAlicomMessagePuller {
|
|||||||
task.messageType = messageType;
|
task.messageType = messageType;
|
||||||
task.queueName = queueName;
|
task.queueName = queueName;
|
||||||
|
|
||||||
synchronized (sLockObjMap) {
|
synchronized (S_LOCK_OBJ_MAP) {
|
||||||
lockObj = sLockObjMap.get(queueName);
|
lockObj = S_LOCK_OBJ_MAP.get(queueName);
|
||||||
if (lockObj == null) {
|
if (lockObj == null) {
|
||||||
lockObj = new Object();
|
lockObj = new Object();
|
||||||
sLockObjMap.put(queueName, lockObj);
|
S_LOCK_OBJ_MAP.put(queueName, lockObj);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -355,11 +355,11 @@ public class DefaultAlicomMessagePuller {
|
|||||||
task.messageType = messageType;
|
task.messageType = messageType;
|
||||||
task.queueName = queueName;
|
task.queueName = queueName;
|
||||||
|
|
||||||
synchronized (sLockObjMap) {
|
synchronized (S_LOCK_OBJ_MAP) {
|
||||||
lockObj = sLockObjMap.get(queueName);
|
lockObj = S_LOCK_OBJ_MAP.get(queueName);
|
||||||
if (lockObj == null) {
|
if (lockObj == null) {
|
||||||
lockObj = new Object();
|
lockObj = new Object();
|
||||||
sLockObjMap.put(queueName, lockObj);
|
S_LOCK_OBJ_MAP.put(queueName, lockObj);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -402,11 +402,11 @@ public class DefaultAlicomMessagePuller {
|
|||||||
task.messageType = messageType;
|
task.messageType = messageType;
|
||||||
task.queueName = queueName;
|
task.queueName = queueName;
|
||||||
|
|
||||||
synchronized (sLockObjMap) {
|
synchronized (S_LOCK_OBJ_MAP) {
|
||||||
lockObj = sLockObjMap.get(queueName);
|
lockObj = S_LOCK_OBJ_MAP.get(queueName);
|
||||||
if (lockObj == null) {
|
if (lockObj == null) {
|
||||||
lockObj = new Object();
|
lockObj = new Object();
|
||||||
sLockObjMap.put(queueName, lockObj);
|
S_LOCK_OBJ_MAP.put(queueName, lockObj);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -76,6 +76,7 @@ public class QueryTokenForMnsQueueRequest
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
public Class<QueryTokenForMnsQueueResponse> getResponseClass() {
|
public Class<QueryTokenForMnsQueueResponse> getResponseClass() {
|
||||||
return QueryTokenForMnsQueueResponse.class;
|
return QueryTokenForMnsQueueResponse.class;
|
||||||
}
|
}
|
||||||
|
@ -60,6 +60,7 @@ public class QueryTokenForMnsQueueResponse extends AcsResponse {
|
|||||||
this.messageTokenDTO = messageTokenDTO;
|
this.messageTokenDTO = messageTokenDTO;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
public QueryTokenForMnsQueueResponse getInstance(UnmarshallerContext context) {
|
public QueryTokenForMnsQueueResponse getInstance(UnmarshallerContext context) {
|
||||||
return QueryTokenForMnsQueueResponseUnmarshaller.unmarshall(this, context);
|
return QueryTokenForMnsQueueResponseUnmarshaller.unmarshall(this, context);
|
||||||
}
|
}
|
||||||
|
@ -50,7 +50,7 @@ public class TokenGetterForAlicom {
|
|||||||
private String domainForPop;
|
private String domainForPop;
|
||||||
private IAcsClient iAcsClient;
|
private IAcsClient iAcsClient;
|
||||||
private Long ownerId;
|
private Long ownerId;
|
||||||
private final static String productName = "Dybaseapi";
|
private final static String PRODUCT_NAME = "Dybaseapi";
|
||||||
private long bufferTime = 1000 * 60 * 2;// 过期时间小于2分钟则重新获取,防止服务器时间误差
|
private long bufferTime = 1000 * 60 * 2;// 过期时间小于2分钟则重新获取,防止服务器时间误差
|
||||||
private final Object lock = new Object();
|
private final Object lock = new Object();
|
||||||
private ConcurrentMap<String, TokenForAlicom> tokenMap = new ConcurrentHashMap<String, TokenForAlicom>();
|
private ConcurrentMap<String, TokenForAlicom> tokenMap = new ConcurrentHashMap<String, TokenForAlicom>();
|
||||||
@ -68,7 +68,7 @@ public class TokenGetterForAlicom {
|
|||||||
}
|
}
|
||||||
|
|
||||||
private void init() throws ClientException {
|
private void init() throws ClientException {
|
||||||
DefaultProfile.addEndpoint(endpointNameForPop, regionIdForPop, productName,
|
DefaultProfile.addEndpoint(endpointNameForPop, regionIdForPop, PRODUCT_NAME,
|
||||||
domainForPop);
|
domainForPop);
|
||||||
IClientProfile profile = DefaultProfile.getProfile(regionIdForPop, accessKeyId,
|
IClientProfile profile = DefaultProfile.getProfile(regionIdForPop, accessKeyId,
|
||||||
accessKeySecret);
|
accessKeySecret);
|
||||||
|
Loading…
x
Reference in New Issue
Block a user