Venus(New Version:3.3.1) 是什么?
它是由(Venus service framework)+服务路由产品(Venus-Bus)+服务注册中心(Venus-Registry) 组合而成,提供远程服务。它着 开发简单、高性能、高并发能力 的服务端框架。
客户端与服务端之间的通讯对开发人员完全透明
他跟目前我们经常用到的框架:axis、CXF、Hessian WebService、Jboss Remoting等框架类似。
系统功能目标:
- 提供高性能的服务通讯框架
- 具备性能监控(可以清晰的看到每个服务执行的时间、过长可以通过监控告警出去)
- 具备流量控制(每个服务每个时刻的调用次数、每天的峰值情况、)
- 访问控制(服务的授权控制)
- 提供可选择性服务数据缓存(cache支持,key采用表达式,由框架提供缓存支持,而不需要编写任何cache相关的代码)
- 提供框架进行再次研发能力,提供interceptor、validator等接口。
- 提供高性能的服务总线(Venus-Bus),能够轻易接入高性能的服务总线。(Venus-Bus项目支持,针对该venus的协议,以后接入服务总线轻而易举)
开发方面:
- 服务接口定义清晰(接口、参数、校验、以及服务鉴权)
- 自动生成接口文档,以方便阅读接口声明
- 客户端框架快速开发、提供多种语言版本的客户端
- 提供3种服务调用方式(同步、异步、回调)
- 服务端框架提供多种协议提供服务,而不需要做额外的开发
![]() | 语言支持情况 目前客户端SDK暂时只有java、PHP语言版本 服务端面向java语言 |
演讲稿下载
开发人员的关注点
1. 如何服务化
采用接口与实现分离,服务接口是一种契约,他与我们开发web Service类似。
- java开发语言:采用对程序员友好的接口申明形式,开发人员不需要关心客户端与服务端之间的传输协议。
- 其他语言:可以通过该框架提供自定义协议或者Http协议(http协议即将在2.1.0版本release出来)进行交互
2. 服务接口定制
- 定义服务接口
- 接口参数命名
- 定义参数校验规则
- Java语言服务接口尽量不要依赖其他项目. 接口层面只需要接口相关的参数对象类与服务类
- 异常定义
3. 接口参数校验
4. 提供3种交互方式
- 请求应答模式:普通的request、response,一般用于接口有返回值
- 异步请求模式:通常用于接口无返回值,客户端并不关心服务器的处理结果,也不用关心服务器处理多少时间
- 异步回调模式:接口无返回值,处理通常消化大量时间,需要服务端通知处理结果的业务接口
源代码:
demo 的svn 地址:svn://svn.hexnova.com/venus/venus-helloworld/trunk
框架svn地址: svn://svn.hexnova.com/venus/venus-framework/trunk
svn的用户名:guest
svn密码:guest
Maven Repository
<repository> <id>hexnova-open</id> <url>http://maven.hexnova.com/nexus/content/groups/hexnova-open</url> <releases> <enabled>true</enabled> <updatePolicy>never</updatePolicy> </releases> <snapshots> <enabled>true</enabled> <updatePolicy>always</updatePolicy> </snapshots> </repository>
目前版本情况:
trunk是最新开发版本,会不停有新东西进入
稳定版本: 3.2.20
最新版本:3.3.1
版本发布Blog地址: http://wiki.hexnova.com/pages/viewrecentblogposts.action?key=Venus
开发人员与blog
日志
2016-Nov-14
2016-Nov-14
2016-Sep-19
2014-Sep-05
2014-Jun-25
2014-Feb-19
2013-Dec-25
2013-Nov-22
2013-Nov-14
2013-Oct-25
2013-Oct-21
2013-Oct-14
2012-Oct-08
2012-Sep-24
2012-Jun-28
2012-May-21
2012-Mar-31
2012-Mar-23
2012-Jan-02
2011-Dec-07
|
|
研发人员列表
|
样例:
- 简单的接口例子:HelloService.java
HelloService接口例子
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",timeWait=10000) public abstract Hello getHello(@Param(name="name") String name); }
- 客户端TestCase编写
客户端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(); } }
- 服务端的实现
服务端对HelloService的简单实现
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); } } }
最近的更新
|
Navigate space |
标签
页面:
1. 各种客户端简单使用
页面: 2. 高级使用指南
页面: 3. Architecture
页面: 4. 协议以及交互序列图介绍
页面: 5. 性能测试工具--Service-benchmark
页面: 6. 性能测试(单客户端)
页面: 7. 极限测试(多客户端)
页面: FAQ
页面: Venus Eclipse Plugin发布
页面: 二、其他语言客户端
页面: 2. 高级使用指南
页面: 3. Architecture
页面: 4. 协议以及交互序列图介绍
页面: 5. 性能测试工具--Service-benchmark
页面: 6. 性能测试(单客户端)
页面: 7. 极限测试(多客户端)
页面: FAQ
页面: Venus Eclipse Plugin发布
页面: 二、其他语言客户端
评论 (32)
2011-Nov-30
匿名用户 发表:
对java开发语言来说,真的非常不错。。 准备试用 !!对java开发语言来说,真的非常不错。。
准备试用 !!
2011-Nov-30
匿名用户 发表:
正在试用ing.....正在试用ing.....
2011-Dec-02
匿名用户 发表:
准备用来投入到项目中去...将公司的业务,都砍成一个细分业务,通过服务接口的方式来实现准备用来投入到项目中去...将公司的业务,都砍成一个细分业务,通过服务接口的方式来实现
2011-Dec-05
匿名用户 发表:
SVN地址连不上去,积极被拒绝啊,本打算学习一下的。SVN地址连不上去,积极被拒绝啊,本打算学习一下的。
2011-Dec-05
Struct 发表:
你的网络是电信还是 移动 还是联通? 目前svn地址放在 电信机房。。 联通 跟 移动连接过去有时候会有点问题你的网络是电信还是 移动 还是联通?
目前svn地址放在 电信机房。。 联通 跟 移动连接过去有时候会有点问题
2012-Mar-26
匿名用户 发表:
我在公司也没法连接,公司是电信网络。我下载amoeba没有问题,谁下载了能否给我发下,谢谢。mail:benyoupeng@163.com,3ks我在公司也没法连接,公司是电信网络。我下载amoeba没有问题,谁下载了能否给我发下,谢谢。mail:benyoupeng@163.com,3ks
2012-Mar-27
匿名用户 发表:
昨天会宿舍下载了代码,但发现里面缺少fastbson的部分,还有人知道从哪边获取啊?或者发到我的邮箱benyoupeng@huawei.com或benyoupe...昨天会宿舍下载了代码,但发现里面缺少fastbson的部分,还有人知道从哪边获取啊?或者发到我的邮箱benyoupeng@huawei.com或benyoupeng@163.com
2012-Jan-09
匿名用户 发表:
环境搭建的文档要是能稍微详细就好了环境搭建的文档要是能稍微详细就好了
2012-Feb-18
匿名用户 发表:
从svn更新代码后,为什么没有com.meidusa.toolkit这个工程相关的代码呢,导致太多的工程都编译不过。问一下在哪里可以获取这个工程的代码或者jar...从svn更新代码后,为什么没有com.meidusa.toolkit这个工程相关的代码呢,导致太多的工程都编译不过。问一下在哪里可以获取这个工程的代码或者jar包也可以。mail:xch_wang@163.com
2012-Mar-27
匿名用户 发表:
最好采用maven来编译,因为项目是采用 maven来管理类库的最好采用maven来编译,因为项目是采用 maven来管理类库的
2012-Aug-10
匿名用户 发表:
cC3OhR <a href="http://lkuipnvtwiic.com/">lkuipnvtwiic</a>cC3OhR <a href="http://lkuipnvtwiic.com/">lkuipnvtwiic</a>
2012-Aug-12
匿名用户 发表:
cCSbrw , [url=http://hwsgtxqpurok.com/]hwsgtxqpurok[/url], [...cCSbrw , [url=http://hwsgtxqpurok.com/]hwsgtxqpurok[/url], [link=http://xpythofiwmes.com/]xpythofiwmes[/link], http://ubhrbwcvufsz.com/
2012-May-30
匿名用户 发表:
venus-common-base 编译不过去,因为缺少依赖,toolkit-common-bean toolkit-common-runtime toolki...venus-common-base 编译不过去,因为缺少依赖,toolkit-common-bean toolkit-common-runtime toolkit-common-util,从http://search.maven2.org/也找不到。是什么原因呢?
2012-May-30
Struct 发表:
<distributionManagement> <repository> <id>hexnova-open&l...repository 请参阅上面的设置
2012-May-31
匿名用户 发表:
多谢大侠,编译过去了。 另外,对hello工程进行 mvn install时,com.meidusa.toolkit.plugins ->mav...多谢大侠,编译过去了。
另外,对hello工程进行 mvn install时,com.meidusa.toolkit.plugins ->maven-autoconfig-plugin 的版本从repository也找不到。最新的是1.0.10,是不是还是配置的问题?
2012-May-31
匿名用户 发表:
搞定了,多谢。正在研究这个框架,希望研究透了能对这个框架做点自己的贡献搞定了,多谢。正在研究这个框架,希望研究透了能对这个框架做点自己的贡献
2012-Jun-05
匿名用户 发表:
关于代码的一个问题,MultipleLoadBalanceObjectPool->setObjectPools this.objectPoo...关于代码的一个问题,MultipleLoadBalanceObjectPool->setObjectPools
this.objectPools = new ObjectPool[objectPools.length];
for(int i=0;i<objectPools.length;i++)
this.objectPools = objectPools;
this.runtimeObjectPools = objectPools.clone();
倒数第二行看来是不需要的啊? 既然都Wrapper了,还要重新赋值?
2012-Jun-05
Struct 发表:
多谢哈,的确是错误的代码,需要重整一下多谢哈,的确是错误的代码,需要重整一下
2012-Dec-14
zhang hongwei 发表:
好多代码需要重新整理啊,:)好多代码需要重新整理啊,:)
2012-Jun-06
匿名用户 发表:
每次check的时候,都会从队列里面 拿出来 的,根据check以后的状态或者根据 delayed的一些自身是否是 isCycle的情况,重新加入到队列里面,等...每次check的时候,都会从队列里面 拿出来 的,根据check以后的状态或者根据 delayed的一些自身是否是 isCycle的情况,重新加入到队列里面,等待下一次check。
2012-Dec-14
zhang hongwei 发表:
又仔细看了一下,感觉有点小问题。又仔细看了一下,感觉有点小问题。
2012-Jun-06
匿名用户 发表:
根据Delayed的策略的,如果是isCycle 那就会重新加入,如果不是,只要Valid就算完成了根据Delayed的策略的,如果是isCycle 那就会重新加入,如果不是,只要Valid就算完成了
2012-Aug-09
匿名用户 发表:
It's about time smooene wrote about this.It's about time smooene wrote about this.
2012-Oct-20
匿名用户 发表:
怎么下载程序?怎么下载程序?
2014-May-25
匿名用户 发表:
Venus-Bus 这部分的代码有没,没找到下载的地方Venus-Bus 这部分的代码有没,没找到下载的地方
2014-Jun-25
Struct 发表:
Venus Bus 目前暂时还没开源Venus Bus 目前暂时还没开源
2015-Feb-14
zhuo 发表:
求开源,大家一起改进求开源,大家一起改进
2014-Nov-05
匿名用户 发表:
看得有点晕啊。有没有更具体一点的使用方法。 demo 里面的 client service api http 还有bus 各种关系。看得有点晕啊。有没有更具体一点的使用方法。 demo 里面的 client service api http 还有bus 各种关系。
2014-Nov-06
匿名用户 发表:
还有那个注册中心。最少要有几个项目可以使用venus还有那个注册中心。最少要有几个项目可以使用venus
2015-Oct-08
wangzhenjun 发表:
svn地址不对吧?访问不了svn地址不对吧?访问不了
2017-Jun-21
匿名用户 发表:
注册中心是否有开放预期。注册中心是否有开放预期。
2017-Jun-30
匿名用户 发表:
svn下载不下来 谁有下载好的吗?发我一份 谢谢 邮箱地址:872737557@qq.comsvn下载不下来 谁有下载好的吗?发我一份 谢谢 邮箱地址:872737557@qq.com
匿名用户 replies:
帮助提示
*bold*
bold_italic_
italich1.
Large headingh5.
Small heading*
Bulleted point#
Numbered point