DUBBO项目构建问题记录

Wesley13
• 阅读 740

  目前公司需要对当前的业务进行微服务化改造,经过讨论选择使用用dubbo进行服务治理,并在我的业务功能模块中进行试点,由于之前写过dubbo相关的demo,基础知识就不再重复了,demo地址:

https://github.com/liujifei/dubbo.git

 工程的基本搭建参照了另一篇博客,写的十分详尽,推荐一下:

Maven多模块,Dubbo分布式服务框架,SpringMVC,前后端分离项目,基础搭建,搭建过程出现的问题

========================================================================================================================

基本配置完成之后,当使用组播的方式时没有发现问题,服务提供方和调用方都正常,当使用zk集群作为注册中心时,项目启动报错:

java.lang.NoClassDefFoundError: org/apache/curator/shaded/com/google/common/cache/CacheBuilder

处理方法:

在parent的pom.xml中dependencyManagement加入

org.apache.curator curator-framework 2.11.0

子module的pom.xml中加入

org.apache.curator curator-framework

问题解决。

另附zk集群配置方法:

< dubbo:registry address = "zookeeper://10.20.153.10:2181?backup=10.20.153.11:2181,10.20.153.12:2181" />

< dubbo:registry protocol = "zookeeper" address = "10.20.153.10:2181,10.20.153.11:2181,10.20.153.12:2181" />

同中心多组的配置方法:

< dubbo:registry id = "chinaRegistry" protocol = "zookeeper" address = "10.20.153.10:2181" group = "china" />

< dubbo:registry id = "intlRegistry" protocol = "zookeeper" address = "10.20.153.10:2181" group = "intl" />

若遇到其他问题再记录

2018-04-12 11:05:16

====================================================================================

上面的provider搞定了,之后就是consumer。之前的调用方式是简单的sdk调用,服务化之后,需要将原web工程改造为dubbo调用方。

具体改造内容很简单主要包括两个文件:

1、pom.xml

<dubbo.version>2.6.1</dubbo.version>

com.alibaba dubbo ${dubbo.version} com.alibaba dubbo-rpc-dubbo ${dubbo.version} com.alibaba dubbo-registry-api ${dubbo.version} com.alibaba dubbo-registry-zookeeper ${dubbo.version}

另外添加服务提供方api的依赖

2、spring-context.xml

 回调:

当provider需要调用consumer中的回调方法时,首先需要在provider的配置文件中修改如下:

<dubbo:service interface="com.***.quality.api.QualityService" ref="qualityService" protocol="dubbo">
<dubbo:method name="excuteJob" >
<dubbo:argument index="1" callback="true" type="com.inspur.quality.api.CallBack"/>

另外需要注意的是,callback作为调用方实现的回调方法,其中不要包含需要dubbo来序列化的对象以及调用其方法,否则会报如下错误:

com.alibaba.dubbo.remoting.RemotingException: Fail to decode request due to: RpcInvocation

如:

DUBBO项目构建问题记录 DUBBO项目构建问题记录

        qualityService.excuteJob(job);
        // 生产报告
        qualityService.productReport(new CallBack() {

            @Override
            public void productReport(String dataBaseName, RuleResult[] result, String jobId, String instanceId) {
                Long time = System.currentTimeMillis();
                for(RuleResult single : result){
                    StringBuilder sqlB = new StringBuilder();
                    sqlB.append("insert into ");
                    sqlB.append(RESULT_TABLE);
                    sqlB.append(" (RESULTID,JOBID,INSTANCEID,CHECKID,RESULT) VALUES ( '");
                    sqlB.append(UUID.randomUUID().toString());
                    sqlB.append("','");
                    sqlB.append(jobId);
                    sqlB.append("','");
                    sqlB.append(instanceId);
                    sqlB.append("','");
                    sqlB.append(single.getRule().getRuleName());
                    sqlB.append("','");
                    sqlB.append(single.getResultNumber());
                    sqlB.append("')");
                    
                    JdbcUtil.exeSql(dataBaseName, sqlB.toString());
                }
            }
        }, dataSources[2]);

View Code

需要改成

DUBBO项目构建问题记录 DUBBO项目构建问题记录

qualityService.excuteJob(job, new CallBack() {

            /**
             * @Field @serialVersionUID : TODO
             */
            private static final long serialVersionUID = -5914504806295102148L;

            @Override
            public String productReport(String dataBaseName, RuleResult[] result, String jobId, String instanceId) {
                Long time = System.currentTimeMillis();
                StringBuilder sqlB = new StringBuilder();
                for(RuleResult single : result){
                    sqlB.append("insert into ");
                    sqlB.append("QUALITY_RESULT");
                    sqlB.append(" (RESULTID,JOBID,INSTANCEID,CHECKID,RESULT) VALUES ( '");
                    sqlB.append(UUID.randomUUID().toString());
                    sqlB.append("','");
                    sqlB.append(jobId);
                    sqlB.append("','");
                    sqlB.append(instanceId);
                    sqlB.append("','");
                    sqlB.append(single.getRule().getRuleName());
                    sqlB.append("','");
                    sqlB.append(single.getResultNumber());
                    sqlB.append("')");
                    
                }
                return sqlB.toString();
            }
        }, dataSources[2]);

View Code

2018-04-18 15:14:13

=====================================================================================

java.lang.NoSuchMethodError: org.apache.curator.utils.ZKPaths.fixForNamespace

问题原因:curator-framework版本为2.11.0与原项目中的包有冲突,改为原项目中的版本2.6.0后,问题解决。

2018-04-23 15:46:31

=====================================================================================

代码的改造进行完之后,调用时发现报错如下:

服务提供方报错:

Caused by: com.alibaba.dubbo.remoting.RemotingException: com.alibaba.com.caucho.hessian.io.HessianProtocolException: 'com.***.quality.rule.MultiCountRule' could not be instantiated
com.alibaba.com.caucho.hessian.io.HessianProtocolException: 'com.***.quality.rule.MultiCountRule' could not be instantiated

Caused by: java.lang.reflect.InvocationTargetException

Caused by: java.lang.NullPointerException
at com.***.quality.rule.MultiCountRule.(MultiCountRule.java:27)

服务调用方报错:

com.alibaba.dubbo.rpc.RpcException: Failed to invoke the method excuteJob in the service com.***.quality.api.QualityService. Tried 3 times of the providers [192.168.138.1:20880] (1/1) from the registry 172.22.5.2:2181 on the consumer 192.168.138.1 using the dubbo version 2.6.1. Last error is: Failed to invoke remote method: excuteJob, provider: dubbo://192.168.138.1:20880/com.***.quality.api.QualityService?anyhost=true&application=crawlManage&check=false&dubbo=2.6.1&excuteJob.1.callback=true&generic=false&interface=com.***.quality.api.QualityService&methods=newExpectCountRule,registDataSource,newNotNullRule,newMultiCountRule,newPatternRule,newUniqueRule,excuteJob,newIntegrityRule,newDataCountRule&pid=115308&register.ip=192.168.138.1&remote.timestamp=1524468008733&revision=0.0.1-SNAPSHOT&side=consumer&timestamp=1524468416127, cause: Fail to decode request due to: RpcInvocation [methodName=excuteJob, parameterTypes=[class com.***.quality.common.QualityCheckJob, interface com.***.quality.api.CallBack, class java.lang.String], arguments=null, attachments={path=com.***.quality.api.QualityService, input=3355, dubbo=2.6.1, version=0.0.0}]

com.alibaba.dubbo.rpc.RpcException: Failed to invoke the method newMultiCountRule in the service com.***.quality.api.QualityService. Tried 3 times of the providers ......

Caused by: com.alibaba.dubbo.remoting.RemotingException: Fail to decode request due to: RpcInvocation [methodName=excuteJob, parameterTypes=[class com.***.quality.common.QualityCheckJob, interface com.***.quality.api.CallBack, class java.lang.String], arguments=null, attachments={path=com.***.quality.api.QualityService, input=3355, dubbo=2.6.1, version=0.0.0}]

问题是由于参数excuteJob中的属性MultiCountRule的类中没有默认构造方法,导致hessian不能正确序列化。

        qualityService.productReport(new CallBack() {
            /**             * @Field @serialVersionUID : TODO             */            private static final long serialVersionUID = -5914504806295102148L;
            @Override            public void productReport(String dataBaseName, RuleResult[] result, String jobId, String instanceId) {                Long time = System.currentTimeMillis();                for(RuleResult single : result){                    StringBuilder sqlB = new StringBuilder();                    sqlB.append("insert into ");                    sqlB.append("QUALITY_RESULT");                    sqlB.append(" (RESULTID,JOBID,INSTANCEID,CHECKID,RESULT) VALUES ( '");                    sqlB.append(UUID.randomUUID().toString());                    sqlB.append("','");                    sqlB.append(jobId);                    sqlB.append("','");                    sqlB.append(instanceId);                    sqlB.append("','");                    sqlB.append(single.getRule().getRuleName());                    sqlB.append("','");                    sqlB.append(single.getResultNumber());                    sqlB.append("')");                                        JdbcUtil.exeSql(dataBaseName, sqlB.toString());                }            }        }, dataSources[2]);

点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
待兔 待兔
4个月前
手写Java HashMap源码
HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22
Jacquelyn38 Jacquelyn38
3年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
Karen110 Karen110
3年前
​一篇文章总结一下Python库中关于时间的常见操作
前言本次来总结一下关于Python时间的相关操作,有一个有趣的问题。如果你的业务用不到时间相关的操作,你的业务基本上会一直用不到。但是如果你的业务一旦用到了时间操作,你就会发现,淦,到处都是时间操作。。。所以思来想去,还是总结一下吧,本次会采用类型注解方式。time包importtime时间戳从1970年1月1日00:00:00标准时区诞生到现在
Wesley13 Wesley13
3年前
00:Java简单了解
浅谈Java之概述Java是SUN(StanfordUniversityNetwork),斯坦福大学网络公司)1995年推出的一门高级编程语言。Java是一种面向Internet的编程语言。随着Java技术在web方面的不断成熟,已经成为Web应用程序的首选开发语言。Java是简单易学,完全面向对象,安全可靠,与平台无关的编程语言。
Stella981 Stella981
3年前
Django中Admin中的一些参数配置
设置在列表中显示的字段,id为django模型默认的主键list_display('id','name','sex','profession','email','qq','phone','status','create_time')设置在列表可编辑字段list_editable
Wesley13 Wesley13
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
为什么mysql不推荐使用雪花ID作为主键
作者:毛辰飞背景在mysql中设计表的时候,mysql官方推荐不要使用uuid或者不连续不重复的雪花id(long形且唯一),而是推荐连续自增的主键id,官方的推荐是auto_increment,那么为什么不建议采用uuid,使用uuid究
Python进阶者 Python进阶者
10个月前
Excel中这日期老是出来00:00:00,怎么用Pandas把这个去除
大家好,我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下:这日期老是出来00:00:00,怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下:pd.toexcel之前把这