HOME

转至元数据结尾
转至元数据起始

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

日志

  • 日志: Venus 3.3.1 Release 创建:
    2016-Nov-14
  • 日志: Venus 3.2.20 Release 创建:
    2016-Nov-14
  • 日志: Venus 3.2.19 Release 创建:
    2016-Sep-19
  • 日志: Venus 3.2.12 Release 创建:
    2014-Sep-05
  • 日志: Venus 3.2.10 Release 创建:
    2014-Jun-25
  • 日志: Venus 3.2.3 Released 创建:
    2014-Feb-19
  • 日志: Venus 3.0.9 Released 创建:
    2013-Dec-25
  • 日志: Venus 3.0.6 Released 创建:
    2013-Nov-22
  • 日志: Venus 3.0.4 Released 创建:
    2013-Nov-14
  • 日志: Venus 3.0.3 Released 创建:
    2013-Oct-25
  • 日志: Venus 3.0.2 Released 创建:
    2013-Oct-21
  • 日志: Venus 3.0.1 Released 创建:
    2013-Oct-14
  • 日志: Venus 2.3.0 Released 创建:
    2012-Oct-08
  • 日志: Venus 2.2.7 Released 创建:
    2012-Sep-24
  • 日志: Venus 2.2.6 Released 创建:
    2012-Jun-28
  • 日志: Venus 2.2.3 Released 创建:
    2012-May-21
  • 日志: Venus 2.0.4 Released 创建:
    2012-Mar-31
  • 日志: Venus 2.0.3 Released 创建:
    2012-Mar-23
  • 日志: Venus 2.0.1 Released 创建:
    2012-Jan-02
  • 日志: Venus 1.3.0 Released 创建:
    2011-Dec-07

  • 研发人员列表
    昵称 角色 职责 开源社区 目前供职于
    Struct Member 负责架构设计、通信框架研发、服务框架研发 Hexnova  
    Daisy Member 对象数据序列化、服务接口数据校验、服务框架研发 Hexnova  
    Sunng Member 服务框架研发 Hexnova  
    Yuanjian Yi Member
    PHP客户端开发 Hexnova
     
    huawei Member
    服务注册中心 Hexnova
     


    样例:

    • 简单的接口例子: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
    Enter labels to add to this page:
    Please wait 
    查找标签? 在此录入。
    1. 2011-Nov-30

      匿名用户 发表:

      对java开发语言来说,真的非常不错。。 准备试用 !!

      对java开发语言来说,真的非常不错。。

      准备试用 !!

    2. 2011-Nov-30

      匿名用户 发表:

      正在试用ing.....

      正在试用ing.....

    3. 2011-Dec-02

      匿名用户 发表:

      准备用来投入到项目中去...将公司的业务,都砍成一个细分业务,通过服务接口的方式来实现

      准备用来投入到项目中去...将公司的业务,都砍成一个细分业务,通过服务接口的方式来实现

    4. 2011-Dec-05

      匿名用户 发表:

      SVN地址连不上去,积极被拒绝啊,本打算学习一下的。

      SVN地址连不上去,积极被拒绝啊,本打算学习一下的。

      1. 2011-Dec-05

        Struct 发表:

        你的网络是电信还是 移动 还是联通? 目前svn地址放在 电信机房。。 联通 跟 移动连接过去有时候会有点问题

        你的网络是电信还是 移动 还是联通?

        目前svn地址放在 电信机房。。 联通 跟 移动连接过去有时候会有点问题

        1. 2012-Mar-26

          匿名用户 发表:

          我在公司也没法连接,公司是电信网络。我下载amoeba没有问题,谁下载了能否给我发下,谢谢。mail:benyoupeng@163.com,3ks

          我在公司也没法连接,公司是电信网络。我下载amoeba没有问题,谁下载了能否给我发下,谢谢。mail:benyoupeng@163.com,3ks

          1. 2012-Mar-27

            匿名用户 发表:

            昨天会宿舍下载了代码,但发现里面缺少fastbson的部分,还有人知道从哪边获取啊?或者发到我的邮箱benyoupeng@huawei.com或benyoupe...

            昨天会宿舍下载了代码,但发现里面缺少fastbson的部分,还有人知道从哪边获取啊?或者发到我的邮箱benyoupeng@huawei.com或benyoupeng@163.com

    5. 2012-Jan-09

      匿名用户 发表:

      环境搭建的文档要是能稍微详细就好了

      环境搭建的文档要是能稍微详细就好了

    6. 2012-Feb-18

      匿名用户 发表:

      从svn更新代码后,为什么没有com.meidusa.toolkit这个工程相关的代码呢,导致太多的工程都编译不过。问一下在哪里可以获取这个工程的代码或者jar...

      从svn更新代码后,为什么没有com.meidusa.toolkit这个工程相关的代码呢,导致太多的工程都编译不过。问一下在哪里可以获取这个工程的代码或者jar包也可以。mail:xch_wang@163.com

      1. 2012-Mar-27

        匿名用户 发表:

        最好采用maven来编译,因为项目是采用 maven来管理类库的

        最好采用maven来编译,因为项目是采用 maven来管理类库的

        1. 2012-Aug-10

          匿名用户 发表:

          cC3OhR <a href="http://lkuipnvtwiic.com/">lkuipnvtwiic</a>

          cC3OhR <a href="http://lkuipnvtwiic.com/">lkuipnvtwiic</a>

        2. 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/

    7. 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/也找不到。是什么原因呢?

      1. 2012-May-30

        Struct 发表:

        <distributionManagement> <repository> <id>hexnova-open&l...
        <distributionManagement>
        		<repository>
        			<id>hexnova-open</id>
        			<name>hexnova Releases</name>
        			<url>http://maven.hexnova.com/nexus/content/repositories/release-open</url>
        		</repository>
        		<snapshotRepository>
        			<id>hexnova-open</id>
        			<name>hexnova snapshots</name>
        			<url>http://maven.hexnova.com/nexus/content/repositories/snapshot-open</url>
        		</snapshotRepository>
        	</distributionManagement>

        repository 请参阅上面的设置

        1. 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,是不是还是配置的问题?

          1. 2012-May-31

            匿名用户 发表:

            搞定了,多谢。正在研究这个框架,希望研究透了能对这个框架做点自己的贡献

            搞定了,多谢。正在研究这个框架,希望研究透了能对这个框架做点自己的贡献

    8. 2012-Jun-05

      匿名用户 发表:

      关于代码的一个问题,MultipleLoadBalanceObjectPool->setObjectPools  this.objectPoo...

      关于代码的一个问题,MultipleLoadBalanceObjectPool->setObjectPools

       this.objectPools = new ObjectPool[objectPools.length];
           for(int i=0;i<objectPools.length;i++)

      Unknown macro: {         this.objectPools[i] = new ObjectPoolWrapper(objectPools[i]);        }

              this.objectPools = objectPools;
              this.runtimeObjectPools = objectPools.clone();

       倒数第二行看来是不需要的啊? 既然都Wrapper了,还要重新赋值?

        

      1. 2012-Jun-05

        Struct 发表:

        多谢哈,的确是错误的代码,需要重整一下

        多谢哈,的确是错误的代码,需要重整一下

        1. 2012-Dec-14

          zhang hongwei 发表:

          好多代码需要重新整理啊,:)

          好多代码需要重新整理啊,:)

          1. 2012-Jun-06

            匿名用户 发表:

            每次check的时候,都会从队列里面 拿出来 的,根据check以后的状态或者根据 delayed的一些自身是否是 isCycle的情况,重新加入到队列里面,等...

            每次check的时候,都会从队列里面 拿出来 的,根据check以后的状态或者根据 delayed的一些自身是否是 isCycle的情况,重新加入到队列里面,等待下一次check。

            1. 2012-Dec-14

              zhang hongwei 发表:

              又仔细看了一下,感觉有点小问题。

              又仔细看了一下,感觉有点小问题。

              1. 2012-Jun-06

                匿名用户 发表:

                根据Delayed的策略的,如果是isCycle 那就会重新加入,如果不是,只要Valid就算完成了

                根据Delayed的策略的,如果是isCycle 那就会重新加入,如果不是,只要Valid就算完成了

          2. 2012-Aug-09

            匿名用户 发表:

            It's about time smooene wrote about this.

            It's about time smooene wrote about this.

    9. 2012-Oct-20

      匿名用户 发表:

      怎么下载程序?

      怎么下载程序?

    10. 2014-May-25

      匿名用户 发表:

      Venus-Bus 这部分的代码有没,没找到下载的地方

      Venus-Bus 这部分的代码有没,没找到下载的地方

      1. 2014-Jun-25

        Struct 发表:

        Venus Bus 目前暂时还没开源

        Venus Bus 目前暂时还没开源

        1. 2015-Feb-14

          zhuo 发表:

          求开源,大家一起改进

          求开源,大家一起改进

    11. 2014-Nov-05

      匿名用户 发表:

      看得有点晕啊。有没有更具体一点的使用方法。 demo 里面的 client service api http 还有bus 各种关系。

      看得有点晕啊。有没有更具体一点的使用方法。 demo 里面的 client service api http 还有bus 各种关系。

      1. 2014-Nov-06

        匿名用户 发表:

        还有那个注册中心。最少要有几个项目可以使用venus

        还有那个注册中心。最少要有几个项目可以使用venus

    12. 2015-Oct-08

      wangzhenjun 发表:

      svn地址不对吧?访问不了

      svn地址不对吧?访问不了

    13. 2017-Jun-21

      匿名用户 发表:

      注册中心是否有开放预期。

      注册中心是否有开放预期。

    14. 2017-Jun-30

      匿名用户 发表:

      svn下载不下来  谁有下载好的吗?发我一份 谢谢   邮箱地址:872737557@qq.com

      svn下载不下来  谁有下载好的吗?发我一份 谢谢   邮箱地址:872737557@qq.com

    添加评论