微服务dubbo实践技术之二

举报
tea_year 发表于 2023/12/12 22:38:25 2023/12/12
【摘要】 1，课程回顾2，本章重点 父子工程的使用，子工程相互调用 springboot+mybatis+dubbo+zookeeper+mysql 部署一个dubbo_admin治理项目（可以对提供者和消费者进行管理） dubbo负载均衡功能3，具体内容3.1 springboot,mybatis整合dubbo 3.1.1创建父项目(springboot+mybatis方式创建)，pom.xml引入...

1，课程回顾

2，本章重点

父子工程的使用，子工程相互调用

springboot+mybatis+dubbo+zookeeper+mysql

部署一个dubbo_admin治理项目（可以对提供者和消费者进行管理）

dubbo负载均衡功能

3，具体内容

3.1 springboot,mybatis整合dubbo

3.1.1创建父项目(springboot+mybatis方式创建)，pom.xml引入jar：

<!--引入springboot 和dependencies并列-->

  <parent>

    <groupId>org.springframework.boot</groupId>

    <artifactId>spring-boot-starter-parent</artifactId>

    <version>2.5.7</version>

    <relativePath/> <!-- lookup parent from repository -->

  </parent>

 

<!--springboot web包-->

<dependency>

<groupId>org.springframework.boot</groupId>

<artifactId>spring-boot-starter-web</artifactId>

</dependency>

<!--简化实例类包-->

<dependency>

<groupId>org.projectlombok</groupId>

<artifactId>lombok</artifactId>

<optional>true</optional>

</dependency>

<!-- Spring Boot Dubbo 依赖 -->

<dependency>

<groupId>com.alibaba.spring.boot</groupId>

<artifactId>dubbo-spring-boot-starter</artifactId>

<version>2.0.0</version>

</dependency>

<!-- zookeeper依赖 -->

<dependency>

<groupId>com.101tec</groupId>

<artifactId>zkclient</artifactId>

<version>0.10</version>

</dependency>

3.1.2 创建子项目common

创建公共的实体类和服务层接口

3.1.3创建子项目consumer

pom.xml

<dependency>

<groupId>com.aaa</groupId>

<artifactId>common</artifactId>

<version>0.0.1-SNAPSHOT</version>

</dependency>

新建启动类并加入dubbo支持：

package com.aaa.pc;

import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.SpringBootConfiguration;

import org.springframework.boot.autoconfigure.SpringBootApplication;

/**

* @ fileName:PowerConsumerApplication

* @ description:

* @ author:zhz

* @ createTime:2022/1/5 9:51

* @ version:1.0.0

*/

@SpringBootApplication

@EnableDubboConfiguration //开启dubbo配置

public class PowerConsumerApplication {

public static void main(String[] args) {

//run方法

SpringApplication.run(PowerConsumerApplication.class,args);

}

}



编写controller，引入Service:


@Reference(check=false)

Dubbo 缺省会在启动时检查依赖的服务是否可用，不可用时会抛出异常，阻止 Spring 初始化完成，以便上线时，能及早发现问题，默认 check="true".

可以通过 check="false" 关闭检查，比如，测试时，有些服务不关心，或者出现了循环依赖，必须有一方先启动。

package com.aaa.pc.controller;

import com.aaa.common.controller.BaseController;

import com.aaa.common.entity.Menu;

import com.aaa.common.service.MenuService;

import com.aaa.common.util.Result;

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

import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;

import java.util.Map;

/**

* 菜单权限表(Menu)表控制层

*

* @author makejava

* @since 2022-01-05 09:45:33

*/

@RestController

@RequestMapping("menu")

public class MenuController extends BaseController {

/**

* 服务对象

*/

@Reference(check = false) //没有配置文件，直接使用引用注解

private MenuService menuService;

/**

* 通过主键查询单条数据

*

* @param id 主键

* @return 单条数据

*/

@GetMapping("selectOne")

public Result selectOne(Integer id) {

return this.success(this.menuService.queryById(id));

}


/**

* 添加

*

* @param menu

* @return

*/

@PutMapping("add")

public Result add(@RequestBody Menu menu) {

return this.success(this.menuService.insert(menu));

}

/**

* 更新

*

* @param menu

* @return

*/

@PutMapping("update")

public Result update(@RequestBody Menu menu) {

return this.success(this.menuService.update(menu));

}

/**

* 根据编号删除

*

* @param id

* @return

*/

@DeleteMapping("deleteById")

public Result deleteById(Integer id) {

return this.success(this.menuService.deleteById(id));

}

}

application.properties:

server:

port: 18090

spring:

dubbo:

application:

#应用名称

name: order_server_customer

protocol:

#协议名称及端口

name: dubbo

port: 10881

registry:

#注册中心地址

address: zookeeper://192.168.170.51:2181

3.1.4创建子项目provider

pom.xml

<dependency>

<groupId>com.aaa</groupId>

<artifactId>common</artifactId>

<version>1.0-SNAPSHOT</version>

</dependency>

<dependency>

<groupId>org.mybatis.spring.boot</groupId>

<artifactId>mybatis-spring-boot-starter</artifactId>

<version>2.2.0</version>

</dependency>

<dependency>

<groupId>mysql</groupId>

<artifactId>mysql-connector-java</artifactId>

<version>5.1.10</version>

</dependency>

<!--druid包-->

<dependency>

<groupId>com.alibaba</groupId>

<artifactId>druid</artifactId>

<version>1.2.8</version>

</dependency>

<dependency>

<groupId>com.alibaba</groupId>

<artifactId>druid-spring-boot-starter</artifactId>

<version>1.2.8</version>

</dependency>

启动类加入：

package com.aaa.pp;

import com.alibaba.dubbo.spring.boot.annotation.EnableDubboConfiguration;

import org.springframework.boot.SpringApplication;

import org.springframework.boot.autoconfigure.SpringBootApplication;

import org.springframework.transaction.annotation.EnableTransactionManagement;

/**

* @ fileName:PowerProviderApplication

* @ description:

* @ author:zhz

* @ createTime:2022/1/5 10:32

* @ version:1.0.0

*/

@SpringBootApplication

@EnableDubboConfiguration

//@EnableTransactionManagement

public class PowerProviderApplication {

public static void main(String[] args) {

SpringApplication.run(PowerProviderApplication.class,args);

}

}


编写服务实现类加入 @server

@com.alibaba.dubbo.config.annotation.Service

@Service 为dubbo 注解，注解暴露服务

application.properties:

server:

port: 19090

spring:

datasource:

#连接池配置

druid:

initial-size: 5

max-active: 20

max-wait: 10

min-idle: 10

username: root

password: root

url: jdbc:mysql://localhost:3306/db_qy153?useSSL=false&characterEncoding=utf-8&serverTimezone=Asia/Shanghai

dubbo:

#应用名称

application:

name: order_server_provider

protocol:

#协议名称和端口

name: dubbo

port: 10881

registry:

#zk注册中心地址配置

address: zookeeper://192.168.170.51:2181

mybatis:

#mapper位置配置

mapper-locations: classpath:mapper/*.xml

#控制台语句输出

configuration:

log-impl: org.apache.ibatis.logging.stdout.StdOutImpl

3.2 服务治理

3.2.1 多台zk集群

前面配置过，直接启动

3.2.2 配置治理项目，并且测试

配置tomcat

tar -xzvf /root/software/apache-tomcat-9.0.52.tar.gz -C /usr/

vim /etc/profile

修改为：


export PATH=$PATH:$JAVA_HOME/bin:$ZK_HOME/bin:/usr/apache-tomcat-9.0.52/bin

生效：

source /etc/profile

startup.sh

查看是否启动成功

jps 或者 ps -ef |grep tomcat |grep -v grep

jps 可以看到Bootstrap进程

复制准备好dubbo-admin项目到tomcat下

使用xft 把dubbo-admin.war上传到/usr/apache-tomcat-9.0.52/webapps/

修改配置

vim /usr/apache-tomcat-9.0.52/webapps/dubbo-admin/WEB-INF/dubbo.properties 

修改第一行：

127.0.0.1 修改为 192.168.xxx.41 (zk所在的机子IP)

启动zk集群：

/root/shelldir/zk-start-stop.sh

测试

http://192.168.170.41:8080/dubbo-admin /

3.2.3 启动提供者和消费者，查看admin项目变化



3.3 负载均衡，集群容错， 服务降级（半权） 路由规则，动态配置，访问控制，权重调节

打包生成多个服务：








cd soft/

使用xftp 把provider_jar上传

cd provider_jar/

java -jar

java -jar provider.jar

运行出错：slf4j-log4j12-1.7.26.jar

修改META-INF/MANIFEST.MF文件，删除slf4j-log4j12-1.7.26.jar包，再次打包运行

再次rebuild 时，要再次修改META-INF/MANIFEST.MF 文件中多余的jar









4，知识点总结

5，本章面试题




【版权声明】本文为华为云社区用户原创内容，转载时必须标注文章的来源（华为云社区）、文章链接、文章作者等基本信息， 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容，欢迎发送邮件进行举报，并提供相关证据，一经查实，本社区将立刻删除涉嫌侵权内容，举报邮箱： cloudbbs@huaweicloud.com
Dubbo
  • 点赞
  • 收藏
  • 关注作者

评论（0）

0/1000
抱歉，系统识别当前为高风险访问，暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称，即可参与社区互动！

*长度不超过10个汉字或20个英文字符，设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符，设置后3个月内不可修改。

确认 取消

加入云驻计划，成为创作者

  • 华为云周边好礼
  • 免费体验产品
  • 特殊身份标识
  • 线下官方门票
  • 内部专家零距离
  • 与10000+优质创作者共同成长
立即加入