Commit Graph

617 Commits

Author SHA1 Message Date
Daydreamer-ia
89b450537e Add the response to setup request. 2022-09-08 18:23:35 +08:00
KomachiSion
b7f25e07d2 For checkstyle. 2022-09-07 11:57:31 +08:00
KomachiSion
1e9b18cd75 only load grpc config from system one time. 2022-09-07 11:53:15 +08:00
KomachiSion
3d7bda84f7 Rename DefaultClientConfig > DefaultGrpcClientConfig 2022-09-07 10:21:36 +08:00
KomachiSion
fb71b4ccd9 Refactor DefaultClientConfig for readability. 2022-09-07 09:59:34 +08:00
Karson
b36e6a50ab
[ISSUE #9013] Enhance Rpc config related to one RpcClientConfig (#9093)
* enhance rpc config related to one RpcClientConfig

* modify rpcclient unit test

* modify rpcclient unit test

* modify rpcclient unit test

* add RpcClient constructor with properties.

* modify some unit test
2022-09-07 09:43:45 +08:00
阿魁
b8bd1cb90d
Fix the actual number of health check retries less than the set one. (#9080)
* Fix the actual number of health check retries less than the set one.

* update testHealthCheck.
2022-09-06 09:53:06 +08:00
Daydreamer-ia
138f0758eb Remove dead code. 2022-09-03 16:12:25 +08:00
Daydreamer-ia
ac2523ab7d Add the priority to AbilityControlManager. 2022-09-03 14:11:55 +08:00
Daydreamer-ia
182b821938 Remove the component listening to cluster ability, disable the cluster capability table when the connected server does not support capability negotiation. 2022-09-02 21:56:03 +08:00
Karson
0aa695e0d3
Add configurable for GrpcClient health check retry times (#9056)
* add configurable for GrpcClient health check retry.

* add some unit test for GrpcClient health check retry.

* reformat code style

* some grpc params move to GrpcConsts

* add GRpcConfigLabel

* reformat style

* reformat style

* reformat style

* reformat style

* reformat style
2022-09-02 15:48:14 +08:00
Daydreamer-ia
118cde52e7 Separate client capability and server capability: ClientAbilities and ServerAbilities. 2022-09-01 19:33:08 +08:00
Daydreamer-ia
a47f052c90 Remove the AbilityHandlePreProcessor and AbilityStatus. Change the way to get or remove AbilityTable for RpcClient. 2022-08-30 21:36:24 +08:00
MajorHe1
44538d1313
[ISSUE #8934] add header back after convert request to jsonBytes (#8935) 2022-08-30 10:27:33 +08:00
Karson
9819820b14
[ISSUE #9013] enhance grpc client (#9017)
* fix issue #9013

* reformat code style

* reformat code style

* reformat code style

* reformat code style

* reformat code style

* reformat code style

* reformat code style

* change config name

* do some enhance

* add queue size to configProperties

* reformat code style

* Change configuration load order
2022-08-29 10:04:24 +08:00
Daydreamer-ia
de9e113e24 Fix checkstyle 2022-08-28 19:10:55 +08:00
Daydreamer-ia
838c3d0ded Adapt the support of new ability control. 2022-08-28 18:20:35 +08:00
Daydreamer-ia
ce4fb189b8 Fix the bug that cannot load AbilityControlManager. 2022-08-28 18:08:29 +08:00
Daydreamer-ia
4275358975 Add the default implements for client and server. 2022-08-28 17:40:08 +08:00
Daydreamer-ia
4098297e51 Add the base implements for ability control. 2022-08-28 17:38:08 +08:00
Daydreamer-ia
a15ef8eb3a Add the base interface and entity for ability control. 2022-08-28 17:35:39 +08:00
chenhao26
3c8c6a7a14
add some utils UT (#9006)
add some utils UT
2022-08-22 15:43:22 +08:00
刘邵宇 ShaoyuLiu
3f75b3a2c5
[ISSUE #8993]Close input stream and output stream by try with resource[nacos-common] (#8997)
* [ISSUE #8993]Close input stream and output stream by try with resource[nacos-common]

* [ISSUE #8993]Close input stream and output stream by try with resource[nacos-common]

* [ISSUE #8993]Close input stream and output stream by try with resource[nacos-common]
2022-08-22 09:40:53 +08:00
Karson
3839cdc307
add unit test for ReflectUtils (#8999)
* add unit test for ReflectUtils

* reformat code
2022-08-22 09:38:01 +08:00
shiherua
ec134a3bc4
Improve code specifications. (#8965)
Flip the call to equals method to avoid null pointer exception.
2022-08-17 14:11:29 +08:00
liushaoyu-soft
474b25dff5
Update IoUtils.java (#8948)
An IOException has been catch,so throws IOException Is invalid
2022-08-12 16:42:38 +08:00
liushaoyu-soft
0c61c5d5eb
[ISSUES#8905]simplify some code (#8908) 2022-08-11 14:32:50 +08:00
ZhangShenao
5a9b1e961f
Add Generic Type for Simple Cache Map (#8812) 2022-08-01 15:33:54 +08:00
GuiShao
56104495da
[ISSUE#8481]Unified TRACE capacity building (#8805)
* [ISSUE#8481]Unified TRACE capacity building

* [ISSUE#8481]Unified TRACE capacity building
1. Event type add to traceEvent.
2. The event about instance add instancePort.
3. Add health check type to healthChangeEvent.
4. Other fixup.
2022-07-29 16:22:40 +08:00
KomachiSion
b0af8087b8 Add exception detail stacks when connect to server failed. 2022-07-26 15:12:01 +08:00
Oliver
667a34d7aa
Remove repeated conditional test (#8732) 2022-07-14 09:28:26 +08:00
MajorHe1
68b521679c
[ISSUE #8709] check serverList size before reconnect to server (#8710)
* [ISSUE #8709] check serverList size before reconnect to server

* use CollectionUtils.isEmpty to judge whether server list  is empty

Co-authored-by: Oliver <wqdyxnbd@163.com>

Co-authored-by: Oliver <wqdyxnbd@163.com>
2022-07-08 11:52:11 +08:00
xiaochangbai
ae1a1bec93
optimize: port offset constant (#8652)
* optimize: port offset constant

* optimize: code formatting

* remove extra spaces
2022-07-01 10:00:42 +08:00
liqipeng
bbbba1f453
Optimize GrpcUtils to reduce memory and cpu cost (#8593) 2022-06-23 11:12:09 +08:00
Cherish 蔡梦缘
747e2f9c25
feat(#8472): [Dependency Governance] replace org.apache.commons.logging.Log with org.slf4j.Logger. (#8472) (#8578) 2022-06-16 10:03:53 +08:00
GuiShao
a7d8066e41
[ISSUE#8481]Unified TRACE capacity building (#8521) 2022-06-14 15:39:46 +08:00
david6969xin
fa5fbd79e1
[ISSUE#8485] (module-common) replace the type specification in this constructor call with the diamond operator ("<>") (#8554) 2022-06-13 10:32:58 +08:00
liqipeng
f7a28105b2
[ISSUE #8428] fix naming subscribe bug when multiple NamingService (#8433) 2022-05-27 14:05:05 +08:00
ZhengBing520
7ca069db60
[ISSUE #8275] Fix ClassCastException: io.grpc.ClientInterceptors$InterceptorChannel cannot be cast to io.grpc.ManagedChannel (#8374) 2022-05-23 16:50:25 +08:00
Karson
89a0f89a8b
optimize IoUtils and Add some unit test (#8398)
* optimize IoUtils and Add some unit test

reformat codes

fix Too many unapproved license issue

fix Too many unapproved license issue

fix Too many unapproved license issue

fix Too many unapproved license issue

fix Too many unapproved license issue

* fix test case issue

* fix test case issue
2022-05-23 15:16:33 +08:00
Oliver
dbc1be8d8d
[ISSUE #8153]Fix AutoExpireCache NPE (#8162)
* Fix AutoExpireCache NPE

* add synchronized

* restore test

* add Null verification

* restore variable definition

* Fix NPE

* Add UT

* checkstyle
2022-05-20 14:52:26 +08:00
Endwas
b928568ce8
[ISSUE #7315] Unfiy Map's get and put methods by computeIfAbsent In ThreadPoolManager (#7304)
* Unfiy Map's get and put methods by computeIfAbsent In ThreadPoolManager

What is the purpose of the change
Optimization and tidy codes.

Brief changelog
Unfiy get/put by computeIfAbsent.

Verifying this change
eclipse-pmd was used to verify the changes

* Unfiy Map's get and put methods by computeIfAbsent In ThreadPoolManager

What is the purpose of the change
Optimization and tidy codes.

Brief changelog
Unfiy get/put by computeIfAbsent.

Verifying this change
eclipse-pmd was used to verify the changes
2022-05-16 10:36:04 +08:00
david6969xin
e17ea65954
[ISSUE#8358] make this anonymous inner class a lambda (common module) (#8368) 2022-05-16 10:18:01 +08:00
Oliver
f39add7900
Replace keySet() to entrySet() (#8281) 2022-04-29 23:02:32 +08:00
onewe
8980a960aa
[ISSUE #7487] Add generics for the CacheBuilder. (#7490) 2022-04-27 13:52:49 +08:00
nov.lzf
2e9c09d367
fix different client worker share same localsnapshot bug ,add properties to control whether load snaoshot content on startup in CacheData (#8202) 2022-04-24 13:33:28 +08:00
Oliver
a9e2cbd4d8
Set interrupted flag to caller (#8116) 2022-04-20 10:49:00 +08:00
Karson
44850cc732
[Optimize] RpcClient constructor (#8113)
* optimize RpcClient constructor

* edit RpcClient.java
2022-04-18 11:38:56 +08:00
Oliver
d52db5c81d
[Optimize] Use StandardCharsets.UTF_8 replace Charset.forName("UTF-8") (#8115)
* Improve performance

* checkstyle

* checkstyle
2022-04-11 10:10:01 +08:00
liqipeng
7319ff13c9
Change implementation of JacksonUtils methods about byte operation to reduce memory cost, especially when DistroProtocol fetching full data from peer node in the initialization phase. (#8072) (#8100) 2022-04-08 13:33:52 +08:00
lmw
c51b405565 [#8035] Missing serialVersionUID when class implements Serializable interface 2022-03-30 20:34:28 +08:00
chenhao26
b4cc3fcddb
Optimize HTTP constants (#7998)
* Optimize HTTP constants

* check nacos style

* check nacos style2

* check nacos style3

* deleet Unused constants in UtilAndComs
2022-03-25 16:05:42 +08:00
Pixy Yuan
2d0a8add41
Support cluster grpc client to set pool size (#7993)
* [ISSUE #7992] Support ThreadUtils preset processors count by property or env.

* [ISSUE #7992] Add thread pool params for cluster grpc client.
2022-03-25 15:04:12 +08:00
李晓双 Li Xiao Shuang
88fb26cfc6
[ISSUE #5695] Add config encrypt spi for nacos server. (#7934)
* [ISSUE#5695] Add a plugin SPI for configuration encryption and decryption for Nacos 2.0 (#6655)

* Defines the interface

* 增加aes实现

* 客户端、服务端加解密实现

* 客户端、服务端加解密实现

* fix code quality (#6727)

* [ISSUE#5695] Add a plugin SPI for configuration encryption and decryption for Nacos 2.0, EncryptedDataKey is persisted (#6740)

* Defines the interface

* 增加aes实现

* 客户端、服务端加解密实现

* 客户端、服务端加解密实现

* 秘钥持久化

* 秘钥持久化

* [ISSUE#5695] Summer2021 Cache encryptedDataKey  (#6878)

* Defines the interface

* 增加aes实现

* 客户端、服务端加解密实现

* 客户端、服务端加解密实现

* 秘钥持久化

* 秘钥持久化

* 秘钥缓存到内存中

* 解决冲突

* 修改filter继承AbstractConfigFilter (#6879)

* [ISSUE#5695] Summer2021   EncryptedDataKey is persisted to Derby (#6882)

* [ISSUE#5695] Add a plugin SPI for configuration encryption and decryption for Nacos 2.0 (#6655)

* Defines the interface

* 增加aes实现

* 客户端、服务端加解密实现

* 客户端、服务端加解密实现

* fix code quality (#6727)

* # This is a combination of 6 commits.tree cf7a399f99c4d81b8667c8de06f5ceb8c79fb6f0
parent 8024ecf31bf23a9edab416be8a3bfd1c0e48ce5e
author 李晓双 Li Xiao Shuang <644968328@qq.com> 1630028256 +0800
committer lixiaoshuang <644968328@qq.com> 1631804378 +0800

# This is a combination of 3 commits.
# This is the 1st commit message:

[ISSUE#5695] Add a plugin SPI for configuration encryption and decryption for Nacos 2.0, EncryptedDataKey is persisted (#6740)

* Defines the interface

* 增加aes实现

* 客户端、服务端加解密实现

* 客户端、服务端加解密实现

* 秘钥持久化

* 秘钥持久化
# This is the commit message #2:

[ISSUE#5695] Summer2021 Cache encryptedDataKey  (#6878)

* Defines the interface

* 增加aes实现

* 客户端、服务端加解密实现

* 客户端、服务端加解密实现

* 秘钥持久化

* 秘钥持久化

* 秘钥缓存到内存中

* 解决冲突
# This is the commit message #3:

修改filter继承AbstractConfigFilter (#6879)


# This is the commit message #6:

客户端、服务端加解密实现

* parent 8024ecf31bf23a9edab416be8a3bfd1c0e48ce5e
author 李晓双 Li Xiao Shuang <644968328@qq.com> 1630028256 +0800
committer lixiaoshuang <644968328@qq.com> 1631805204 +0800

parent 8024ecf31bf23a9edab416be8a3bfd1c0e48ce5e
author 李晓双 Li Xiao Shuang <644968328@qq.com> 1630028256 +0800
committer lixiaoshuang <644968328@qq.com> 1631804378 +0800

[ISSUE#5695] Add a plugin SPI for configuration encryption and decryption for Nacos 2.0, EncryptedDataKey is persisted (#6740)

* 配置加解密插件

* derby支持秘钥存储

* 克隆功能兼容配置加解密 (#6913)

* [ISSUE#5695] Summer2021 Import/export compatible with configuration encryption and decryption (#6956)

* 克隆功能兼容配置加解密

* 导入导出兼容配置加解密

* 秘钥base64编码、更换AES加密模式 (#6974)

* [ISSUE#5695] Summer2021 add unit test for ConfigCryptoFilter (#6991)

* add unit test for ConfigCryptoFilter

* add unit test for ConfigCryptoFilter

* [ISSUE#5695] Summer2021 add unit test for CryptoExecutor (#6990)

* add unit test for CryptoExecutor

* add Copyright

* [ISSUE#5695] Summer2021  add unit test for CryptoManager (#6989)

* add unit test for CryptoManager

* add unit test for CryptoManager

* [ISSUE#5695] Summer2021 add unit test for AesCrypto (#6988)

* add unit test for AesCrypto

* update AesCryptoTest

* Increased iv randomness

* add default Iv

* fix javadoc

* fix unit test

* defining plugin intergace

* Replace the client encryption and decryption actuator

* Replace the server encryption and decryption actuator

* add unit test

* add unit test

* remove old code

* fix NacosConfigServiceTest

* Encryption and decryption to achieve migration

Co-authored-by: 杨翊 SionYang <263976490@qq.com>
2022-03-16 10:54:11 +08:00
胡俊
2e07c6a0c1
Package scan (#7917)
* PayloadRegistry update use spi

* PayloadRegistry update use spi

* PayloadRegistry update use spi

* PayloadRegistry update use spi

* add test

* update comment

* remove code
rename code
2022-03-11 15:50:44 +08:00
zrlw
bc40318c66
[develop] set default connection lease request timeout and merge default config (#7906)
* set default connection lease request timeout and merge default config

* remove useless code

* correct comments of mergeDefaultConfig
2022-03-09 16:03:27 +08:00
胡俊
fdf90133a2
[ISSUE#7886]Feature package scan (#7895)
* for #7886

* nacos style

* nacos style

* code style

* .

* scan nacos style

* class reader

* class reader

* class reader

* class reader

* add comment

* update dependency

* update dependency

* rat update
check style update

* package change

* pdm exclude

* pdm update

* comment

* comment

* change pkg  final

* code structure update

* code style

* code style update
2022-03-08 20:11:21 +08:00
胡俊
3dddb75fed
optimization append (#7798) 2022-03-03 15:03:33 +08:00
zrlw
5df5baf491
log what causes I/O reactor status to STOPPED (#7723) 2022-02-21 15:47:27 +08:00
Karson
cb6526c845
[ISSUE #7837] add expire checking for AutoExpireCache in common util. (#7392) 2022-01-14 15:52:16 +08:00
shunfan-shao
a36d96acc8
Use LinkedHashMap to preserve string order (#7296)
* Use LinkedHashMap to preserve string order

* fix similar test
2022-01-09 22:31:22 +08:00
李晓双 Li Xiao Shuang
27ed668695
Strengthen the code (#7511) 2022-01-07 18:09:55 +08:00
onewe
9aeafd9359
[ISSUE #7411] fix NPE when the RpcClient shutdown (#7413)
* [ISSUE #7411] fix NPE when the RpcClient shutdown

- add unit test for this issue

* remove UnusedImports
2021-12-15 11:10:35 +08:00
caomingjie-code
f136dde8fa
优化代码。防止并发bug (#7341) 2021-12-07 10:25:01 +08:00
ethan
36f30dccd5
Add port offset configuration for the client when using reverse proxy to expose different nacos server ports (#7150) 2021-11-16 11:26:51 +08:00
吴治国
87ddbeff90
[ISSUE #6970] Add rest api v2 in core module (#7085)
* Add rest api v2 in core module

* merge cluster listNodes methods

* ut

* add beta annotation
2021-11-10 14:11:40 +08:00
赵延
1778a84964
Fix PushAckRequest mismatch problem. (#7179)
* fix PushAckRequest mismatch problem.

* add doc.

* add doc.
2021-11-08 10:23:14 +08:00
孙继峰
91706cf137
[ISSUE #6978] move unit test case that exist in integration test class (#7042)
* delete unit test case that already exist in HttpUtilsTest

* move unit test case to QueryTest

* move unit test case to ResponseHandlerTest

* delete empty test class
2021-10-11 09:50:31 +08:00
吴治国
a74eb55270
[ISSUE #5095] Add some testcases for common cache (#6950)
* add testcase for common cache

* license
2021-09-23 10:29:58 +08:00
吴治国
cdd2a8f5b8
[ISSUE #5095] Add testcase for common base64 (#6952)
* add testcase for common base64

* testcase

* license
2021-09-23 10:29:15 +08:00
吴治国
cf2b4a541a
[ISSUE #5095] Add some testcases for common executor (#6959)
* add some testcases for common executor

* style
2021-09-23 10:28:17 +08:00
BlackBAKA
1a53916329
[ISSUE #6628] Remove redundant functional interfaces (#6653) 2021-08-17 09:27:46 +08:00
secbro2
8801be513d
complete the warn log (#6646)
* complete the warn log

* format and optimize the log
2021-08-16 10:11:35 +08:00
brotherlu-xcq
46c1f7e6df
simple the logic of input RpcClient. (#6444) 2021-08-11 13:42:38 +08:00
孙继峰
2343a4ed14
add unit test to HttpUtils (#6617) 2021-08-11 13:34:18 +08:00
赵延
1a3c8cfb60
fix npe when connection is not established. (#6534) 2021-08-10 09:31:40 +08:00
孙继峰
4c1175acf0
add retryTimes check (#6594) 2021-08-09 10:05:42 +08:00
孙继峰
f91089eb90
[ISSUE #6595] Optimize RpcClient (#6596)
* replace explicit type argument with <>

* replace anonymous class with lambda

* remove redundant initializer

* format comment & log and fix typo

* add unit test to RpcClient::resolveServerInfo

* extend CollectionUtils::getOrDefault

* simplify RpcClient::resolveServerInfo

* remove unused variable
2021-08-09 09:42:37 +08:00
孙继峰
4a134b233c
add unit test to RpcClient (#6584) 2021-08-06 11:06:30 +08:00
ZZQ的
ca89efb620
remove guava Iterables (#6563) 2021-08-05 09:37:08 +08:00
ZZQ的
1119d0336f
Replace "ThreadFactoryBuilder" API with jdk API and add unit test (#6532) 2021-08-04 13:56:26 +08:00
ZZQ的
449480f68b
Refactor the cache to replace guava (#6520)
* Refactor the cache to replace guava

* Refactor CacheBuilder

* add unit test

* Format code
2021-08-03 09:30:26 +08:00
ZZQ的
b0f7bfbba7
replace "google.common.base.Preconditions" API with jdk API (#6502)
* replace "google.common.base.Preconditions" API with jdk API

* delete static method import "lenitentFoment"

* add unit test
2021-07-30 16:35:46 +08:00
ZZQ的
a729001ec5
[Reduce dependence]>[Sets] Replace "google.common.collect.*" API with… (#6445)
* [Reduce dependence]>[Sets] Replace "google.common.collect.*" API with jdk API

* delete empty line separator
2021-07-30 16:32:38 +08:00
ZZQ的
9beaacbc54
[Reduce dependence]>[Maps] Replace "google.common.collect.*" API with jdk API (#6443) 2021-07-29 10:46:22 +08:00
孙继峰
e3c9fcf2d7
[ISSUE #5095] Add unit test for RpcClientFactory (#6471)
* fix typo

* Add unit test for RpcClientFactory
2021-07-27 18:00:43 +08:00
ZZQ的
838a62cc4a
Replace "google.common.collect.Strings" API with jdk API (#6464) 2021-07-27 13:53:52 +08:00
ZZQ的
47c6706a63
[Reduce dependence]>[Lists] Replace "google.common.collect.*" API wit… (#6404)
* [Reduce dependence]>[Lists] Replace "google.common.collect.*" API with jdk API

* use elements.size to init the array length

* Replace IllegalArgumentException with NullPointerException

* Refactor CollectionUtilsTest#list()

* Add exception message

* update annotation

* update unit test method name
2021-07-27 13:47:41 +08:00
brotherlu-xcq
2b186bc3fe
[ISSUE #6367] Add IOReactorExceptionHandler to avoid IOReactor out of loop when meet unknown Network error. (#6441)
* Add IOExceptionHandler to handle the Exception form IOReactor.

* remove the systemProperties for create ConnectionManager.

* fix the javadoc.
2021-07-27 09:29:58 +08:00
ZZQ的
c52589fd03
[Reduce dependence]>[Iterators] Replace "google.common.collect.*" API with jdk API (#6447) 2021-07-26 09:29:43 +08:00
孙继峰
c464f7c8c0
[ISSUE #5095] Add unit test for TlsFileWatcher (#6453)
* Add unit test for TlsFileWatcher

* replace explicit type argument with <>

* replace anonymous Runnable with lambda

* 'catch' parameter named 'ignored' is used

* adjust log style
2021-07-26 09:26:52 +08:00
孙继峰
727446c022
[ISSUE #5095] Add unit test for SelfHostnameVerifier (#6428)
* replace the variable with a constant

* [ISSUE #5095] Add unit test for SelfHostnameVerifier
2021-07-23 10:38:33 +08:00
孙继峰
7587bf7685
[ISSUE #5095] Add unit test for JacksonUtils (#6415) 2021-07-22 09:57:26 +08:00
hunjipo
cdc276e829
To slightly improve performance, this commit switches to StringBuilder.append(char) instead of StringBuilder.append(String) whenever we append a single character to a StringBuilder. (#6300) 2021-07-12 13:51:14 +08:00
孙继峰
f326a0c543
[ISSUE #5095] Add unit test for ClassUtils (#6327)
* fix typo

* add unit test for ClassUtils
2021-07-12 09:45:35 +08:00
ZZQ的
98e1e72ed9
[issue #6284][naming module] replace *commons.lang3*.*Utils to com.al… (#6291)
* [issue #6284][naming module] replace *commons.lang3*.*Utils to com.alibaba.nacos.common.utils.*Utils

* add StringUtils.split() function

* Replace NumberUtils.isNumber()  -> NumberUtils.isDigits()
2021-07-12 09:16:57 +08:00
ZZQ的
b9e388bff9
[core module] replace *commons.lang3*.*Utils to com.alibaba.nacos.com… (#6288)
* [core module] replace *commons.lang3*.*Utils to com.alibaba.nacos.common.utils.*Utils

* Use StringUtils replace jdk String method.

* Fix error logic.
2021-07-08 15:13:34 +08:00
孙继峰
26caf8e97a
[ISSUE #5095] Add unit test for ConvertUtils (#6269)
* 100% cover ConvertUtils

* delete dead code

* simplify code
2021-07-08 15:09:38 +08:00
孙继峰
97abc6dd72
[ISSUE #5095] Add unit test for CollectionUtils (#6251) 2021-07-02 17:55:52 +08:00
ZZQ的
afb512b476
[ISSUE #6240] Add TypeUtils/TypeUtilsTest (#6247) 2021-07-02 17:55:15 +08:00
ZZQ的
2d40c5225b
[ISSUE #6241] Add DateFormatUtils、DateFormatUtilsTest (#6245)
* [ISSUE #6241] Add DateFormatUtils、DateFormatUtilsTest

* Format code
2021-07-02 17:53:19 +08:00
ZZQ的
119a193ba9
[ISSUE #6228] Add RandomUtils/RandomUtilsTest (#6243)
* [ISSUE #6228] Add RandomUtils/RandomUtilsTest

* [ISSUE #6228] Canonical code
2021-07-02 17:52:41 +08:00
ZZQ的
888f50b5e4
Add NumberUtils、NumberUtilsTest;Modify NumberUtil dependency (#6227)
* Add NumberUtils、NumberUtilsTest;Modify NumberUtil dependency

* delete "isNumber" function

* [ISSUE #6221] Canonical code
2021-07-02 17:46:32 +08:00
ZZQ的
80078ae8ee
[ISSUE#3102] nacos-common module ArrayUtils、StringUtils (#6211)
* add ArrayUtils and TestClass

* modified StringUtils for remove common-lang3

* add Comment for StringUtils, Completion unit test

* fix variable name error and erro test

* Optimize the code.

* Edit author
2021-07-01 14:28:49 +08:00
孙继峰
16734cdec9
[ISSUE #5095] Add unit test for InternetAddressUtil (#6222)
* add unit test to InternetAddressUtil

* inline variable

* simplify assert
2021-07-01 11:33:21 +08:00
孙继峰
f36556657f
[ISSUE #6197] Use java.util.Objects instead of com.alibaba.nacos.common.utils.Objects (#6218) 2021-07-01 11:32:34 +08:00
ZZQ的
4cd6c58a95
[ISSUE #6198] BUG nacos-common>utils>StringUtils.join method NullPointerException #6198 (#6213)
* [ISSUE #6198] fix bug

* format code

* Modify Comment.Remove toString()
2021-06-30 19:13:40 +08:00
孙继峰
8dcf38f65b
[ISSUE #5095]Add unit test for VersionUtils (#6195)
* replace with try with resource

* replace with lambda

* add unit test

* inline variable
2021-06-30 10:18:29 +08:00
赵延
3fd77bc7e0
If the client already disconnect, ignore this request to avoid NPE. (#6175)
* if the client already disconnect, ignore this request to avoid npe.

* unify code with DistroClientDataProcessor.

* print warn info when client already disconnect.

* transfer client check logic to method.

* if client is not ephemeral, is illegal.
2021-06-30 10:15:06 +08:00
杨翊 SionYang
f2676bc6ca
[ISSUE#6129] Add ServerConfigChangeEvent when config file changed. (#6130)
* Add ServerConfigChangeEvent when config file changed.

* Upgrade config after notify ServerConfigChangeEvent
2021-06-22 14:39:37 +08:00
孙继峰
fb3e5ad290
simplify Assert (#6095) 2021-06-17 19:17:37 +08:00
realJackSun
7f1f917839
[5989] Fix unit tests in nacos-common (#5994) 2021-06-08 13:24:48 +08:00
Pixy Yuan
4cbc6a4960
[ISSUE #5952] Feature make naming rpc client aware of server list change (#5974)
* [ISSUE #5952] Optimize rpcClient creation lock.

* [ISSUE #5952] Make naming rpc client aware of server list change.
2021-06-07 20:07:39 +08:00
nov.lzf
de6a4b803d
client aware server list change (#5952) 2021-06-04 19:34:38 +08:00
nov.lzf
55c6f44413
fix query sla multi connection model ;add rpc client error log; optimize client shutdown (#5949)
* fix multi connection model ,query sla

* add rpc client error log

* optimize client shutdown

* optimize client log
2021-06-04 15:27:32 +08:00
nov.lzf
3dc1a8cd96
fix ak sk and some tiny optimize (#5937)
* fix ak bug.

* fix ak bug.

* revert version
2021-06-04 09:41:40 +08:00
杨翊 SionYang
1d5a6605ee
[ISSUE#5918] Refactor event publisher in naming module to fix event without orders. (#5930)
* Rollback #5778.

* Add method to register custom sharded event publisher

* Make naming module event use custom sharded publisher
2021-06-03 12:53:29 +08:00
李晓双 Li Xiao Shuang
e199a5ee64
[ISSUE #5774] improve the code quality for naming core (#5914)
* mprove the code quality for naming core

* fix build
2021-06-03 09:59:52 +08:00
孙继峰
15c71831e7
[ISSUE #5765] fix localhost not match ip (#5852)
* rename IPUitl to InternetAddressUtil

* move isDomain to InternetAddressUtil

* [ISSUE #5765] fix localhost not match ip

* fix typo

* delete the verification IP, follow the single responsibility principle
2021-05-27 19:01:39 +08:00
xiaoheng1
6831de3111
Publisher code optimization (#5778)
* fix #5762 Publisher code optimization

* there is no subscriber, return directly.
2021-05-25 09:28:51 +08:00
brotherlu-xcq
f9d696beb4
[code quality] [nacos-common] [tls/utils] remove unnecessary symbol, export constant in class, change the Chinese javadoc to English (#5821) 2021-05-24 14:15:11 +08:00
brotherlu-xcq
4dafe6fa86
[code quality] [nacos-common] [remote/spi] remove unnecessary symbol, export constant in class. (#5820) 2021-05-24 14:10:38 +08:00
brotherlu-xcq
5089af1a1e
[code quality] [nacos-common] [notify/http] remove unnecessary symbol, export constant in class. (#5819) 2021-05-24 14:05:28 +08:00
KomachiSion
cf5a171ac5 Merge remote-tracking branch 'upstream/develop' into feature_support_grpc_core
# Conflicts:
#	NOTICE
#	api/pom.xml
#	common/src/main/java/com/alibaba/nacos/common/notify/DefaultPublisher.java
#	config/src/main/java/com/alibaba/nacos/config/server/service/LongPollingService.java
#	naming/src/test/java/com/alibaba/nacos/naming/consistency/persistent/impl/NamingSnapshotOperationTest.java
#	naming/src/test/java/com/alibaba/nacos/naming/core/DomainsManagerTest.java
#	naming/src/test/java/com/alibaba/nacos/naming/healthcheck/ClientBeatCheckTaskTest.java
#	pom.xml
#	test/src/test/java/com/alibaba/nacos/test/core/JacksonUtils.java
2021-05-14 11:04:52 +08:00
孙继峰
4ecf293fa7
[ISSUE #5704] adjust code style (#5705) 2021-05-14 10:07:52 +08:00
孙继峰
7ed7b45772
[ISSUE #5538] fix test case fail (#5620) 2021-05-14 09:38:20 +08:00
孙继峰
818d37b71c
delete duplicated dependency (#5622) 2021-05-10 10:43:58 +08:00
wql
a713203c66
IPv6 and IPv4 check rules are optimized. splitIPPortStr method adds IPv4 check, and the optimized method does not affect the startup of container environment (#5514)
* The IPv6 judgment logic in this method will obtain IP address according to the host. In the container environment, K8S has not allocated IP to this pod, and then the judgment will report an error. After finding this problem, I gave feedback to remove the IPv4 judgment, but this problem still exists in IPv6. Suggested to remove the verification logic can be in other ways to optimize.

* Revert "The IPv6 judgment logic in this method will obtain IP address according to the host. In the container environment, K8S has not allocated IP to this pod, and then the judgment will report an error. After finding this problem, I gave feedback to remove the IPv4 judgment, but this problem still exists in IPv6. Suggested to remove the verification logic can be in other ways to optimize."

This reverts commit a112e52

* Both IPv4 and IPv6 validation rules adopt regular validation. In order to prevent the container from adding domain name rule validation in the case of domain name resolution deployment, the logic of removing Chinese slogan should be added before the rule validation in IPv6.

* Optimize and add licenses according to Ali's protocol

* The isDomain method is changed to validate only rules

* Format to optimize
2021-04-30 09:14:08 +08:00
brothelul
d65453f163
format the code in DefaultPublisher.java, log.error and @Override issue (#5515) 2021-04-29 18:57:20 +08:00
KomachiSion
2847373fd0 Solve conflict 2021-04-27 16:19:56 +08:00
KomachiSion
92da848375 Merge remote-tracking branch 'upstream/develop' into merge-1.X-to-2.0
# Conflicts:
#	client/src/main/java/com/alibaba/nacos/client/config/NacosConfigService.java
#	client/src/main/java/com/alibaba/nacos/client/config/impl/CacheData.java
#	client/src/main/java/com/alibaba/nacos/client/config/impl/ClientWorker.java
#	client/src/main/java/com/alibaba/nacos/client/naming/core/PushReceiver.java
#	console/src/main/resources/static/css/main.css
#	console/src/main/resources/static/js/main.js
#	naming/src/main/java/com/alibaba/nacos/naming/core/SubscribeManager.java
#	naming/src/test/java/com/alibaba/nacos/naming/core/SubscribeManagerTest.java
#	test/src/test/java/com/alibaba/nacos/test/BaseTest.java
2021-04-27 15:57:24 +08:00
孙继峰
da3a1ea796
[ISSUE #5380] Use assert instead of System.out (#5472)
* use assert instead of System.out

* move test case, there is no file named ParamCheckUtil.java
2021-04-25 10:03:28 +08:00
孙继峰
3ce1cbab8b
fix #5390 (#5391) 2021-04-19 10:56:43 +08:00
杨翊 SionYang
73eea9c0bb
Use ThreadUtil and EnvUtil replace Runtime.availableProcessor (#5388) 2021-04-16 17:32:14 +08:00
xiaoheng1
acb02f6bf3
[ISSUE #5370]Modify the Chinese comments in MD5Utils to English (#5371)
* fix #5370 Modify the Chinese comments in MD5Utils to English

* code format
2021-04-16 11:00:11 +08:00
KomachiSion
51cc2b1b4b Merge remote-tracking branch 'upstream/develop' into feature_support_grpc_core
# Conflicts:
#	client/src/main/java/com/alibaba/nacos/client/config/NacosConfigService.java
#	client/src/main/java/com/alibaba/nacos/client/config/impl/CacheData.java
#	client/src/main/java/com/alibaba/nacos/client/config/impl/ClientWorker.java
#	client/src/test/java/com/alibaba/nacos/client/config/common/GroupKeyTest.java
#	common/src/test/resources/META-INF/services/com.alibaba.nacos.common.spi.SpiTestInterface
#	config/src/main/java/com/alibaba/nacos/config/server/controller/ConfigServletInner.java
#	console/src/main/resources/static/css/main.css
#	console/src/main/resources/static/js/main.js
#	istio/src/main/java/com/alibaba/nacos/istio/mcp/NacosMcpService.java
#	naming/src/main/java/com/alibaba/nacos/naming/controllers/ApiController.java
#	naming/src/main/java/com/alibaba/nacos/naming/controllers/CatalogController.java
#	naming/src/main/java/com/alibaba/nacos/naming/push/PushService.java
2021-04-13 14:28:30 +08:00
杨翊 SionYang
e689c1a3a1
Remove blocked thread for Protocol metadata (#5354) 2021-04-13 14:12:19 +08:00
Wu Zhiguo
9bcb901174
Fix some typo (#5260)
* fix some typo

* rollback some comment format
2021-04-03 12:57:57 +08:00
nov.lzf
46179d6664
fix cluster reconnection bug. (#5265) 2021-04-01 18:45:23 +08:00
杨翊 SionYang
d146e057c4
Fix ThreadPool usage problem and add some monitor for distro (#5237) 2021-03-30 16:27:41 +08:00
nov.lzf
a6a254a1c0
fix thread pool (#5233)
* fix thread pool

* fix log
2021-03-29 21:31:06 +08:00
赵延
cb289d31f7
fix thread name generate strategy. (#5139) 2021-03-23 09:25:35 +08:00
nov.lzf
9bb08d9f4d
remote reconnect bugfix (#5136)
* remote reconnect bugfix

* remote reconnect bugfix
2021-03-19 09:30:08 +08:00
KomachiSion
bd4b63d834 Merge remote-tracking branch 'upstream/feature_support_grpc_core' into develop-merge-to-2.0 2021-03-18 13:38:35 +08:00
nov.lzf
5fc13e9654
add client ip (#5134)
* add client  ip

* checkstyle fix

* wait to register connection setup
2021-03-18 13:22:10 +08:00
KomachiSion
6cda5ad55a Merge remote-tracking branch 'upstream/develop' into develop-merge-to-2.0
# Conflicts:
#	client/src/main/java/com/alibaba/nacos/client/naming/core/HostReactor.java
#	client/src/main/java/com/alibaba/nacos/client/naming/remote/http/NamingHttpClientProxy.java
#	client/src/test/java/com/alibaba/nacos/client/config/impl/YmlChangeParserTest.java
#	common/src/main/java/com/alibaba/nacos/common/http/param/Header.java
#	common/src/main/java/com/alibaba/nacos/common/utils/ConcurrentHashSet.java
#	config/src/main/java/com/alibaba/nacos/config/server/controller/ConfigController.java
#	console/src/main/resources/static/js/main.js
#	core/src/main/java/com/alibaba/nacos/core/cluster/ServerMemberManager.java
#	core/src/main/java/com/alibaba/nacos/core/utils/Loggers.java
#	naming/src/main/java/com/alibaba/nacos/naming/controllers/InstanceController.java
#	naming/src/main/java/com/alibaba/nacos/naming/healthcheck/HealthCheckReactor.java
#	pom.xml
2021-03-18 12:08:45 +08:00
haoyann
4029d32e01
fix ConcurrentHashSet compatibility problems (#5122) 2021-03-17 09:49:38 +08:00
nov.lzf
5247548e86
shade client and using remote ip from header (#5068)
* shade client

* shade client

* fix default cluster port

* rollback client ip

* using remote ip from header

* using remote ip from header

* using remote ip from header
2021-03-10 11:18:37 +08:00
haoyann
d80a272646
Remove extra semicolons (#5063) 2021-03-10 10:00:04 +08:00
nov.lzf
3afa7eac89
shutdown long connection where server rollback; use client submit client ip (#5013)
* use  client ip from connection setup request.

* reset remote connection for rollback

* npe bugfix

* npe bugfix

* stop long connection where server rollback

* stop long connection where server rollback
2021-03-05 09:28:01 +08:00