Hessian
基于hessian, Burlap协议调用java方法
一个最简单的例子
基于hessian协议调用java方法
先定义一个接口：
public interface TestService {
public void test(String name);
}
实现这个接口：
public class TestServiceImpl implements TestService {
@Override
public void test(String name) {
System.out.println("test:" + name);
}
}
基于hessian模拟rpc怎么调用呢？
public class HessianSkeletonTest {
private static TestServiceImpl testService;
private static HessianSkeleton skeleton;
@BeforeClass
public static void initialize() {
testService = new TestServiceImpl();
skeleton = new HessianSkeleton(testService, TestService.class);
}
/**
* m 0x00 0x04 test
* S 0x00 0x0A helloworld
* z
*
* @throws IOException
*/
@Test
public void invoke() throws IOException {
ByteArrayOutputStream bos = new ByteArrayOutputStream();
// m 0x00 0x04 test
bos.write('m');
bos.write(0x00);
bos.write(0x04);
bos.write("test".getBytes());
// S 0x00 0x0A helloworld
String s = "helloworld";
int length = 10;
bos.write('S');
length = (length << 16) >>> 16;
bos.write(length >>> 8);
bos.write((length << 8) >>> 8);
bos.write(s.getBytes());
// z
bos.write('z');
InputStream isToUse = new ByteArrayInputStream(bos.toByteArray());
OutputStream osToUse = new ByteArrayOutputStream();
AbstractHessianInput in = new HessianInput(isToUse);
AbstractHessianOutput out = new HessianOutput(osToUse);
try {
skeleton.invoke(in, out);
} catch (Throwable e) {
e.printStackTrace();
}
}
}
运行输出：
test:helloworld
基于hessian协议调用java方法-一个map例子
基于hessian协议调用java方法-一个map例子
map
map ::= M t b16 b8 type-string (object, object)* z
Map类型，同时支持对象Object。
type描述map类型，可为空
如果是对象，type表示类全名
先定义一个接口：
public interface TestService {
public void testMap(Map<String, Object> map);
}
实现这个接口：
public class TestServiceImpl implements TestService {
public void testMap(Map<String, Object> map) {
if (map != null) {
for (Entry<String, Object> entry : map.entrySet()) {
System.out.println("key: " + entry.getKey());
System.out.println("value: " + entry.getValue());
}
} else {
System.out.println("null");
}
}
}
基于hessian模拟rpc怎么调用呢？
public class HessianSkeletonTest {
private static TestServiceImpl testService;
private static HessianSkeleton skeleton;
@BeforeClass
public static void initialize() {
testService = new TestServiceImpl();
skeleton = new HessianSkeleton(testService, TestService.class);
}
/**
* m 0x00 0x07 testMap
* M
* S 0x00 0x04 name
* S 0x00 0x06 whoami
* S 0x00 0x03 age
* I 0x00 0x00 0x02 0x0C #0000 0000 0010 1100 #44
* S 0x00 0x04 male
* T
* z #end of map
* z #end of method
*
* @throws IOException
*/
@Test
public void invokeTestMap() throws IOException {
ByteArrayOutputStream bos = new ByteArrayOutputStream();
String skey = null;
String svalue = null;
int ivalue = 0;
boolean bvalue = false;
// m 0x00 0x07 testMap
bos.write('m');
bos.write(0x00);
bos.write(0x07);
bos.write("testMap".getBytes());
// M
bos.write('M');
// S 0x00 0x04 name
bos.write('S');
skey = "name";
int length = 4;
length = (length << 16) >>> 16;
bos.write(length >>> 8);
bos.write((length << 8) >>> 8);
bos.write(skey.getBytes());
// S 0x00 0x06 whoami
bos.write('S');
svalue = "whoami";
length = 6;
length = (length << 16) >>> 16;
bos.write(length >>> 8);
bos.write((length << 8) >>> 8);
bos.write(svalue.getBytes());
// S 0x00 0x03 age
bos.write('S');
skey = "age";
length = 3;
length = (length << 16) >>> 16;
bos.write(length >>> 8);
bos.write((length << 8) >>> 8);
bos.write(skey.getBytes());
// I 0x00 0x00 0x02 0x0C #0000 0000 0000 0000 0000 0000 0010 1100 #44
bos.write('I');
ivalue = 44;
bos.write(ivalue >>> 24);
ivalue = (ivalue << 8) >>> 8;
bos.write(ivalue >>> 16);
ivalue = (ivalue << 8) >>> 8;
bos.write(ivalue >>> 8);
ivalue = (ivalue << 8) >>> 8;
bos.write(ivalue);
// S 0x00 0x04 male
bos.write('S');
skey = "male";
length = 4;
length = (length << 16) >>> 16;
bos.write(length >>> 8);
bos.write((length << 8) >>> 8);
bos.write(skey.getBytes());
// T
bvalue = true;
bos.write(bvalue ? 'T' : 'F');
// z
bos.write('z');
// z
bos.write('z');
InputStream isToUse = new ByteArrayInputStream(bos.toByteArray());
OutputStream osToUse = new ByteArrayOutputStream();
AbstractHessianInput in = new HessianInput(isToUse);
AbstractHessianOutput out = new HessianOutput(osToUse);
try {
skeleton.invoke(in, out);
} catch (Throwable e) {
e.printStackTrace();
}
}
}
m 0x00 0x07 testMap
M
S 0x00 0x04 name
S 0x00 0x06 whoami
S 0x00 0x03 age
I 0x00 0x00 0x02 0x0C #0000 0000 0010 1100 #44
S 0x00 0x04 male
T
z #end of map
z #end of method
运行输出：
key: name
value: whoami
key: age
value: 44
key: male
value: true
基于Burlap协议调用java方法
public interface TestService {
public void test(String name);
}
public class TestServiceImpl implements TestService {
@Override
public void test(String name) {
System.out.println("test:" + name);
}
}
public class BurlapSkeletonTest {
private static TestServiceImpl testService;
private static BurlapSkeleton skeleton;
@BeforeClass
public static void initialize() {
testService = new TestServiceImpl();
skeleton = new BurlapSkeleton(testService, TestService.class);
}
private Document initBurlapRequest() throws BurlapException {
DocumentBuilder domBuilder = null;
try {
domBuilder = DocumentBuilderFactory.newInstance().newDocumentBuilder();
} catch (ParserConfigurationException e) {
throw new BurlapException(e);
}
return domBuilder.newDocument();
}
private InputStream getBurlapInputStream(Document doc) throws BurlapException {
ByteArrayOutputStream bos = new ByteArrayOutputStream();
Transformer transformer = null;
try {
TransformerFactory transFactory = TransformerFactory.newInstance();
transformer = transFactory.newTransformer();
} catch (Exception e) {
throw new BurlapException(e);
}
transformer.setOutputProperty("encoding", "gb2312");
transformer.setOutputProperty("indent", "yes");
// omit xml declaration
// <?xml version="1.0" encoding="GB2312" standalone="no"?>
transformer.setOutputProperty(OutputKeys.OMIT_XML_DECLARATION, "yes");
DOMSource source = new DOMSource();
source.setNode(doc);
StreamResult result = new StreamResult();
result.setOutputStream(bos);
try {
transformer.transform(source, result);
} catch (Exception e) {
throw new BurlapException(e);
}
System.out.println(new String(bos.toByteArray()));
return new ByteArrayInputStream(bos.toByteArray());
}
/**
* <burlap:call>
* <method>test</method>
* <string>helloworld</string>
* </burlap:call>
*
* @throws IOException
*/
@Test
public void invoke() throws IOException {
Document doc = null;
try {
doc = initBurlapRequest();
} catch (BurlapException e) {
throw new IOException(e);
}
Element root = doc.createElement("burlap:call");
Element element = doc.createElement("method");
element.setTextContent("test");
root.appendChild(element);
element = doc.createElement("string");
element.setTextContent("helloworld");
root.appendChild(element);
doc.appendChild(root);
InputStream isToUse;
try {
isToUse = getBurlapInputStream(doc);
} catch (BurlapException e) {
throw new IOException(e);
}
OutputStream osToUse = new ByteArrayOutputStream();
BurlapInput in = new BurlapInput(isToUse);
BurlapOutput out = new BurlapOutput(osToUse);
try {
skeleton.invoke(in, out);
} catch (Throwable e) {
e.printStackTrace();
}
}
}
Hessian （RPC）序列化：对象类型（Java）
要实现一个远程方法调用，最基本的是要考虑调用方法的序列化，包括方法名，传参（参数类型以及传值），返回类型以及返回值。
方法名很简单，就是个字符串，传参和返回就比较麻烦。
传参和返回有类型，光这些类型表示就比较多，尤其是对象类型，特别是复杂对象类型。
Hessian针对对象的序列化不同于Java，对象的序列化形式如下：
map
map ::= M t b16 b8 type-string (object, object)* z
Map类型，同时支持对象Object。
type描述map类型，可为空
如果是对象，type表示类全名
基于Hessian RPC序列化（协议）调用java方法: 针对对象（Java）类型序列化的例子。
在这个例子中，仅根据Hessian RPC序列化模拟一个本地Java方法的调用，并不实现远程调用，和调用本地方法效果是一样的。
先定义一个接口：
package com.chos.test.service;
public class Block {
private long id;
private int account;
/**
* expenses and receipts
*
* 收入还是支出
*/
private boolean receipt;
private String signature;
public long getId() {
return id;
}
public void setId(long id) {
this.id = id;
}
public int getAccount() {
return account;
}
public void setAccount(int account) {
this.account = account;
}
public boolean isReceipt() {
return receipt;
}
public void setReceipt(boolean receipt) {
this.receipt = receipt;
}
public String getSignature() {
return signature;
}
public void setSignature(String signature) {
this.signature = signature;
}
}
public interface TestService {
public void testObjectBlock(Block block);
}
实现这个接口：
public class TestServiceImpl implements TestService {
public void testObjectBlock(Block block) {
System.out.println(ToStringBuilder.reflectionToString(block, ToStringStyle.MULTI_LINE_STYLE));
}
}
基于hessian模拟rpc怎么调用呢？
public class HessianSkeletonTest {
private static TestServiceImpl testService;
private static HessianSkeleton skeleton;
@BeforeClass
public static void initialize() {
testService = new TestServiceImpl();
skeleton = new HessianSkeleton(testService, TestService.class);
}
@Test
public void invokeTestObjectBlock() throws IOException {
ByteArrayOutputStream bos = new ByteArrayOutputStream();
// m 0x00 0x0F testObjectBlock
bos.write('m');
bos.write(0x00);
bos.write(0x0F);
bos.write("testObjectBlock".getBytes());
// M
bos.write('M');
// t x00 x1B com.chos.test.service.Block
bos.write('t');
String className = Block.class.getName();
int classNameLength = 27;
classNameLength = (classNameLength << 16) >>> 16;
bos.write(classNameLength >>> 8);
bos.write((classNameLength << 8) >>> 8);
bos.write(className.getBytes());
// S 0x00 0x02 id
bos.write('S');
String fieldId = "id";
int fieldIdLength = 2;
fieldIdLength = (fieldIdLength << 16) >>> 16;
bos.write(fieldIdLength >>> 8);
bos.write((fieldIdLength << 8) >>> 8);
bos.write(fieldId.getBytes());
// L 0x00 0x00 0x00 0x00 0x00 0x00 0x02 0x0C #0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0010 1100 #44
bos.write('L');
long fieldIdValue = 44;
bos.write((int) (fieldIdValue >>> 56));
fieldIdValue = (fieldIdValue << 8) >>> 8;
bos.write((int) (fieldIdValue >>> 48));
fieldIdValue = (fieldIdValue << 8) >>> 8;
bos.write((int) (fieldIdValue >>> 40));
fieldIdValue = (fieldIdValue << 8) >>> 8;
bos.write((int) (fieldIdValue >>> 32));
fieldIdValue = (fieldIdValue << 8) >>> 8;
bos.write((int) (fieldIdValue >>> 24));
fieldIdValue = (fieldIdValue << 8) >>> 8;
bos.write((int) (fieldIdValue >>> 16));
fieldIdValue = (fieldIdValue << 8) >>> 8;
bos.write((int) (fieldIdValue >>> 8));
fieldIdValue = (fieldIdValue << 8) >>> 8;
bos.write((int) fieldIdValue);
// S 0x00 0x07 account
bos.write('S');
String fieldAccount = "account";
int fieldAccountLength = 7;
fieldAccountLength = (fieldAccountLength << 16) >>> 16;
bos.write(fieldAccountLength >>> 8);
bos.write((fieldAccountLength << 8) >>> 8);
bos.write(fieldAccount.getBytes());
// I 0x00 0x00 0x04 0xD2 #0000 0000 0000 0000 0000 0100 1101 0010 #1234
bos.write('I');
int fieldAccountValue = 1234;
bos.write(fieldAccountValue >>> 24);
fieldAccountValue = (fieldAccountValue << 8) >>> 8;
bos.write(fieldAccountValue >>> 16);
fieldAccountValue = (fieldAccountValue << 8) >>> 8;
bos.write(fieldAccountValue >>> 8);
fieldAccountValue = (fieldAccountValue << 8) >>> 8;
bos.write(fieldAccountValue);
// S 0x00 0x07 receipt
bos.write('S');
String fieldReceipt = "receipt";
int fieldReceiptLength = 7;
fieldReceiptLength = (fieldReceiptLength << 16) >>> 16;
bos.write(fieldReceiptLength >>> 8);
bos.write((fieldReceiptLength << 8) >>> 8);
bos.write(fieldReceipt.getBytes());
// T
boolean fieldReceiptValue = true;
bos.write(fieldReceiptValue ? 'T' : 'F');
// S 0x00 0x09 signature
bos.write('S');
String fieldSignature = "signature";
int fieldSignatureLength = 9;
fieldSignatureLength = (fieldSignatureLength << 16) >>> 16;
bos.write(fieldSignatureLength >>> 8);
bos.write((fieldSignatureLength << 8) >>> 8);
bos.write(fieldSignature.getBytes());
// S 0x00 0x0F signature value
bos.write('S');
String fieldSignatureValue = "signature value";
int fieldSignatureValueLength = 15;
fieldSignatureValueLength = (fieldSignatureValueLength << 16) >>> 16;
bos.write(fieldSignatureValueLength >>> 8);
bos.write((fieldSignatureValueLength << 8) >>> 8);
bos.write(fieldSignatureValue.getBytes());
// z
bos.write('z');
// z
bos.write('z');
InputStream isToUse = new ByteArrayInputStream(bos.toByteArray());
OutputStream osToUse = new ByteArrayOutputStream();
AbstractHessianInput in = new HessianInput(isToUse);
AbstractHessianOutput out = new HessianOutput(osToUse);
try {
skeleton.invoke(in, out);
} catch (Throwable e) {
e.printStackTrace();
}
}
}
m 0x00 0x0F testObjectBlock
M
t x00 x1B com.chos.test.service.Block
S 0x00 0x02 id
L 0x00 0x00 0x00 0x00 0x00 0x00 0x02 0x0C #0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0000 0010 1100 #44
S 0x00 0x07 account
I 0x00 0x00 0x04 0xD2 #0000 0000 0000 0000 0000 0100 1101 0010 #1234
S 0x00 0x07 receipt
T
S 0x00 0x09 signature
S 0x00 0x0F signature value
z #end of map
z #end of method
运行输出：
com.chos.test.service.Block@1064425[ id=44 account=1234 receipt=true signature=signature value ]
1、基于hessian协议调用java方法：https://lobin.iteye.com/blog/2367731
2、基于hessian协议调用java方法-一个map例子：https://lobin.iteye.com/blog/2368200
3、基于hessian协议进行rpc调用（http方式）：https://lobin.iteye.com/blog/2368721
相关推荐
在图像处理领域，多尺度Hessian滤波器是一种高级的图像增强技术，它主要用于检测图像中的线性结构，特别是对于微弱或者噪声较大的图像特征有很好的识别能力。这个技术是基于数学形态学的Hessian矩阵理论，由V.S. ...
赠送jar包：hessian-4.0.63.jar； 赠送原API文档：hessian-4.0.63-javadoc.jar； 赠送源代码：hessian-4.0.63-sources.jar； 赠送Maven依赖信息文件：hessian-4.0.63.pom； 包含翻译后的API文档：hessian-4.0.63-...
- 在实际开发中，我们可能会需要编写一些辅助工具类来处理Hessian的相关操作，例如Hessian2Input和Hessian2Output，它们用于读写Hessian序列化的二进制流。 6. **安全性与优化**： - 虽然Hessian协议效率高，但其...
在IT领域，尤其是在医学图像分析中，Hessian矩阵是一个重要的数学工具，用于图像特征检测，特别是在血管分割的应用中。本文将深入探讨标题和描述中提到的"基于Hessian矩阵增强的心血管分割"这一主题。 Hessian矩阵...
Hessian是一种高效的二进制序列化协议，常用于实现轻量级的远程过程调用（RPC）。这个案例涉及到了Hessian在Java和Python之间的跨语言通信。以下是对Hessian技术及其应用的详细解释： 1. **Hessian简介**：Hessian...
在Spring框架中集成Hessian是为了实现远程方法调用（Remote Method Invocation, RMI），这是一种轻量级的序列化协议，可以高效地传输Java对象。Hessian使得服务提供者和服务消费者之间能够通过网络进行快速的数据...
Hessian矩阵是图像处理和计算机视觉领域中一个重要的数学工具，尤其在特征检测和结构分析中扮演着关键角色。在本项目中，它被应用于血管增强，这是一个在医学成像和图像分析中常见的任务，目的是突出血管结构，以...
本文将详细探讨"Jerman增强滤波器"，它是一种基于Hessian矩阵的滤波器，旨在突出图像中的血管结构。Hessian矩阵在图像处理中起到关键作用，因为它可以有效地检测图像的局部特征，特别是边缘和曲线。 首先，我们来...
本文将深入探讨Hessian框架的基础知识，它是一个高效的二进制序列化协议，广泛应用于Java和.NET之间跨语言通信。通过学习Hessian，我们可以更有效地处理数据传输，提高应用性能。 首先，让我们理解什么是序列化。...
Java Hessian远程调用是一种高效的、轻量级的RPC（Remote Procedure Call）解决方案，它允许Java应用程序通过网络进行跨语言的通信。Hessian是BEA Systems开发的一种二进制Web服务协议，它提供了序列化和远程方法...
这篇教程主要探讨了如何利用MATLAB编程环境以及Hessian矩阵来增强2D和3D图像中的血管脊状结构。Hessian矩阵是一种数学工具，用于计算图像中像素点的二阶导数，从而帮助识别图像的边缘和特征点。 首先，我们要理解...
在图像处理领域，Hessian Frangi滤波算法是一种用于血管检测和结构分析的高级技术，尤其在医学成像中有着广泛的应用。它基于Hessian矩阵，可以有效地检测图像中的线性和圆状结构。本篇文章将深入探讨如何使用Python...
Hessian是一种二进制Web服务协议，由Caucho Technology公司开发，主要用于提供轻量级、高效的远程方法调用（Remote Method Invocation, RMI）机制。它结合了HTTP协议的可扩展性和Java序列化机制的易用性，使得在...
这个压缩包包含了Hessian的多个版本，分别是Hessian3.1.6、Hessian3.2.1以及Hessian4.0.7。每个版本都有其特定的功能改进和优化，了解这些版本的区别和适用场景对于开发者来说至关重要。 Hessian3.1.6是Hessian的一...
在这个“hessian服务端 客户端 可运行”的压缩包文件中，很可能包含了一个完整的示例，让我们来详细探讨Hessian在服务端和客户端的实现及其重要性。 首先，我们来理解一下Hessian服务端。在Java中，Hessian服务端...
在IT行业中，尤其是在移动开发领域，Hessian是一种广泛使用的二进制协议，它允许远程对象调用(Remote Object Invocation)。本知识点主要关注的是在Android平台上，如何使用Hessian进行异步请求访问，以便提高应用...
赠送jar包：hessian-4.0.63.jar； 赠送原API文档：hessian-4.0.63-javadoc.jar； 赠送源代码：hessian-4.0.63-sources.jar； 赠送Maven依赖信息文件：hessian-4.0.63.pom； 包含翻译后的API文档：hessian-4.0.63-...
在IT行业中，Hessian是一种轻量级的二进制序列化协议，主要用于远程方法调用（RMI）和Web服务。Hessian由Caucho Technology开发，它的设计目标是提供比XML更快、更简洁的数据传输方式，从而提高网络通信效率。在Java...
在图像处理领域，Hessian矩阵是一种非常重要的工具，尤其在边缘检测和纹理分析中发挥着关键作用。本项目“hessian_homework1_hessian_matlab中心线_hessianmatlab_”是利用MATLAB实现的Hessian矩阵计算，用于寻找...