add kryo
diff --git a/dubbo-kryo-client/pom.xml b/dubbo-kryo-client/pom.xml
index a57b6a5..b4a2927 100644
--- a/dubbo-kryo-client/pom.xml
+++ b/dubbo-kryo-client/pom.xml
@@ -27,6 +27,11 @@
<groupId>com.esotericsoftware</groupId>
<artifactId>kryo</artifactId>
</dependency>
+ <dependency>
+ <groupId>org.apache.dubbo.extensions</groupId>
+ <artifactId>dubbo-serialization-kryo</artifactId>
+ <version>${dubbo-serialization-extension.version}</version>
+ </dependency>
</dependencies>
<build>
diff --git a/dubbo-kryo-client/src/main/java/org/apache/dubbo/benchmark/KryoClassInitializer.java b/dubbo-kryo-client/src/main/java/org/apache/dubbo/benchmark/KryoClassInitializer.java
new file mode 100644
index 0000000..5ceb894
--- /dev/null
+++ b/dubbo-kryo-client/src/main/java/org/apache/dubbo/benchmark/KryoClassInitializer.java
@@ -0,0 +1,32 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.dubbo.benchmark;
+
+import org.apache.dubbo.benchmark.bean.Page;
+import org.apache.dubbo.benchmark.bean.User;
+import org.apache.dubbo.common.serialize.kryo.utils.KryoUtils;
+
+import javax.annotation.PostConstruct;
+
+public class KryoClassInitializer {
+
+ @PostConstruct
+ public void registerKryo(){
+ KryoUtils.register(User.class);
+ KryoUtils.register(Page.class);
+ }
+}
diff --git a/dubbo-kryo-client/src/main/resources/consumer.xml b/dubbo-kryo-client/src/main/resources/consumer.xml
index 78cfd28..9b97ea7 100644
--- a/dubbo-kryo-client/src/main/resources/consumer.xml
+++ b/dubbo-kryo-client/src/main/resources/consumer.xml
@@ -7,6 +7,9 @@
<dubbo:application name="dubbo-kyro-client"/>
<dubbo:reference id="userService" check="false"
interface="org.apache.dubbo.benchmark.service.UserService"
- url="dubbo://${server.host}:${server.port}?optimizer=org.apache.dubbo.benchmark.serialize.SerializationOptimizerImpl&serialization=kryo"/>
+ url="dubbo://${server.host}:${server.port}?optimizer=org.apache.dubbo.benchmark.serialize.SerializationOptimizerImpl&serialization=kryo">
+ <dubbo:parameter key="prefer.serialization" value="kryo"/>
+ </dubbo:reference>
<dubbo:consumer client="netty4" filter="-default"/>
+ <bean id="kryoClassInitializer" class="org.apache.dubbo.benchmark.KryoClassInitializer"/>
</beans>
\ No newline at end of file
diff --git a/dubbo-kryo-server/pom.xml b/dubbo-kryo-server/pom.xml
index 67f2f1a..994f88e 100644
--- a/dubbo-kryo-server/pom.xml
+++ b/dubbo-kryo-server/pom.xml
@@ -22,6 +22,11 @@
<groupId>de.javakaffee</groupId>
<artifactId>kryo-serializers</artifactId>
</dependency>
+ <dependency>
+ <groupId>org.apache.dubbo.extensions</groupId>
+ <artifactId>dubbo-serialization-kryo</artifactId>
+ <version>${dubbo-serialization-extension.version}</version>
+ </dependency>
</dependencies>
<build>
diff --git a/dubbo-kryo-server/src/main/java/org/apache/dubbo/benchmark/KryoClassInitializer.java b/dubbo-kryo-server/src/main/java/org/apache/dubbo/benchmark/KryoClassInitializer.java
new file mode 100644
index 0000000..5ceb894
--- /dev/null
+++ b/dubbo-kryo-server/src/main/java/org/apache/dubbo/benchmark/KryoClassInitializer.java
@@ -0,0 +1,32 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.dubbo.benchmark;
+
+import org.apache.dubbo.benchmark.bean.Page;
+import org.apache.dubbo.benchmark.bean.User;
+import org.apache.dubbo.common.serialize.kryo.utils.KryoUtils;
+
+import javax.annotation.PostConstruct;
+
+public class KryoClassInitializer {
+
+ @PostConstruct
+ public void registerKryo(){
+ KryoUtils.register(User.class);
+ KryoUtils.register(Page.class);
+ }
+}
diff --git a/dubbo-kryo-server/src/main/resources/provider.xml b/dubbo-kryo-server/src/main/resources/provider.xml
index c0ba8cd..87fae41 100644
--- a/dubbo-kryo-server/src/main/resources/provider.xml
+++ b/dubbo-kryo-server/src/main/resources/provider.xml
@@ -10,4 +10,5 @@
<dubbo:registry address="N/A"/>
<dubbo:service interface="org.apache.dubbo.benchmark.service.UserService" ref="userService" filter="-default"/>
<bean id="userService" class="org.apache.dubbo.benchmark.service.UserServiceServerImpl"/>
+ <bean id="kryoClassInitializer" class="org.apache.dubbo.benchmark.KryoClassInitializer"/>
</beans>
\ No newline at end of file
diff --git a/pom.xml b/pom.xml
index d9d78a4..d68c94c 100644
--- a/pom.xml
+++ b/pom.xml
@@ -15,10 +15,10 @@
<dubbo.version>3.2.11</dubbo.version>
<dubbo-serialization-extension.version>1.0.1</dubbo-serialization-extension.version>
<netty.version>4.1.107.Final</netty.version>
- <kryo.version>4.0.2</kryo.version>
+ <kryo.version>5.3.0</kryo.version>
<avro.version>1.11.3</avro.version>
<protostuff.version>1.8.0</protostuff.version>
- <kryo-serializers.version>0.42</kryo-serializers.version>
+ <kryo-serializers.version>0.45</kryo-serializers.version>
<fst.version>2.48-jdk-6</fst.version>
<jmh.version>1.21</jmh.version>
<slf4j.version>1.7.25</slf4j.version>
