文档章节

Spring Cloud+Dubbo对Feign进行RPC改造

算法之名
 算法之名
发布于 2018/11/01 11:25
字数 982
阅读 3.9W
收藏 6

「深度学习福利」大神带你进阶工程师,立即查看>>>

因为Spring Cloud Feign是基于Http Restful的调用,在高并发下的性能不够理想(虽然他是基于Ribbon以及带有熔断机制,可以防止雪崩),成为性能瓶颈,所以我们今天对Feign进行Dubbo的RPC改造。

我们Spring Cloud的项目结构如下

其中user-center是我们的用户中心,game-center是我们的游戏中心,以游戏中心调用用户中心的Feign如下

@Component
@FeignClient("user-center")
public interface UserClient {

    @PutMapping("/api-u/users-anon/internal/updateAppUser")
    AppUser updateUser(@RequestBody AppUser appUser);

    @PostMapping("/api-u/users-anon/internal/users/updateUserBanlance")
    String updateUserBanlance(@RequestParam("id") long id, @RequestParam("banlance") BigDecimal banlance);
}

我们先来改造用户中心作为Dubbo的提供者,pom添加Dubbo的引用

<dependency>
   <groupId>com.alibaba.spring.boot</groupId>
   <artifactId>dubbo-spring-boot-starter</artifactId>
   <version>2.0.0</version>
</dependency>
<dependency>
   <groupId>com.github.sgroschupf</groupId>
   <artifactId>zkclient</artifactId>
   <version>0.1</version>
</dependency>

将service接口放入公共模块api-model

public interface AppUserService {
   void addTestUser(AppUser user);

   void addAppUser(AppUser appUser);

   void updateAppUser(AppUser appUser);

   LoginAppUser findByUsername(String username);

   AppUser findById(Long id);

   void setRoleToUser(Long id, Set<Long> roleIds);

   void updatePassword(Long id, String oldPassword, String newPassword);

   void updateWithdrawal(Long id, String oldPassword, String newPassword);

   Page<AppUser> findUsers(Map<String, Object> params);

   Set<SysRole> findRolesByUserId(Long userId);

   void bindingPhone(Long userId, String phone);

   int updateUserBanlance(long id, BigDecimal banlance);

   Map<String, Object> findUserMapById(long userId);

   Page<Map<String, Object>> findUsers(String username, BigDecimal minBanlance, BigDecimal maxBanlance, String startTime, String endTime, Integer groupId, Integer control, int pageNo, int pageSize);

   void deleteTestUser(Assist assist);
}

用户中心资源配置,添加dubbo配置

spring:
  application:
    name: user-center
  cloud:
    config:
      discovery:
        enabled: true
        serviceId: config-center
      profile: dev
  dubbo:
    application:
      id: user-center-dubbo-prodiver
      name: user-center-dubbo-prodiver
    registry:
      address: zookeeper://192.168.5.129:2181
    server: true
    protocol:
      name: dubbo
      port: 20880

接口实现类的标签修改

@Slf4j
@Service(interfaceClass = AppUserService.class)
@Component
public class AppUserServiceImpl implements AppUserService {

其中这个@Service已经不再是spring的标签,而需要使用,

import com.alibaba.dubbo.config.annotation.Service;

的Dubbo标签

之前的spring @Service改用@Component

在Springboot的主类添加Dubbo的配置标签

@EnableDubboConfiguration
@EnableScheduling
@EnableSwagger2
@EnableFeignClients
@EnableDiscoveryClient
@SpringBootApplication
public class UserCenterApplication {

   public static void main(String[] args) {
      SpringApplication.run(UserCenterApplication.class, args);
   }

}

此时启动用户中心项目,可以在Dubbo主控台中看到

点进去可以看到提供者注册信息

然后再来看看游戏中心的消费者

pom依赖跟用户中心一样

资源文件配置添加Dubbo配置

spring:
  application:
    name: game-center
  cloud:
    config:
      discovery:
        enabled: true
        serviceId: config-center
      profile: dev
  dubbo:
    application:
      name: game-center-dubbo-consumer
      id: game-center-dubbo-consumer
    protocol:
      port: 20800
      name: dubbo
    registry:
      address: zookeeper://192.168.5.129:2181

在使用的Controller中注释掉之前的feign注入,使用Dubbo的接口

//    @Autowired
//    private UserClient userClient;
@Reference
private AppUserService appUserService;

因为该接口在公共模块api-model中,所以任何模块都可以识别的到,此时需要使用Dubbo的注释

import com.alibaba.dubbo.config.annotation.Reference;

在Springboot主类中添加Dubbo注释

@EnableDubboConfiguration
@EnableScheduling
@EnableSwagger2
@EnableFeignClients
@EnableDiscoveryClient
@SpringBootApplication
public class GameCenterApplication {

   public static void main(String[] args) {
      ApplicationContext context = SpringApplication.run(GameCenterApplication.class, args);
      SpringBootUtil.setApplicationContext(context);
   }
}

启动游戏中心项目,在Dubbo控制台中的消费者中,我们可以看到

点进去可以看到消费者注册信息

这样我们在实际使用中,将之前的feign代码改成直接使用该service接口就可以通过RPC的远程调用了

//调用userService更新用户信息 TODO
//        userClient.updateUser(user);
        appUserService.addAppUser(user);

最后就是进行压测,性能要绝对优于Feign调用的吞吐量。

另外Springboot Dubbo的调试直连提供者,只连接固定IP的提供者,绕过注册中心,不进行负载均衡

@Reference(url = "dubbo://192.168.5.33:20880")
private AppUserService appUserService;

此方法只能在测试时使用,生产环境中必须去掉。

消息只订阅

dubbo:
  application:
    id: user-center-dubbo-prodiver
    name: user-center-dubbo-prodiver
  registry:
    address: zookeeper://192.168.5.129:2188
    register: false
  server: true
  protocol:
    name: dubbo
    port: 20880

这么写,注册中心注册不到你,其他消费者调用不到你这个服务,只有像上面直连提供者那种才可以调用的到。

这个也只是在测试环境里面使用,生产环境必须去掉 register: false 

算法之名
粉丝 96
博文 223
码字总数 563436
作品 0
广州
私信 提问
加载中
此博客有 4 条评论,请先登录后再查看。
NSSplitView 扩展--DMSplitView

DMSplitView 对标准的 OS X 的 NSSplitView 控件进行改造,可满足更复杂的要求: 子视图的大小和约束 分隔条位置 可收缩伸展的子视图 动画变换效果 可控制分隔条的粗细和样式 可保存和恢复分...

匿名
2013/01/24
368
0
Go-node

Go-node 是一个用 Go 语言实现的 Erlang/OTP node 已支持的功能: Publish listen port via EPMD Handle incoming connection from other node using Erlang Distribution Protocol Spawn E......

匿名
2013/01/25
1.5K
1
PHP web 服务器--YACS

YACS 是一个强大的 PHP 脚本,可以让你维护一个动态的 Web 服务器。 特性: - Runs on your own server, or on a shared web site - Post articles with web forms, by e-mail, or remotely ......

匿名
2013/03/18
858
0
高效 Java Web 开发框架--JessMA

JessMA 是功能完备的高性能 Full-Stack Web 应用开发框架,内置可扩展的 MVC Web 基础架构和 DAO 数据库访问组件(内部已提供了 Hibernate、MyBatis 与 JDBC DAO 组件),集成了 Action 拦截...

伤神小怪兽
2012/11/13
9.2K
3
高性能跨语言 RPC--Hprose

Hprose 是高性能远程对象服务引擎(High Performance Remote Object Service Engine)的缩写 —— 微服务首选引擎。 它是一个先进的轻量级的跨语言跨平台面向对象的高性能远程动态通讯中间件...

andot
2012/12/27
6.1W
28

没有更多内容

加载失败,请刷新页面

加载更多

C#中const和readonly有什么区别? - What is the difference between const and readonly in C#?

问题: What is the difference between const and readonly in C#? C#中const和readonly什么区别? When would you use one over the other? 您什么时候可以使用另一个? 解决方案: 参考一...

fyin1314
28分钟前
25
0
百度地图SDK新版内测邀请

本文作者:用****9 百度地图开放平台为开发者提供七大基础服务能力,其中地图SDK和导航SDK是开发者广泛使用的重要基础服务,为了满足开发者更多使用需求以及提升开发者集成后的应用效果,本次...

百度开发者中心
前天
0
0
获取JavaScript数组中的所有唯一值(删除重复项) - Get all unique values in a JavaScript array (remove duplicates)

问题: I have an array of numbers that I need to make sure are unique. 我需要确定一个唯一的数字数组。 I found the code snippet below on the internet and it works great until th......

javail
今天
11
0
如何检查字符串是否为空? - How to check if the string is empty?

问题: Does Python have something like an empty string variable where you can do: Python是否有类似空字符串变量的内容可以在其中执行: if myString == string.empty: Regardless, wh......

富含淀粉
今天
19
0
您如何存储未跟踪的文件? - How do you stash an untracked file?

问题: I have changes to a file, plus a new file, and would like to use git stash to put them away while I switch to another task. 我对一个文件进行了更改,再加上一个新文件,并希......

技术盛宴
今天
39
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部