1. 如何服务化
采用接口与实现分离,服务接口是一种契约,他与我们开发web Service类似。
java开发语言:采用对程序员友好的接口申明形式,开发人员不需要关心客户端与服务端之间的传输协议。
其他语言:可以通过该框架提供自定义协议进行交互
2. 服务接口定制
定义服务接口
接口参数命名
定义参数校验规则
Java语言服务接口尽量不要依赖其他项目. 接口层面只需要接口相关的参数对象类与服务类
异常定义
3. 接口参数校验
4. 提供3种交互方式
请求应答模式:普通的request、response,一般用于接口有返回值
异步请求模式:通常用于接口无返回值,客户端并不关心服务器的处理结果,也不用关心服务器处理多少时间
异步回调模式:接口无返回值,处理通常消化大量时间,需要服务端通知处理结果的业务接口
下面是一个例子:
1、简单的接口例子:HelloService.java
package com.meidusa.venus.hello.api;
import com.meidusa.venus.annotations.Endpoint;
import com.meidusa.venus.annotations.Param;
import com.meidusa.venus.annotations.Service;
import com.meidusa.venus.notify.InvocationListener;
/**
* Service framework的 HelloService 接口例子.</p>
* 支持3种调用方式:</p>
* <li> 请求应答模式:普通的request、response,一般用于接口有返回值</li>
* <li> 异步请求模式:通常用于接口无返回值,客户端并不关心服务器的处理结果,也不用关心服务器处理多少时间</li>
* <li> 异步回调模式:接口无返回值,处理通常消化大量时间,需要服务端通知处理结果的业务接口</li>
*
* @author Struct
*
*/
@Service(name="HelloService",version=1)
public interface HelloService {
/**
* 无返回结果的服务调用,支持回调方式,该服务在通讯层面上为异步调用
* @param name
* @param invocationListener 客户端的回调接口
*/
@Endpoint(name="sayHelloWithCallbak")
public abstract void sayHello(@Param(name="name") String name,
@Param(name="callback") InvocationListener<Hello> invocationListener);
/**
* 无返回结果的服务调用,支持同步或者异步调用,
* 该接口申明:同步,并且接口申明异常
* @param name
*/
@Endpoint(name="sayHello",async=false)
public abstract void sayHello(@Param(name="name") String name) throws HelloNotFoundException;
/**
* 无返回结果的服务调用,支持同步或者异步调用,无异常申明
* @param name
*/
@Endpoint(name="sayAsyncHello",async=true)
public abstract void sayAsyncHello(@Param(name="name") String name);
/**
* 有返回结果的服务调用,该接口只能支持同步调用
* @param name
* @return
*/
@Endpoint(name="getHello")
public abstract Hello getHello(@Param(name="name") String name);
}
2、客户端TestCase编写
package com.meidusa.venus.hello.client;
import java.util.concurrent.CountDownLatch;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import com.meidusa.venus.exception.CodedException;
import com.meidusa.venus.hello.api.Hello;
import com.meidusa.venus.hello.api.HelloNotFoundException;
import com.meidusa.venus.hello.api.HelloService;
import com.meidusa.venus.notify.InvocationListener;
@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration(locations="classpath:/applicationContext-helloworld-client.xml")
public class TestHelloService {
@Autowired
private HelloService helloService;
@Test
public void saySync(){
System.out.println(helloService.getHello("jack"));
}
@Test
public void testSyncWithException(){
try {
helloService.sayHello("jack");
} catch (HelloNotFoundException e) {
System.out.println("throw an user defined HelloNotFoundException");
}
}
@Test
public void testAsync(){
helloService.sayAsyncHello("jack");
}
@Test
public void testCallback() throws Exception{
//为了让回调完成,采用countDownLatch计数器方式,避免testcase主线程运行完成而回调未结束的问题
final CountDownLatch latch = new CountDownLatch(1);
//在正常的使用的代码中这个类需要单实例,避免过多的callback listener导致内存问题
InvocationListener<Hello> listener = new InvocationListener<Hello>() {
public void callback(Hello myobject) {
System.out.println(" async call back result="+myobject);
latch.countDown();
}
@Override
public void onException(Exception e) {
if(e instanceof CodedException){
CodedException exception = (CodedException) e;
System.out.println(" async call back error:"+exception.getErrorCode()+",message="+exception.getMessage());
}else{
System.out.println(" async call back message="+e.getMessage());
}
latch.countDown();
}
};
helloService.sayHello("jack",listener);
latch.await();
}
}
3、服务端的实现
package com.meidusa.venus.hello.impl;
import java.math.BigDecimal;
import java.util.HashMap;
import java.util.Map;
import com.meidusa.venus.hello.api.Hello;
import com.meidusa.venus.hello.api.HelloNotFoundException;
import com.meidusa.venus.hello.api.HelloService;
import com.meidusa.venus.notify.InvocationListener;
public class DefaultHelloService implements HelloService {
private String greeting;
public String getGreeting() {
return greeting;
}
public void setGreeting(String greeting) {
this.greeting = greeting;
}
public Hello getHello(String name) {
Hello hello = new Hello();
hello.setName(name);
hello.setGreeting(greeting);
Map<String,Object> map = new HashMap<String,Object>();
hello.setMap(map);
map.put("1", 1);
map.put("2", new Long(2));
map.put("3", new Integer(3));
hello.setBigDecimal(new BigDecimal("1.341241233412"));
return hello;
}
public void sayHello(String name) throws HelloNotFoundException {
throw new HelloNotFoundException(name +" not found");
}
@Override
public void sayAsyncHello(String name) {
System.out.println("method sayAsyncHello invoked");
}
public void sayHello(String name,
InvocationListener<Hello> invocationListener) {
Hello hello = new Hello();
hello.setName(name);
hello.setGreeting(greeting);
Map<String,Object> map = new HashMap<String,Object>();
hello.setMap(map);
map.put("1", 1);
map.put("2", new Long(2));
map.put("3", new Integer(3));
if(invocationListener != null){
invocationListener.callback(hello);
}
}
}
分享到:
相关推荐
venus:一个简单的包管理器
即使您正在开发 Venus OS 的一部分,例如其驱动程序之一或 gui,仍然没有必要从源代码构建完整的 Venus OS。 请务必先阅读 。 所以,如果你坚持:这个 repo 是构建 Venus 的起点。 它包含围绕 bitbake 和 git 的...
主要成分认证机构我们的项目使用RSA加密技术,因此我们需要一个安全的位置来存储服务器的公共密钥。 这是CA的目的。 要使一个可用,只需运行(在导入之后): ca = vCA ()ca.listen ()服务器这是负责运行投票会议...
Filecoin是一个去中心化的存储网络,它将世界上未使用的存储变成一个算法市场,为网络创造了一个永久的,去中心化的未来。 矿工通过提供数据存储和/或检索来获取本机协议令牌(也称为“文件币”)。 客户向矿工付费...
金星:适合那些讨厌看墙纸的人 Venus旨在成为一个跨平台工具,使用图像自动更改您的桌面墙纸。 默认情况下,所有映像都存储在系统的临时目录中,这种方式由操作系统处理。 金星还可以处理使用具有您的分辨率的图像。...
关于过去一小时,过去一天,过去一周,过去一个月间隔的KPI统计信息的历史面板数据。 依赖图可视化,用于映射服务结构和方法。 服务器端身份验证,用于安全存储和分发分析。 金星轨道的简要概述 金星轨道分为三个...
金星一个 android 应用程序,提供了一个方便的衣柜。
Kubernetes是另一个流行的容器技术,它是一个开源的容器编排系统,可以帮助开发人员管理和调度多个容器的部署。 Go语言也提供了对Kubernetes的支持,可以使用Kubernetes API创建和管理容器,以及监视和扩展整个集群...
在撰写本文时,该插件支持Venus服务类“ gps”,“ tank”和“ temperature” 该插件借鉴了Kevin Windrem的项目的GUI增强功能,以实现如下所示的显示,为维纳斯的多通道油箱传感器问题提供了特定的解决方案。...
当你在 JS 开发一个基于浏览器的项目时,你想创建单元测试并频繁地运行它们。通常,你会用一些库比如 Mocha 或 Jasmine,写一个单元测试,这些库可以让你定义测试用例,并提供 API 来编写判断。我们通过创建一个工具...
基于Rust语言开发的web项目 引用技术 actix-web rbatis handlebars mysql redis 快速使用教程 安装mysql,建数据库rust_test,将sql/venus_web.sql文件导入数据库 配置数据库连接src/config/mod.rs pub const MYSQL_...
金星计划 金星计划(Project Venus)是一个基于AI的聊天机器人,从头开始用Python构建。
它会生成一个VS Code扩展源代码的压缩文件夹,当前该文件夹必须由操作员打包,然后才能手动或通过社会工程交付给目标/测试机器。 确保已安装Node.js,然后获取vsce软件包并打包在Mythic上通过“ Create Payload”...
金星是WRAL的系统,用于捕获和消化NC大会的账单,赞助商和选票,并为申请提供服务。 由Python, 和来自数据提供支持。 就像本文档一样,它仍在进行中。 由WRAL( 创建。 配置 克隆repo并使用pip安装要求。 git ...
主题:来自planet-venus原始包的主题定制,可以在data/theme文件夹中使用。已知限制现在, planet-venus似乎有些破损,因此它无法在上游 debian/ubuntu 上运行。 所以docker-venus在 ubuntu:12.04 容器中运行。去做...
金星 就像Jupyter,但更轻,更快,更热。 将带LaTeX的解释语言(当前为python,shell和... Venus识别代码块,并将结果放入该块之后的另一个代码块中(如果Venus知道如何执行)。 金星产生的现有区块将被替换。 这
中文名: 全球首款3D浏览器 英文名: Venus 别名: 维纳斯网页浏览新体验 资源格式: 安装包 版本: 更新0.2.7.95 简体中文版 发行时间: 2010年11月30日 制作发行: Visual Domains Ltd.
Venus7.0 for D7,优秀组件,exe直接安装版, 支持Delphi7
可以作为一个插件安装在你的浏览器上面,同时也可作为一个独立的浏览器存在。我们的Venus ?插件可以让你直接在你的浏览器上面使用Venus ?。目前开放的插件是“venus 搜索”,你可以将该插件安装在你的IE或火狐浏览器...
Venus 7.0b With Full Source For D7 Serial: 435506684D7 Source: 927033087D7