本篇主要介绍dubbo-demo-api接口层和dubbo-demo-service层,介绍代码前,咱们先来回顾一下整个demo工程的结构
1.dubbo-demo-api
这里面主要是定义所有的接口,demo工程里就定义了一个测试接口,看一下该层的代码结构
DemoApi.java代码
package com.example.dubbo.demo.api; import java.util.List; import dubbo.demo.model.entity.Student; /** * Demo 接口定义 * @author * */ public interface DemoApi { String sayHello(String name); void add(Student student); List<Student> getAll(); }
2.dubbo-demo-service
该层主要实现api的接口,因此该层依赖api层,pom文件的依赖如下
<dependency> <groupId>com.example.dubbo</groupId> <artifactId>dubbo-demo-api</artifactId> <version>0.0.1-SNAPSHOT</version> </dependency>
说明:需要在api层执行install的maven命令,把api的jar包生打包到本地.m2仓库。
该层代码结构如下:
-
aop包主要是记录每一个service方法调用时的入参,返回值,执行时间、接口的全名称等信息。
-
impl包实现api的接口逻辑
-
mapper包是mybatis与数据库交互的方法,与mapper.xml对应
-
mapping文件夹下保存所有mapper.xml文件
-
dubbo-config.xml 是dubbo暴露服务的配置文件
impl/DemoApiImpl.java代码
package com.example.dubbo.demo.service.impl; import com.example.dubbo.demo.api.DemoApi; import com.example.dubbo.demo.service.mapper.StudentMapper; import dubbo.demo.model.entity.Student; import java.util.List; import org.apache.dubbo.config.annotation.Service; import org.springframework.beans.factory.annotation.Autowired; /** * * @author chenlong12 * */ @Service public class DemoApiImpl implements DemoApi { @Autowired private StudentMapper studentMapper; /** * 实现 sayHello 接口 * * @param name * @return */ @Override public String sayHello(String name) { return "Hello, " + name + " (from Spring Boot with dubbo-2.7.1)"; } @Override public void add(Student student) { // TODO Auto-generated method stub studentMapper.add(student); } @Override public List<Student> getAll() { // TODO Auto-generated method stub return studentMapper.getAll(); } }
mapper/StudentMapper.java代码
package com.example.dubbo.demo.service.mapper; import java.util.List; import dubbo.demo.model.entity.Student; public interface StudentMapper { void add(Student student); List<Student> getAll(); }
mapping/StudentMapper.xml代码
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.example.dubbo.demo.service.mapper.StudentMapper"> <resultMap id="StudentResultMap" type="dubbo.demo.model.entity.Student"> <result column="id" jdbcType="INTEGER" property="id" /> <result column="num" jdbcType="VARCHAR" property="num" /> <result column="name" jdbcType="VARCHAR" property="name" /> <result column="age" jdbcType="INTEGER" property="age" /> <result column="sex" jdbcType="VARCHAR" property="sex" /> </resultMap> <insert id="add" parameterType="dubbo.demo.model.entity.Student"> insert into student (num, name, age,sex) values (#{num},#{name},#{age},#{sex}) </insert> <!--我自己加的方法--> <select id="getAll" resultType="dubbo.demo.model.entity.Student"> select * from student </select> </mapper>
application.properties
dubbo-config.xml会引用该配置文件里的内容
spring.config.name=application # spring 的环境配置 spring.profiles.active=dev # 服务启动端口,即内置 tomcat 启动时占用的端口 server.port=8087 spring.aop.auto=true spring.datasource.driver-class-name=com.mysql.jdbc.Driver spring.datasource.url=jdbc:mysql://127.0.0.1:3306/school?useSSL=false&useUnicode=true&characterEncoding=UTF-8 spring.datasource.username= spring.datasource.password= mybatis.mapper-locations=classpath:mapping/*.xml mybatis.type-aliases-package=dubbo.demo.model.entity # dubbo config # 应用定义了提供方应用信息,用于计算依赖关系;在 dubbo-admin 或 dubbo-monitor 会显示这个名字,方便辨识 my.dubbo.application.name=dubbo-demo-service # 应用所属者 my.dubbo.application.owner=ll # 应用所属组织 my.dubbo.application.organization=ll # 使用 zookeeper 注册中心暴露服务,注意要先开启 zookeeper # 注册中心id my.dubbo.registry.id=zookeeper-registry # 注册中心协议 my.dubbo.registry.protocol=zookeeper # 注册中心地址 my.dubbo.registry.address=127.0.0.1:2181 # dubbo协议在20880端口暴露服务 # 协议名称 my.dubbo.protocol.name=dubbo # 协议端口 my.dubbo.protocol.port=20880 # 协议访问log my.dubbo.protocol.accesslog=dubbo-access.log # 重试次数 my.dubbo.provider.retries=0 # 超时时间 my.dubbo.provider.timeout=3000 # 注册监控中心 my.dubbo.monitor.protocol=registry
dubbo-config.xml
这dubbo的配置文件,所有的服务都是通过这个配置文件发布出去
<?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:dubbo="http://code.alibabatech.com/schema/dubbo" xsi:schemaLocation=" http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd"> <!-- 定义了提供方应用信息,用于计算依赖关系;在 dubbo-admin 或 dubbo-monitor 会显示这个名字 --> <dubbo:application name="${my.dubbo.application.name}" owner="ll" organization="ll" /> <!-- 使用 zookeeper 注册中心暴露服务,注意要先开启 zookeeper--> <dubbo:registry id="zookeeper-registry" protocol="${my.dubbo.registry.protocol}" address="${my.dubbo.registry.address}" /> <!-- dubbo协议在20880端口暴露服务 --> <dubbo:protocol name="${my.dubbo.protocol.name}" port="${my.dubbo.protocol.port}" accesslog="dubbo-access.log"/> <dubbo:provider retries="0" timeout="30000"/> <dubbo:monitor protocol="registry"/> <bean id="demoApiImpl" class="com.example.dubbo.demo.service.impl.DemoApiImpl"></bean> <!-- 使用 dubbo 协议实现定义好的 Service Api 接口--> <dubbo:service interface="com.example.dubbo.demo.api.DemoApi" ref="demoApiImpl" retries="0" timeout="60000"> <dubbo:method name="add" timeout="10000" retries="0" loadbalance="leastactive" actives="5" /> </dubbo:service> </beans>
详细的配置说明请参见dubbo官方文档
http://dubbo.apache.org/zh-cn/docs/user/references/xml/dubbo-service.html
DubboDemoServiceApplication.java
项目启动main方法,项目启动前需要先把zookeeper启动
package com.example.dubbo.demo.service; import org.apache.dubbo.config.spring.context.annotation.DubboComponentScan; import org.apache.dubbo.config.spring.context.annotation.EnableDubboConfig; import org.mybatis.spring.annotation.MapperScan; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.annotation.ImportResource; //@EnableDubboConfig //@DubboComponentScan("com.example.dubbo.demo.service.impl") @MapperScan("com.example.dubbo.demo.service.mapper") @SpringBootApplication @ImportResource(locations="classpath:dubbo-config.xml") public class DubboDemoServiceApplication { public static void main(String[] args) { SpringApplication.run(DubboDemoServiceApplication.class, args); } }
下一篇咱们介绍怎么用aop获取每一个service服务的入参、出参、执行时间等信息
相关推荐
Spring Framework、SpringMVC、SpringBoot、MyBatis、Dubbo、Redis、Elasticsearch、Spring Security、Thymeleaf、Mysql、Websocket ### 前端技术 Bootstrap、jQuery 1. 分布式:为了解藕和提高扩展性,将系统...
SpringBoot整合mybatis-plus实现多数据源的动态切换且支持分页查询,案例以postgresql和oracle数据库为数据源,分别使用mybatis-plus分页插件和pagehelper分页插件实现分页查询。
持久层:mybatis持久化,使用MyBatis-Plus优化,减少sql开发量;aop切换数据库实现读写分离。Transtraction注解事务。 MVC: 基于spring mvc注解,Rest风格Controller。Exception统一管理。 缓存和Session:注解redis...
此小demo是springboot集成dubbo,redis,mybatis,logbakc,aspect,等框架,利用Configuration配置,摆脱了xml形式的配置文件,实现springboot微服务,
简单的介绍这个项目是一个大学生信息管理系统,提供用户等级的登录注册数据管理,信息查询,信息修改(管理员权限),简单的数据可视化分析等功能,也有基本的安全性保障SpringBoot + Mybatis分支: : SpringBoot + ...
这个是我平时项目开发搭建的一u个系统架构,采用的是sprimgmvc+redis+mybatis+dubbo,有意向学习的可以拿来做借鉴。redis操作模块封装了一些常用的方法。5个资源分绝对值得你下载!
java筑基(二):并发+Netty+JVM Java架构面试专题及架构学习笔记 Dubbo服务框架面试专题及答案整理文档 BAT面试常问80题 23种设计模式知识要点整理 面试必备—API接口安全 面试必备—服务器推送技术 面试必备—...
微服务项目(SpringBoot+Mybatis+Dubbo+Mysql+Redis+RocketMQ) 数据结构与算法(Leetcode/剑指Offer) 设计模式 常用工具 如果观看不流畅,可以去我的博客浏览面试知识点 Dreamcats的公众号: 常用网站 :一款新闻聚合...
springboot-dubbo-two:Dubbo注解方式二 springboot-rocketmq-producer:RocketMQ生产者 springboot-rocketmq-consumer:RocketMQ消费者 springboot-elasticsearch:Elasticsearch springboot-custom-annotation:...
spring boot 实践学习案例,与其它组件结合如 mybatis、jpa、dubbo、redis、mongodb、memcached、kafka、rabbitmq、activemq、elasticsearch、security、shiro等 #### Spring Boot 版本 - 2.0.3.RELEASE #### 模块...
xml java系统源码 SpringCloud笔记 1、前言 1.1、回顾 ... 2.这么多服务?服务之间如何通信? 3.这么多服务?如何治理? 4.服务挂了怎么办? 解决方案: Spring Cloud 生态! SprintBoot 1.Spring
程序员面试刷题的书哪个好 SpringCloud笔记 1、前言 ... 2.这么多服务?服务之间如何通信? 3.这么多服务?如何治理? 4.服务挂了怎么办? 解决方案: Spring Cloud 生态! SprintBoot 1.Spring
2、对springboot,spring,mybatis,mybatis plus,mysql,freemarker等java技术有基本应用。 3、可大大提高开发效率,数据表创建完以后,自动生成entity,mapper.xml,dao,service,controller,vo,dto相关代码。 4、本...
spring 实践学习案例,与其它组件结合如 mybatis、jpa、dubbo、redis、mongodb、memcached、kafka、rabbitmq、activemq、shiro等 #### 软件架构 基于Java 1.8 #### Spring 版本 - 5.0.8.RELEASE #### 模块说明 - ...
持久层:mybatis持久化,使用MyBatis-Plus优化,减少sql开发量;aop切换数据库实现读写分离。Transtraction注解事务。 MVC: 基于spring mvc注解,Rest风格Controller。Exception统一管理。 调度:Spr
ElasticSearch(`基本操作和高级查询`)、Async(`异步任务`)、集成Dubbo(`采用官方的starter`)、MongoDB(`文档数据库`)、neo4j(`图数据库`)、docker(`容器化`)、`JPA多数据源`、`Mybatis多数据源`、`代码生成器`、Gray...
spring-dubbo-service微服务一,服务模块1,服务器配置:servlet,侦听器,拦截器,过滤器,aop,定时任务mybatis配置集成,多数据源;级联查询一对一对一对多注解配置及xml配置方式;分页处理:传递Page参数或继承...
xml java系统源码 自述 一个高可用,高效率,可重用性和...AOP加注解方式记录日志,日志内容清晰,记录方式简单.-- 简单易用的导出配置,助你5分钟实现导出,详见底部 强大的代码生成器助你快速开发,配合mybatisGenerate使用,
springboot例子, 包含druid数据源, druid的sql监控, druid过滤, mybatis xml配置, mybatis分页插件, logback日志配置, springboot多环境配置, 发送邮件, AOP拦截, 过滤器 spring拦截器, 全局异常, 统一响应, 自定义...
ElasticSearch(基本操作和高级查询)、Async(异步任务)、集成Dubbo(采用官方的starter)、MongoDB(文档数据库)、neo4j(图数据库)、docker(容器化)、JPA多数据源、Mybatis多数据源、代码生成器、GrayLog(日志收集)、...