What’s New in Dubbo-go-hessian2 v1.7.0
Dubbo-go-hessian2 v1.7.0 已发布，详见 https://github.com/apache/dubbo-go-hessian2/releases/tag/v1.7.0， 以下对这次更新内容进行详细整理。
另外 v1.6.3 将 attachment 类型由 map[string]stiring 改为 map[string]interface{} 导致版本不兼容问题，这部分已还原，后续的计划是将 dubbo 协议的 request/response 对象整体迁移到 dubbogo 项目中进行迭代修改，hessian2 中将不再改动到 request/response 对象。
1. New Features
1.1 add GetStackTrace method into Throwabler and its implements. #207
contributed by https://github.com/cvictory
go 语言 client 请求 java 语言服务时，如果 java 语言抛出了异常，异常对应的堆栈信息是被保存在 StackTraceElement 中。
这个异常信息在日志中最好能被打印出来，以方便客户端排查问题，所以在 Throwabler 和对应子类中增加了 StackTraceElement 的获取。
注：其实还有一种更好的方法，所有的具体的异常类型都包含 java_exception/exception.go 的 Throwable struct 。这样只需要在 Throwable 中增加 GetStackTrace 方法就可以了。但是这种方式需要更多的测试验证，改动的逻辑相对会复杂一些。但是代码会更整洁。 这里先不用这种方法。
1.2 catch user defined exceptions. #208
contributed by https://github.com/cvictory
golang 中增加一个 java 中 Exception 对象的序列化输出方法：
func JavaException() []byte { e := hessian.NewEncoder() exception := java_exception.NewException("java_exception") e.Encode(exception) return e.Buffer() } 在 output/output.go 提供调用入口:添加如下函数初始化声明
func init() { funcMap["JavaException"] = testfuncs.JavaException } java 代码中增加调用 go 方法序列化结果: 说明: Assert.assertEquals 不能直接比较 Exception 对象是否相等
/** * test java java.lang.Exception object and go java_exception Exception struct */ @Test public void testException() { Exception exception = new Exception("java_exception"); Object javaException = GoTestUtil.readGoObject("JavaException"); if (javaException instanceof Exception) { Assert.assertEquals(exception.getMessage(), ((Exception) javaException).getMessage()); } } 1.3 support java8 time object. #212, #221
contributed by https://github.com/willson-chen, https://github.com/cyb-code
golang 中增加一个 java8 对象的序列化输出方法：
// test java8 java.time.Year func Java8TimeYear() []byte { e := hessian.NewEncoder() year := java8_time.Year{Year: 2020} e.Encode(year) return e.Buffer() } // test java8 java.time.LocalDate func Java8LocalDate() []byte { e := hessian.NewEncoder() date := java8_time.LocalDate{Year: 2020, Month: 9, Day: 12} e.Encode(date) return e.Buffer() } 在 output/output.go 提供调用入口:添加函数初始化声明
func init() { funcMap["Java8TimeYear"] = testfuncs.Java8TimeYear funcMap["Java8LocalDate"] = testfuncs.Java8LocalDate } java 代码中增加调用 go 方法序列化结果:
/** * test java8 java.time.* object and go java8_time/* struct */ @Test public void testJava8Year() { Year year = Year.of(2020); Assert.assertEquals(year , GoTestUtil.readGoObject("Java8TimeYear")); LocalDate localDate = LocalDate.of(2020, 9, 12); Assert.assertEquals(localDate, GoTestUtil.readGoObject("Java8LocalDate")); } 1.4 support test golang encoding data in java. #213
contributed by https://github.com/wongoo
为了更好的测试验证 hessian 库，原来已经支持在 golang 中测试 java 的序列化数据，现在增加在 java 中测试 golang 的序列化数据，实现双向测试验证。
golang 中增加序列化输出方法:
func HelloWorldString() []byte { e := hessian.NewEncoder() e.Encode("hello world") return e.Buffer() } 将该方法注册到 output/output.go 中
// add all output func here func init() { funcMap["HelloWorldString"] = testfuncs.HelloWorldString } output/output.go 提供调用入口:
func main() { flag.Parse() if *funcName == "" { _, _ = fmt.Fprintln(os.Stderr, "func name required") os.Exit(1) } f, exist := funcMap[*funcName] if !exist { _, _ = fmt.Fprintln(os.Stderr, "func name not exist: ", *funcName) os.Exit(1) } defer func() { if err := recover(); err != nil { _, _ = fmt.Fprintln(os.Stderr, "error: ", err) os.Exit(1) } }() if _, err := os.Stdout.Write(f()); err != nil { _, _ = fmt.Fprintln(os.Stderr, "call error: ", err) os.Exit(1) } os.Exit(0) } java 代码中增加调用 go 方法序列化结果:
public class GoTestUtil { public static Object readGoObject(String func) { System.out.println("read go data: " + func); try { Process process = Runtime.getRuntime() .exec("go run output/output.go -func_name=" + func, null, new File("..")); int exitValue = process.waitFor(); if (exitValue != 0) { Assert.fail(readString(process.getErrorStream())); return null; } InputStream is = process.getInputStream(); Hessian2Input input = new Hessian2Input(is); return input.readObject(); } catch (Exception e) { e.printStackTrace(); return null; } } private static String readString(InputStream in) throws IOException { StringBuilder out = new StringBuilder(); InputStreamReader reader = new InputStreamReader(in, StandardCharsets.UTF_8); char[] buffer = new char[4096]; int bytesRead; while ((bytesRead = reader.read(buffer)) != -1) { out.append(buffer, 0, bytesRead); } return out.toString(); } } 增加 java 测试代码:
@Test public void testHelloWordString() { Assert.assertEquals("hello world" , GoTestUtil.readGoObject("HelloWorldString")); } 1.5 support java.sql.Time & java.sql.Date. #219
contributed by https://github.com/zhangshen023
增加了 java 类 java.sql.Time, java.sql.Date 支持，分别对应到 hessian.Time 和 hessian.Date， 详见 https://github.com/apache/dubbo-go-hessian2/pull/219/files 。
2. Enhancement
2.1 Export function EncNull. #225
contributed by https://github.com/cvictory
开放 hessian.EncNull 方法，以便用户特定情况下使用。
3. Bugfixes
3.1 fix enum encode error in request. #203
contributed by https://github.com/pantianying
原来在 dubbo request 对象中没有判断 enum 类型的情况，此 pr 增加了判断是不是 POJOEnum 类型。详见 https://github.com/apache/dubbo-go-hessian2/pull/203/files
3.2 fix []byte field decoding issue. #216
contributed by https://github.com/wongoo
v1.7.0 之前如果 struct 中包含[]byte 字段时无法反序列化, 报错“error list tag: 0x29”，主要原因是被当做 list 进行处理，对于这种情况应该按照 binary 数据进行处理即可。
type Circular struct { Num int Previous *Circular Next *Circular ResponseDataBytes []byte // <---- } func (Circular) JavaClassName() string { return "com.company.Circular" } 3.3 fix decoding error for map in map. #229
contributed by https://github.com/wongoo
v1.7.0 之前嵌套 map 无法正确解析，主要原因是对应的 map 对象被当做一个数据类型却未被自动加到类引用列表中，而嵌套 map 类信息是同一类型的引用，去类引用列表找，找不到就报错了。 解决这个问题的方法就是遇到 map 类对象，也将其加入到类引用列表中即可。 问题详细参考 #119.
3.4 fix fields name mismatch in Duration class. #234
contributed by https://github.com/skyao
这个 PR 解决了 Duration 对象中字段错误定义，原来是”second/nano”， 应该是”seconds/nanos”。
同时改善了测试验证数据。之前使用 0 作为 int 字段的测试数据，这是不准确的，因为 int 类型默认值就是 0.
欢迎加入 dubbo-go 社区
有任何 dubbo-go 相关的问题，可以加我们的钉钉群 23331795 询问探讨，我们一定第一时间给出反馈。 