Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

check child is json or not in zookeeper.it will be continue if not. #14166

Merged
merged 29 commits into from
May 21, 2024
Merged

check child is json or not in zookeeper.it will be continue if not. #14166

Changes from 11 commits
Commits
Show all changes
29 commits
Select commit Hold shift + click to select a range
f020aa6
check child is json or not.it will be continue if not.
walkinggo May 8, 2024
d6042b2
try to save code format problem.
walkinggo May 8, 2024
cd2cc51
child could be json array.so child could start with { or [.
walkinggo May 8, 2024
d95f757
fix the problem of it will continue some message to make zookeeper ou…
walkinggo May 8, 2024
96298d8
try to continue the string without warn.
walkinggo May 8, 2024
e215a95
format the code.
walkinggo May 8, 2024
b10ddc8
Merge branch '3.2' into 3.2
AlbumenJ May 9, 2024
30fe20a
Merge branch '3.2' into 3.2
CrazyHZM May 10, 2024
7e1fa5c
catch the exception of JSONException.
walkinggo May 11, 2024
1022ca5
Merge remote-tracking branch 'origin/3.2' into 3.2
walkinggo May 11, 2024
f991fe2
try to fix java.lang.NoClassDefFoundError because of JSONException.
walkinggo May 11, 2024
2fe1d10
add isJson method and implement it in JSON.
walkinggo May 16, 2024
0cfde5c
implement the checkJson method and use it in ZookeeperRegistry
walkinggo May 16, 2024
144e8ac
format the code.
walkinggo May 16, 2024
036d242
add some test case.
walkinggo May 17, 2024
5c5f64a
format the code.
walkinggo May 17, 2024
897b9b3
format the code.
walkinggo May 17, 2024
1b17fa8
format the code.
walkinggo May 17, 2024
d192864
format the code.
walkinggo May 17, 2024
318b959
format the code.
walkinggo May 17, 2024
a33bb10
format the code.
walkinggo May 17, 2024
16bc553
format the code.
walkinggo May 17, 2024
22a7d8b
format the code.
walkinggo May 17, 2024
1b65455
format the code.
walkinggo May 17, 2024
3dcca3a
add some information.
walkinggo May 17, 2024
44ea28c
format the code.
walkinggo May 17, 2024
7835f39
add human friendly comment.
walkinggo May 20, 2024
f5c4bc0
format the code.
walkinggo May 20, 2024
8012e9f
format the code.
walkinggo May 20, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
15 changes: 14 additions & 1 deletion ...gistry-zookeeper/src/main/java/org/apache/dubbo/registry/zookeeper/ZookeeperRegistry.java
View file
Open in desktop
walkinggo marked this conversation as resolved.
Show resolved Hide resolved
Original file line number Diff line number Diff line change
Expand Up @@ -42,10 +42,15 @@
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.CountDownLatch;

import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;

import static org.apache.dubbo.common.constants.CommonConstants.ANY_VALUE;
import static org.apache.dubbo.common.constants.CommonConstants.CHECK_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.INTERFACE_KEY;
import static org.apache.dubbo.common.constants.CommonConstants.PATH_SEPARATOR;
import static org.apache.dubbo.common.constants.LoggerCodeConstants.PROTOCOL_ERROR_DESERIALIZE;
import static org.apache.dubbo.common.constants.LoggerCodeConstants.REGISTRY_ZOOKEEPER_EXCEPTION;
import static org.apache.dubbo.common.constants.RegistryConstants.CONFIGURATORS_CATEGORY;
import static org.apache.dubbo.common.constants.RegistryConstants.CONSUMERS_CATEGORY;
Expand Down Expand Up @@ -201,7 +206,15 @@ public void doSubscribe(final URL url, final NotifyListener listener) {
ChildListener zkListener = ConcurrentHashMapUtils.computeIfAbsent(
listeners, listener, k -> (parentPath, currentChildren) -> {
for (String child : currentChildren) {
child = URL.decode(child);
try {
child = URL.decode(child);
Object parse = JSON.parse(child);
walkinggo marked this conversation as resolved.
Show resolved Hide resolved
if (!(parse instanceof JSONObject) && !(parse instanceof JSONArray)) {
throw new Exception(child + "is not json");
}
} catch (Exception e) {
logger.warn(PROTOCOL_ERROR_DESERIALIZE, "", "", e.getMessage());
Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Enhance log content here

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

should i output more information here?

Copy link
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Yes, for some human friendly comment

}
if (!anyServices.contains(child)) {
anyServices.add(child);
subscribe(
Expand Down
Loading