文档章节

Venus框架

o
 osc_7338dds5
发布于 2018/06/28 23:01
字数 1593
阅读 52
收藏 0

「深度学习福利」大神带你进阶工程师,立即查看>>>

http://wiki.hexnova.com/display/Venus/HOME

它是由(Venus service framework)+服务路由产品(Venus-Bus)+服务注册中心(Venus-Registry) 组合而成,提供远程服务。它着 开发简单高性能高并发能力 的服务端框架。

Venus Service Framework提供服务器端开发SDK以及客户端SDK。它们之间采用Venus自定义的私有协议。encoder、decoder采用多种序列化方式,客户端根据自己的语言选择一种序列化方式。

目前提供3种序列化方式:0:表示JSON, 1:表示BSON , 3:表示JAVA对象序列化(仅限于java语言)。

​ Venus为让开发人员只专注服务开发而努力,开发人员在设计接口的时候只需要按照java的接口设计原则进行设计,把接口、接口中使用的参数对象类、接口异常类封装成API包即可对外提供。

而Venus则承担协调沟通客户端服务器端的通讯框架。

###Demo

接口定义

接口:用来约束客户端、服务端的应用层协议,他申明了具体服务接口的调用方式,参数的数据类型,具体功能的声明、异常的描述等等信息,它有服务端开发工程师,服务使用方工程师共同制定的。

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);
}

####客户端开发

1、引入venus相关依赖

2、编写Spring的配置文件

3、编写venus客户端配置文件:VenusClient-simple.xml

4、编写Testcase进行junit测试

1、依赖管理

maven pom.xml 增加依赖

<dependencies>
	<dependency>
		<groupId>com.meidusa.venus</groupId>
		<artifactId>venus-client</artifactId>
		<version>${venus.version}</version>
	</dependency>
</dependencies>
<properties>
    <venus.version>3.2.19</venus.version>
</properties>

2、客户端的spring的配置

Spring xml配置内容

<bean class="org.springframework.beans.factory.annotation.AutowiredAnnotationBeanPostProcessor"/>
<bean id="serviceFactory" class="com.meidusa.venus.client.VenusServiceFactory">
    <property name="configFiles">
          <list>
              <value>classpath:VenusClient-simple.xml</value>
              <!--
               支持file: 绝对路径与classpath:,这儿可以配置多个文件
              <value>file:VenusClient-simple.xml</value>
              -->
          </list>
    </property>
</bean>

3、客户端的 venus.xml的配置

VenusClient-simple.xml 配置

<?xml version="1.0" encoding="utf8"?>
<venus-client>

    <!-- 服务接口列表 -->
    <services>
    <!-- 定义服务以及指定该服务提供方的远程相关配置 -->
        <service type="com.meidusa.venus.hello.api.HelloService">
	    <property name="ipAddressList">127.0.0.1:16800</property>
        </service>
    </services>
</venus-client>

4、testCase using Spring autowire

使用Spring autowire功能

import org.springframework.beans.factory.annotation.Autowired;

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");
	}

}

服务端开发

1、引入对venus的依赖

2、实现HelloService接口

3、Venus的服务端配置:VenusServices-simple.xml

4、Spring的相关Bean的配置(注意:需要让spring容器默认采用 byName autowire 的功能: default-autowire="byName")

1、引入Venus相关的依赖

maven pom.xml 增加依赖

<dependencies>
	<dependency>
		<groupId>com.meidusa.venus</groupId>
		<artifactId>venus-backend</artifactId>
		<version>${venus.version}</version>
	</dependency>

</dependencies>
<properties>
    <venus.version>3.2.19</venus.version>
</properties>

2、DefaultHelloService的实现

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);
		}

	}
}

3、VenusService-simple.xml的配置

VenusServices-simple.xml 配置

<?xml version="1.0" encoding="utf-8"?>
<venus-server>
	<services>
 		<!-- 有2种方式暴露Service,1: instance由venus负责实例化,如下代码: -->
		<service type="com.meidusa.venus.hello.api.HelloService">
			<instance class="com.meidusa.venus.hello.impl.DefaultHelloService">
				<property name="greeting">hello venus hello service</property>
			</instance>
		</service>


		<!-- 第二种:instance由Spring负责提供,则需要采用${...} 这种方式引用Spring的bean,这种方式主要是Spring内其他bean依赖该bean,则通常采用这种 -->
		<!--  这儿的 ${helloService} 表示在你的spring xml中需要配置一个 beanName为 helloService,type为DefaultHelloService的一个bean
		<service type="com.meidusa.venus.hello.api.HelloService">
			<property name="instance">${helloService}</property>
		</service>		-->
	</services>
</venus-server>

4、Spring相关的venus 配置

Spring 配置相关的bean

<!-- 引入venus Service 相关的配置 -->
    <import resource="classpath:/spring/applicationContext-service-container.xml"/>

    <!-- 加载服务配置文件 -->
    <bean id="serviceManager" class="com.meidusa.venus.backend.services.xml.XmlFileServiceManager">
        <property name="configFiles">
            <list>
                <value>classpath:VenusServices-simple.xml</value>
            </list>
        </property>
    </bean>

    <!-- 设置authenticateProvider,默认为可以使用该配置 -->
    <!-- venus目前提供2种方式的认证,一种是默认的采用虚拟的方式,另外一种支持用户名/密码登录,你也可以自己实现provider -->
    <bean id="authenticateProvider" class="com.meidusa.venus.backend.authenticate.SimpleAuthenticateProvider">
    	<property name="useDummy" value="true"/>
    	<property name="username" value="venus"/>
    	<property name="password" value="venus"/>
    </bean>

####服务端的启动控制台展示

1、显示了多少个Service暴露出来

2、显示了每个Service有哪些Endpoint暴露出来

3、服务端的监听端口

服务器端运行展现

2011-11-28 20:52:01,242 INFO  xml.XmlFileServiceManager - Add Endpoint: HelloService.sayHello
2011-11-28 20:52:01,242 INFO  xml.XmlFileServiceManager - Add Endpoint: HelloService.sayHelloWithCallbak
2011-11-28 20:52:01,242 INFO  xml.XmlFileServiceManager - Add Endpoint: HelloService.sayAsyncHello
2011-11-28 20:52:01,242 INFO  xml.XmlFileServiceManager - Add Endpoint: HelloService.getHello
2011-11-28 20:52:01,242 INFO  xml.XmlFileServiceManager - Add Endpoint: ParameterizedService.arrayLong
2011-11-28 20:52:01,242 INFO  xml.XmlFileServiceManager - Add Endpoint: ParameterizedService.arraylong
2011-11-28 20:52:01,258 INFO  net.ServerableConnectionManager - Server listening on 0.0.0.0/0.0.0.0:16800.
o
粉丝 0
博文 500
码字总数 0
作品 0
私信 提问
加载中
请先登录后再评论。
TDD的测试框架--Machine.Specification

Machine.Specification 是一个 TDD 测试驱动开发的测试框架,简化了测试,无需关心语言本身特性。 Machine.Specifications 带来的好处是不需要在代码里有注释,但同时阅读代码的人可以一目了...

匿名
2013/01/22
1.2K
0
mvc框架--Razor

Razor 是一个轻巧而优雅的servlet mvc框架 # 又一个轮子? no,写就她是为了证实我个人的某些想法,并在这个过程中练练手,这两种冲动碰撞在一起,自然而然地产生了Razor # Razor的现在和未来...

dtubest
2013/01/25
3.2K
0
Android3D应用与游戏开发框架--JQGL

JQGL 是一款针对Android设备上3D应用、游戏的开发框架。 核心功能是OpenGL-ES的使用框架,相对于大部分开发者而已,OpenGL是陌生的,没有专门研究无法进行相关的开发。 本框架针对于Android...

Jping
2013/02/21
1.6K
0
响应式框架--Groundwork

GroundworkCSS 是一个基于 Sass 预处理器的开源项目 ,主要用于快速构建响应式 Web 应用程序。拥有一个灵活的、可嵌套的网格系统,可以创建适应多种浏览设备的布局。 Groundwork 还提供多种 ...

匿名
2013/02/25
2.8W
4
WebUI自动化测试框架--Dagger

Dagger是网易杭州研究院QA团队开发的一个轻量级、运行稳定的WebUI自动化测试框架,主要基于Selenium及TestNg可以认为是对Selenium进行二次封装的一个框架(俗称 造轮子 )。之所以把这个轮子...

ChenKan
2013/03/05
2.8W
6

没有更多内容

加载失败,请刷新页面

加载更多

汇总你在 Linux 上的命令使用情况

使用合适的命令,你可以快速了解 Linux 系统上使用的命令以及执行的频率。 汇总 Linux 系统上使用的命令只需一串相对简单的命令以及几条管道将它们绑定在一起。当你的历史记录缓冲区保留了最...

osc_bvincwvq
25分钟前
7
0
Hacker News 简讯 2020-08-15

最后更新时间: 2020-08-15 07:01 Welders set off Beirut blast while securing explosives - (maritime-executive.com) 焊工在固定炸药的同时引爆了贝鲁特爆炸 得分:383 | 评论:322 Factor......

FalconChen
今天
24
0
OSChina 周六乱弹 —— 老椅小猫秋乡梦 梦里石台堆小鱼

Osc乱弹歌单(2020)请戳(这里) 【今日歌曲】 @小小编辑 :《MOM》- 蜡笔小心 《MOM》- 蜡笔小心 手机党少年们想听歌,请使劲儿戳(这里) @狄工 :腾讯又在裁员了,35岁以上清退,抖音看到...

小小编辑
今天
120
3
构建高性能队列,你不得不知道的底层知识!

前言 本文收录于专辑:http://dwz.win/HjK,点击解锁更多数据结构与算法的知识。 你好,我是彤哥。 上一节,我们一起学习了如何将递归改写为非递归,其中,用到的数据结构主要是栈。 栈和队列...

彤哥读源码
今天
17
0
Anaconda下安装keras和tensorflow

Anaconda下安装keras和tensorflow 一、下载并安装Anaconda: Anaconda下载 安装步骤: 如果是多用户操作系统选择All Users,单用户选择Just Me 选择合适的安装路径 然后勾选这个,自动配置环境...

Atlantis-Brook
今天
15
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部