`
天空晴朗
  • 浏览: 25406 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

(十六) 构建dubbo分布式平台-dubbo服务接口定义

阅读更多

在前面的章节中,我们着手介绍了dubbo的相关知识,在这个基础之上,我们可以考虑将dubbo服务应用于我们的分布式系统了,从今天开始,我们会详细介绍如何将dubbo和spring集成并应用于我们的分布式系统。

 

1. 创建ant-bookmark-facade项目(dubbo服务接口),其中pom.xml文件定义如下:

<?xml version="1.0"?>
<project
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.sml.sz</groupId>
<artifactId>ant-project</artifactId>
<version>1.0.0</version>
</parent>
<artifactId>ant-member-facade</artifactId>
<packaging>jar</packaging>
<name>ant-member-facade</name>
<url>http://maven.apache.org</url>
<description>ant的收藏模块Dubbo服务接口包,提供相关的Dubbo服务入口</description>
 
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- ant framework begin -->
<!--  系统核心框架包 -->
<dependency>
<groupId>com.sml.sz</groupId>
<artifactId>ant-framework</artifactId>
</dependency>
<!-- ant framework end -->
</dependencies>
</project>
<?xml version="1.0"?>
<project
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"
xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>com.sml.sz</groupId>
<artifactId>ant-project</artifactId>
<version>1.0.0</version>
</parent>
<artifactId>ant-member-facade</artifactId>
<packaging>jar</packaging>
<name>ant-member-facade</name>
<url>http://maven.apache.org</url>
<description>ant的会员模块Dubbo服务接口包,提供相关的Dubbo服务入口</description>
 
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<!-- ant framework begin -->
<!--  系统核心框架包 -->
<dependency>
<groupId>com.sml.sz</groupId>
<artifactId>ant-framework</artifactId>
</dependency>
<!-- ant framework end -->
</dependencies>
</project>

2. 定义实体entity,因为接口中的对象要使用

package com.sml.sz.bookmark.entity;

import org.hibernate.validator.constraints.Length;

import com.sml.sz.common.persistence.DataEntity;

/**
 * 我的收藏链接管理Entity
 * 
 * @author ant
 * @version 2016-01-30
 */
public class Bookmark extends DataEntity<Bookmark> {

	private static final long serialVersionUID = 1L;
	private String tagId;
	private BookmarkTag bookmarkTag; // 业务主表ID 父类
	private String bookmarkname; // 名称
	private String bookmarkurl; // 名称

	public Bookmark() {
		super();
	}

	public Bookmark(String id) {
		super(id);
	}

	public Bookmark(BookmarkTag bookmarkTag) {
		this.tagId = bookmarkTag.getId();
		this.bookmarkTag = bookmarkTag;
	}

	@Length(min = 1, max = 64, message = "业务主表ID长度必须介于 1 和 64 之间")
	public String getTagId() {
		return tagId;
	}

	public void setTagId(String tagId) {
		this.tagId = tagId;
	}

	@Length(min = 1, max = 100, message = "名称长度必须介于 1 和 100 之间")
	public String getBookmarkname() {
		return bookmarkname;
	}

	public void setBookmarkname(String bookmarkname) {
		this.bookmarkname = bookmarkname;
	}

	@Length(min = 1, max = 100, message = "名称长度必须介于 1 和 100 之间")
	public String getBookmarkurl() {
		return bookmarkurl;
	}

	public void setBookmarkurl(String bookmarkurl) {
		this.bookmarkurl = bookmarkurl;
	}

	public BookmarkTag getBookmarkTag() {
		return bookmarkTag;
	}

	public void setBookmarkTag(BookmarkTag bookmarkTag) {
		this.bookmarkTag = bookmarkTag;
	}

}
package com.sml.sz.bookmark.entity;

import java.util.List;

import org.hibernate.validator.constraints.Length;

import com.google.common.collect.Lists;
import com.sml.sz.common.persistence.DataEntity;

/**
 * 我的收藏链接管理Entity
 * @author ant
 * @version 2016-01-30
 */
public class BookmarkTag extends DataEntity<BookmarkTag> {
	
	private static final long serialVersionUID = 1L;
	private String bookmarktagname;		// 标签名称
	private List<Bookmark> bookmarkList = Lists.newArrayList();		// 子表列表
	
	public BookmarkTag() {
		super();
	}

	public BookmarkTag(String id){
		super(id);
	}

	@Length(min=1, max=64, message="标签名称长度必须介于 1 和 64 之间")
	public String getBookmarktagname() {
		return bookmarktagname;
	}

	public void setBookmarktagname(String bookmarktagname) {
		this.bookmarktagname = bookmarktagname;
	}
	
	public List<Bookmark> getBookmarkList() {
		return bookmarkList;
	}

	public void setBookmarkList(List<Bookmark> bookmarkList) {
		this.bookmarkList = bookmarkList;
	}
}

  

3. 定义接口类,此类会在dubbo生产者和dubbo消费者之间被引用

package com.sml.sz.bookmark.service;

import java.util.List;

import com.sml.sz.bookmark.entity.BookmarkTag;
import com.sml.sz.common.persistence.Page;

/**
 * 我的收藏链接管理Service
 * 
 * @author ant
 * @version 2016-01-30
 */
public interface BookmarkTagFacade {
	public BookmarkTag get(String id);

	public List<BookmarkTag> findList(BookmarkTag bookmarkTag);

	public Page<BookmarkTag> findPage(Page<BookmarkTag> page, BookmarkTag bookmarkTag);

	public void save(BookmarkTag bookmarkTag);

	public void delete(BookmarkTag bookmarkTag);
}

 欢迎大家跟我一起学习《构建dubbo分布式平台》,希望大家持续关注后面的文章!

 

4
0
分享到:
评论
2 楼 天空晴朗 2017-12-22  
valiant025 写道
期待新的文章,受益匪浅

谢谢,近期有点忙,文章更新有点慢
1 楼 valiant025 2017-12-22  
期待新的文章,受益匪浅

相关推荐

    单点登录源码

    Dubbo | 分布式服务框架 | [http://dubbo.io/](http://dubbo.io/) TBSchedule & elastic-job | 分布式调度框架 | [https://github.com/dangdangdotcom/elastic-job](https://github.com/dangdangdotcom/elastic-job)...

    Dubbo的demo

    Dubbo的demo,其中包含了构建好的一个使用dubbo的分布式架构项目demo,和使用jwt+cookie实现的单点登录demo,关于单点登录,这里实现的方式并不完善,只是为了省略前端代码,就将token放入到了cookie中,思路仅供...

    基于Python实现的一个简单的分布式高并发RPC框架+源代码+文档说明

    ## 用Python构建分布式高并发的RPC框架 ------ ### 一、为什么要写一个RPC框架? &gt; + 不是想要造轮子,Dubbo、gRPC、Thift这些轮子已经非常好用了 &gt; + RPC在微服务、分布式系统、Web服务器方面应用太广泛了,...

    springboot学习

    Spring Boot 基础教程(基于1.3.x-1.5.x) 快速入门 chapter1:基本项目构建(可作为工程脚手架),引入web模块,完成一个简单的RESTful API 使用Intellij中的Spring...chapter9-2-2:Spring Boot与Dubbo中管理服务依赖

    java开源包1

    Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就流数据模型。这是一个可靠、容错的服务。 彩信发送开发包 apimms apimms 提供了各种语言用来发送彩信...

    spring-cloud-alibaba:Spring Cloud Alibaba为阿里巴巴中间件的分布式解决方案提供了一站式的应用程序开发解决方案

    您还可以使用注释来自定义流控制和服务降级规则。 规则可以动态更改。 服务注册和发现:可以注册服务,并且客户可以使用Spring托管的bean(自动集成功能区)发现实例。 分布式配置:支持分布式系统中的外部配置,...

    spring-cloud-alibaba:Spring Cloud Alibaba为阿里巴巴中间件的分布式解决方案提供了应用程序开发的一站式解决方案

    您还可以使用注释来自定义流控制和服务降级规则。 规则可以动态更改。 服务注册和发现:可以注册服务,客户可以使用Spring托管的bean,自动集成功能区发现实例。 分布式配置:支持分布式系统中的外部配置,配置...

    spring-cloud-rest-tcc:以Spring Cloud Netflix作为服务治理基础,展示基于tcc思想所实现的分布式事务解决方案

    变体在微服务兴起的时候,由于对集团内部现有的中间件生态考量与性能的实质需求,更多基于RPC协议进行构建,如gRPC,Dubbo和Thrift等框架。面对TCC设计思想,同样应该以更温和的方式落地,而不应加入于应用层协议,...

    java开源包10

    Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就流数据模型。这是一个可靠、容错的服务。 彩信发送开发包 apimms apimms 提供了各种语言用来发送彩信...

    java开源包11

    Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就流数据模型。这是一个可靠、容错的服务。 彩信发送开发包 apimms apimms 提供了各种语言用来发送彩信...

    java开源包2

    Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就流数据模型。这是一个可靠、容错的服务。 彩信发送开发包 apimms apimms 提供了各种语言用来发送彩信...

    java开源包3

    Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就流数据模型。这是一个可靠、容错的服务。 彩信发送开发包 apimms apimms 提供了各种语言用来发送彩信...

    java开源包6

    Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就流数据模型。这是一个可靠、容错的服务。 彩信发送开发包 apimms apimms 提供了各种语言用来发送彩信...

    java开源包5

    Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就流数据模型。这是一个可靠、容错的服务。 彩信发送开发包 apimms apimms 提供了各种语言用来发送彩信...

    java开源包4

    Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就流数据模型。这是一个可靠、容错的服务。 彩信发送开发包 apimms apimms 提供了各种语言用来发送彩信...

    java开源包8

    Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就流数据模型。这是一个可靠、容错的服务。 彩信发送开发包 apimms apimms 提供了各种语言用来发送彩信...

    java开源包7

    Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就流数据模型。这是一个可靠、容错的服务。 彩信发送开发包 apimms apimms 提供了各种语言用来发送彩信...

    java开源包9

    Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就流数据模型。这是一个可靠、容错的服务。 彩信发送开发包 apimms apimms 提供了各种语言用来发送彩信...

    java开源包101

    Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就流数据模型。这是一个可靠、容错的服务。 彩信发送开发包 apimms apimms 提供了各种语言用来发送彩信...

    Java资源包01

    Flume 是一个分布式、可靠和高可用的服务,用于收集、聚合以及移动大量日志数据,使用一个简单灵活的架构,就流数据模型。这是一个可靠、容错的服务。 彩信发送开发包 apimms apimms 提供了各种语言用来发送彩信...

Global site tag (gtag.js) - Google Analytics