java和c#通过esb服务互调用组件
场景:java和c#写的服务、站点,互相任意调用。实现一切即服务。
解决方案:使用这种轻量级的esb架构,通过tcp通信解决通信传输问题,总线服务解决服务地址问题,契约解决数据交互问题。由于组件封装了底层细节,比较方便好用,所以开发效率还是挺高的。
主组件:
Java: Ljc.JFramework.jar(jre1.8)
C#:Ljc.Framework.dll(.net4.5)
LJC.FrameWork.SOA.dll
依赖组件:无
使用方法:
前提:
需要一个总线服务。总线服务的作用就是接收服务注册,并转发请求,客户端口不需要关心服务的地址。总线服务可以发布在任何地方,只需要ip端口能访问。
ESBServer _esb = new ESBServer(20000); //总线使用的tcp端口
_esb.StartServer(); //启动
开发跨语言服务
1、添加配置文件
2、设计服务契约
这个是服务请求和响应的需要的类,见后面契约部分。
3、编写服务
增加一个服务,继承类ESBService,并且增加一个构造函数,然后重写方法DoResponse,获取请求参数,响应服务调用。
Java的demo:
public final class SparkService extends ESBService {
public SparkService(int sNo, boolean supportTcpServiceRidrect) throws Exception {
super(sNo, supportTcpServiceRidrect);
// TODO Auto-generated constructor stub
}
@Override
public Object DoResponse(Tuple<Integer,byte[]> tup) throws java.lang.Exception{
int funid=tup.GetItem1();
byte[] buffer=tup.GetItem2();
switch(funid) {
case 1:
{
//解析出请求参数
SubmitSparkRequest request=EntityBufCore.DeSerialize(SubmitSparkRequest.class, buffer, true);
//使用请求处理业务
...
SubmitSparkResponse resp= new SubmitSparkResponse();
resp.setSuccess(true);
//返回结果
return resp;
}
}
return super.DoResponse(tup);
}
}
C#的demo:
class SparkTaskCallBackService:ESBService
{
public SparkTaskCallBackService()
: base(101)
{
}
public override object DoResponse(int funcId, byte[] Param)
{
switch(funcId){
case 1:
{
//这里获取请求参数
var request = EntityBufCore.DeSerialize<CallBackRequest>(Param);
//响应
return new CallBackResponse
{
Success=true
};
}
}
return base.DoResponse(funcId, Param);
}
}
4、注册服务到总线
//100是要注册到总线的服务号
//由于只通过总线转发,不接受客户端直调,所以第二个参数为false,如果要接收客户端直接调用,第二个参数为true,但需要把服务加到防火墙白名单,
//这种模式下,服务会随机起一个端口,注册时会告知总线该服务端口,但客户端要通过DoSOARequest2调用,DoSOARequest2是DoSOARequest的增强版本,支持不通过总线自动直连服务
SparkService _sparkservice = new SparkService(100, false);
_sparkservice.StartService();
5、服务关闭后注销服务
Java
try {
_sparkservice.UnRegisterService();
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
_sparkservice.CloseClient();
C#
service.UnRegisterService();
service.Dispose();
客户端调用服务
1、添加配置文件
2、添加或者引用目标服务提供的契约,具体看下面契约部分
3、调用方法
//仅通过总线调
响应契约=ESBClient.DoSOARequest(服务号,功能号,请求契约)
//如果能直调目标服务就直调,不支持就通过总线调
响应契约=ESBClient.DoSOARequest2(服务号,功能号,请求契约)
Java:
Date end=new Date();
CallBackRequest request=new CallBackRequest();
request.setSparkTaskId(sparktaskid);
request.setStartTime(start);
request.setEndTime(end);
request.setErrorOutPut(errinfo);
request.setStdOutPut(stdinfo);
request.setSuccess(errinfo=="");
CallBackResponse resp= Ljc.JFramework.SOA.ESBClient.DoSOARequest(CallBackResponse.class, Statics.CallBackServiceNo, Statics.Fun_CallBack, request);
C#:
var resp = ESBClient.DoSOARequest<SubmitSparkResponse>(SubmitContract.Consts.SparkServiceNo,
Consts.Fun_SubmitSpark, new SubmitSparkRequest()
{
Context = new SparkLauncherContext
{
AppResource = item.AppResource,
MainClass = item.MainClass,
Master = item.Master,
SparkHome = item.SparkHome,
},
TaskId = item._id.ToString()
});
配置文件
配置文件名称:ESBConfig.xml
内容:
<?xml version="1.0" encoding="utf-16"?>
<ESBConfig>
<ESBServer>127.0.0.1</ESBServer>
<ESBPort>20000</ESBPort>
<AutoStart>true</AutoStart>
</ESBConfig>
字段 |
含义 |
说明 |
ESBServer |
总线地址 |
支持ipv4,和计算机名 |
ESBPort |
总线端口 |
|
AutoStart |
是否自动启动 |
固定为true |
说明:java服务放到程序执行目录下,net服务放到程序目录下,net web放到网站根目录下。
关于契约
Esb组件仅使用内置的序列化和反序列化机制,不依赖外部其它的如json/pb的序列化器工作。
契约包括请求契约和响应契约,调用方发送请求契约,服务方返回响应契约。
契约可以是简单的数据类型如int,string等,也可以是复杂的结构化类型,建议不要用简单的类型来作契约,后期扩展性差,且建议使用一对xxxRequest/xxxResponse规范命名。由于契约是要被序列化和反序列化的,类型有限制。简单类型目前只支持以下类型:
Java类型 |
Net类型 |
|
java.lang.Short/short |
Short |
|
java.lang.Integer/int |
Int16/int |
|
不支持 |
UInt16 |
|
不支持 |
Ushort |
|
java.lang.Long/long |
Int32/long/Int64 |
|
java.lang.Byte/byte |
Byte |
|
char/java.lang.Character |
Char |
|
java.lang.Double/double |
Double |
|
java.lang.Float/float |
Float |
|
java.lang.String |
String |
|
java.util.Date |
DateTime |
|
Boolean/boolean |
bool |
|
java.util.HashMap |
Dictionary |
|
java.util.List |
List |
|
Array |
Array |
|
不支持 |
enum |
|
不支持 |
Decimal |
|
Complex(复杂对象) |
Complex(复杂对象) |
成员类型必须是上面支持的类型,或者也是Complex及Complext的数组,Complext的列表或字典 |
说明:跨越java和c#的契约字段类型按上面对照,list和array是两种数据类型,不能对应。有些字段java不支持,如果c#服务要求的契约包含这种数据,java无法调成功。字段名称不一样,但字段类型要一致,顺序也要对应,字段要写成属性,java用getxxx和setxxx,net写成public 类型 xxx{get;set;}。
Java:
public class SubmitSparkRequest {
private SparkLauncherContext _context;
private String _taskId;
public SparkLauncherContext getContext()
{
return this._context;
}
public void setContext(SparkLauncherContext value) {
this._context=value;
}
public String getTaskId()
{
return this._taskId;
}
public void setTaskId(String value) {
this._taskId=value;
}
}
C#:
public class SubmitSparkRequest
{
public SparkLauncherContext Context
{
get;
set;
}
public String TaskId
{
get;
set;
}
}
跨语言情况下,服务端契约和客户端契约应该单独写成文件最好不要混合其它无关的字段和方法,防止干扰出错,下面列出服务端契约变动的影响:
情况 |
影响 |
必须同步契约 |
服务端改契约字段名或者类名 |
无影响 |
不需要 |
服务端改契约字段类型 |
调方失败 |
需要 |
服务端在响应契约末尾增加字段 |
调方获取不了新字段,旧的无影响 |
不一定需要 |
服务端删除字段 |
调方失败 |
需要 |
关于性能问题:
1、c#服务使用的是iocp技术,java使用的是iocp/epoll保证了服务端性能,服务端内部全异步操作,没有等待线程,服务端与客户端保持长连接并且自动断线重连,定时心跳。简单起见,一般情况下使用总线转发就行了,粗略测试情况下吞吐量10000左右,java作总线性能高30%左右,如果要求较高,可以使用服务端直接调用方式,不通过总线转发,且多个相同的服务可以实现简单负载均衡(须部署在不同机器上),c#之间实现通过udp调用,吞吐量可达30000左右(传输速度1.5GB/s)。序列化为了使用方便采用的是内置自己实现的,尽量通明化和傻瓜化,性能上c#单线程序列化反序化十个字段小对象可达百万每秒。目前网站http://106.14.193.150/blog/ 和http://106.14.193.150/cjzf 及其管理后台都是通过这种技术实现的,仅花钱购买一台低配置的阿里云作前端服务器,调用后端十几个轻重服务搭建而成的(部署在自有机器上)。
附件下载:
dotnet.rar
Ljc.JFramework.jar.rar
本文章转自 http://106.14.193.150/blog/Detail.cshtml?id=59fab9622e0ee312904afcf8#_配置文件
转载于:https://www.cnblogs.com/lhxsoft/p/8609558.html
java和c#通过esb服务互调用组件相关推荐
- Java之 Spring Cloud 微服务的 SpringCloud Config 配置中心(第四个阶段)【二】【SpringBoot项目实现商品服务器端调用】
SpringCloud学习目录点击跳转对应的文章 Java之 Spring Cloud 微服务搭建(第一个阶段)[一][SpringBoot项目实现商品服务器端是调用] Java之 Spring Cl ...
- Java开发必读--初识微服务一定要阅读这篇文章
原文转自一线互联网资深架构师,微服务布道师小马哥的原创文章,始发与小马哥公众号. 微服务是什么? 微服务是一种细粒度(Fine-Grain)的SOA 或许在座的高朋了解过其概念.个人认为,与其说微服务 ...
- 万字长文解析:分布式架构、SOA、微服务架构、API网关、ESB服务总线架构之间的关联及演进
1架构演进 架构十五年:改变的是形态,不变的是目的 业务驱动架构形态变化 过去十几年,随着互联网发展以及业务的多样化,系统的架构也在不断发生变化,总体上来说大体经历了从单体应用架构-垂直应用架构-分布 ...
- esb 服务编排_在ESB中进行路由和编排之间的选择
esb 服务编排 介绍 如今,企业服务总线确实是有用的解决方案,它结合了一系列工具,可以解决应用程序和服务集成领域中的实际问题. 但是,它们给工具箱带来了轻微的不便,给工具箱用户带来了不便,后者知道解 ...
- java cxf服务端代码_【JAVA】 cxf 生成 webservice 服务端代码
CXF Apache CXF = Celtix + XFire.CXF 继承了 Celtix 和 XFire 两大开源项目的精华,提供了对 JAX-WS 全面的支持,并且提供了多种 Binding . ...
- 通过jsl工具将java程序注册为windows服务
通过jsl工具将java程序注册为windows服务 首先下载jsl工具包,主要有jsl.exe可执行文件和jsl.ini配置信息文件 jsl 下载地址 在应用目录下新建以下几个路径 lib目录内容如 ...
- spring cloud java b2b2c o2o分布式 微服务电子商务平台
大型企业分布式互联网电子商务平台,推出PC+微信+APP+云服务的云商平台系统,其中包括B2B.B2C.C2C.O2O.新零售.直播电商等子平台. 需要JAVA Spring Cloud大型企业分布式 ...
- 面向Java应用的快速Web服务支持工具 - Netrifex
面向Java应用的快速Web服务支持工具 - Netrifex Proxisoft今天宣布Netrifex 1.0版. Netrifex可以立即把Web Services添加到现有的Java SE和J ...
- 使用nodejs和Java访问远程服务器的服务
既然这篇文章用的是nodejs和Java访问远程服务器的服务,那么咱们先用另一门编程语言,SAP的ABAP(我日常工作使用得最多的编程语言)来开发一个服务吧. 这是我用ABAP编程语言实现服务的类:Z ...
最新文章
- Mysql事务字符集
- 暴 雨 雲 于 7月17日
- 使用Git进行代码管理的心得
- Nginx+Redis+Ehcache:大型高并发与高可用的三层缓存架构总结
- Windows环境下MinGW/gcc安装和环境配置
- Java基础02 方法与数据成员
- Redis和Memcached整体
- cisco 防火墙模拟器_【方案分享】如何解决cisco设备无法进入系统问题?
- c++反汇编与逆向分析技术揭秘_C++反汇编与逆向分析技术揭秘
- 获取本地ip地址适用于windows和Linux环境
- 批量复制文件并改成有顺序的文件名
- 《Sharding-JDBC》——数据库分表+数据库脱敏实现方案
- 分式加法JAVA程序_分式加减运算的八种技巧,有几种方法学校老师没讲过,记得收藏...
- MetaFun 小传
- 提高项目进度的5个建议
- 电商运营如何打造爆品?
- 在其他电脑远程访问svn
- 散列:排解冲突(1)
- Cadence Allegro 生成网表提示Check the symbol for consistency of pin definition 错误的解决办法
- 平板电脑性能测试软件,最新电脑性能测试软件PCMark 8正式登陆Steam
热门文章
- Unity动画系统知识体系概览
- Android 12原生壁纸下载
- vue的keep-alive属性
- 【Python爬虫案例学习4】Python 爬取meizitu
- mac m1 解决fatal: unable to access ‘https://github.com/Homebrew/homebrew-core/‘ ;同时指定intel架构的brew 版本
- open3d画3D矩形框
- excel导出图片---HSSFWorkbook--SXSSFWorkbook
- 在Qt中设置程序图标的方法介绍
- python随机生成英文字母_在Python中生成随机字母
- spring之aop(前置通知,后置通知,环绕通知,过滤通知,异常通知)