带新手入门之Dubbo+Nacos

Spring Boot + Dubbo + Nacos,使用一个简单的小例子带你入门

一.项目结构:

commons	公共的配置类以及实体类
dependencies	公共的依赖版本控制文件
shop-web	消费端
user-application	生产端

二.Dubbo的用法就不用说了,这里只简单提一下异常处理的两种处理方式:

(1)直接使用公共的异常类进行传递:

生产端及消费端共用异常类;当生产端抛出自定义异常时,消费端可以使用@RestControllerAdvice统一拦截异常处理响应;

(2)使用Dubbo自定义Filter配置,使用异常码等方式,将异常转换为特定的公共响应数据处理,例如:

@Activate(group = {CommonConstants.PROVIDER})
public class GDubboExceptionFilter implements Filter, Filter.Listener {
<span class="hljs-meta">@Override</span>
<span class="hljs-keyword">public</span> Result <span class="hljs-title function_">invoke</span><span class="hljs-params">(Invoker&lt;?&gt; invoker, Invocation invocation)</span> <span class="hljs-keyword">throws</span> RpcException {
    <span class="hljs-keyword">return</span> invoker.invoke(invocation);
}

<span class="hljs-meta">@Override</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">onResponse</span><span class="hljs-params">(Result appResponse, Invoker&lt;?&gt; invoker, Invocation invocation)</span> {
    <span class="hljs-keyword">if</span> (appResponse.hasException() &amp;&amp; GenericService.class != invoker.getInterface()) {
        <span class="hljs-keyword">try</span> {
            <span class="hljs-type">Throwable</span> <span class="hljs-variable">exception</span> <span class="hljs-operator">=</span> appResponse.getException();
            <span class="hljs-comment">//如果是自定义异常则转换</span>
            <span class="hljs-keyword">if</span> (exception <span class="hljs-keyword">instanceof</span> GException) {
                exception = (GException) exception;
                appResponse.setValue(<span class="hljs-keyword">new</span> <span class="hljs-title class_">ResultDTO</span>(ResultCodeEnum.EXCEPTION.getCode(), <span class="hljs-literal">null</span>,
                        ((GException) exception).getMsg(), <span class="hljs-literal">null</span>));
                appResponse.setException(<span class="hljs-literal">null</span>);
            }
        } <span class="hljs-keyword">catch</span> (Throwable e) {
        }
    }
}

<span class="hljs-meta">@Override</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">onError</span><span class="hljs-params">(Throwable e, Invoker&lt;?&gt; invoker, Invocation invocation)</span> {
    
}

}

指定组为生产端,只处理生产端的异常;也可同时指定为消费端,对Rpc响应数据进行自定义处理;

(3)以上两种方式要注意一个问题,就是要去除Dubbo自己的ExceptionFilter,查看源码可知,它会把你继承RuntimeException的自定义异常,包装为RuntimeException,以至于无法正常拦截到;

解决方式就是配置去除该过滤器: dubbo.provider.filter=-exception

三.多环境配置文件使用Nacos配置中心:

1.配置Nacos:

(1)首先在命名空间中创建新的空间;

(2)回到配置列表,点击上方的新建的不同的命名空间后,在下方新建配置文件;

2.正常使用本地多环境配置方式,将不同的Nacos命名空间ID填写到不同环境的配置文件即可,如:

nacos:
  server-addr: 127.0.0.1:8848
  config:
    namespace: 71c499c2-f171-4357-a8b5-e8fcba346b6a

XX.其余的可以看这个小Demo

本文由 GY 创作，采用知识共享署名4.0 国际许可协议进行许可
本站文章除注明转载/出处外，均为本站原创或翻译，转载前请务必署名
最后编辑时间为: 2021/11/19 15:20