重要：Missian刚刚更新到0.31，新增了Future风格的回调方式。
Missian没有绑定spring，但是强烈推荐配合spring一起使用。异步客户端由于需要调用BeanLocator去寻找回调的
Bean，如果配合Spring使用，可以直接使用SpringLocator(BeanLocator的唯一实现)，否则需要自己实现。
使用异步客户端需要注意一点：由于是异步调用，所以一个远程方法的返回值永远是null（如果不是void的话）或者是原生数据类型的默认值。一段时间后(比如100毫秒)后客户端收到这个返回值，会去找到相应的回调对象进行调用。
异步的优势是：在调用的期间我们不需要像同步调用一样有一个线程一直在等着它的返回值，而是调用完即可返回释放线程，当客户端接受到返回值后会进行
回调，业务流程可以继续往下执行。不要小看这个等待的时间，假如A服务调用了一个跨机房的服务或者一个重型的服务B，那么B的响应时间可能是100毫秒甚
至更多，那么可以想象在高并发的情况下，可能A服务的全部线程都耗死在无穷的等待上了。
我们还是先看看如何配合Spring来使用Missian异步客户端。
步骤一：给Hello.hello(String, int)创建一个回调类
注意和0.2x相比，这里有比较大的不同：
public class HelloCallback {
public void hello(String returnValue) {
System.out.println(returnValue);
}
}
这个类的方法要和Hello接口的方法一一对应，Hello中所有方法（除了返回值为void的方法）都应该有一个回调方法，回调方法名和Hello接口中对应的方法名一样，而且只接受一个参数，参数类型和对应方法的返回值一致。
例如，Hello有一个hello(String, int)方法的返回值是String类型，那么要求HelloCallback必须有一个hello(String)的方法。
步骤二：修改Hello接口，用注解的方法声明回调Bean
这里和0.21前的版本也有所不同，以前这个注解是用在方法上的，现在直接用在接口上，所以一个接口只需要注解一次了。
@CallbackTarget("helloCallback")
public interface Hello {
public String hello(String name, int age);
}
步骤三：在Spring配置文件中配置这个回调Bean
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">
<!-- your callback bean, missian client will invoke its execute() method when received the returned object -->
<bean id="helloCallback" class="com.missian.example.bean.HelloCallback">
</bean>
</beans>
步骤四：在Spring中创建AsyncMissianProxyFactory
<bean id="asyncMissianProxyFactory" class="com.missian.client.async.AsyncMissianProxyFactory" init-method="init" destroy-method="destroy">
<constructor-arg >
<bean class="com.missian.common.beanlocate.SpringLocator"/>
</constructor-arg>
</bean>
这里我们使用的是AsyncMissianProxyFactory的最简单的构造函数，只接受一个BeanLocator。这时候默认创建一个4
个线程的线程池用来处理回调逻辑，1个线程用来处理IO，需要指定线程数，或者将一个已经存在的线程池传入，可以参考其它几个构造函数：
public AsyncMissianProxyFactory(BeanLocator callbackLoacator, ExecutorService threadPool, int callbackIoProcesses, boolean logBeforeCodec, boolean logAfterCodec, NetworkConfig networkConfig) {}
public AsyncMissianProxyFactory(BeanLocator callbackLoacator, ExecutorService threadPool, int callbackIoProcesses, boolean logBeforeCodec, boolean logAfterCodec){}
public AsyncMissianProxyFactory(BeanLocator callbackLoacator, ExecutorService threadPool) {}
public AsyncMissianProxyFactory(BeanLocator callbackLoacator, int threadPoolSize, int callbackIoProcesses, boolean logBeforeCodec, boolean logAfterCodec) {}
public AsyncMissianProxyFactory(BeanLocator callbackLoacator, ExecutorService threadPool, NetworkConfig networkConfig) {}
public AsyncMissianProxyFactory(BeanLocator callbackLoacator, int threadPoolSize, int callbackIoProcesses, boolean logBeforeCodec, boolean logAfterCodec, NetworkConfig networkConfig) {}
public AsyncMissianProxyFactory(BeanLocator callbackLoacator, int threadPoolSize){}
假如在服务器里使用Missian客户端，可以考虑将服务器主线程池传入给AsyncMissianProxyFactory，共享线程池。
步骤五：实现异步调用
public static void main(String[] args) throws IOException {
ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("com/missian/example/client/async/withspring/applicationContext-*.xml");
//actually you can inject AsyncMissianProxyFactory into any other beans to use it.
//we just show how AsyncMissianProxyFactory works here.
AsyncMissianProxyFactory asyncMissianProxyFactory = (AsyncMissianProxyFactory)context.getBean("asyncMissianProxyFactory");
Hello hello = (Hello)asyncMissianProxyFactory.create(Hello.class, "tcp://localhost:1235/hello");
long time = System.currentTimeMillis();
for(int i=0; i<10000; i++) {
hello.hello("gg", 25);
}
System.out.println(System.currentTimeMillis()-time);
}
你可以清楚地看到，所有的请求都发送出去之后，返回值陆续返回并回掉了HelloCallback。
和同步的客户端一样，可以使用http协议发送数据：
Hello hello = (Hello)asyncMissianProxyFactory.create(Hello.class, "http://localhost:1235/hello");
但目前比较遗憾的是，还不能够支持异步调用Hessian服务。
另外需要说明的是，这个直接从Context里面取出AsyncMissianProxyFactory只是用来演示异步调用的用法；正常的做法应该是将AsyncMissianProxyFactory注入到我们需要使用它的Bean。
===============0.31.新增功能分割线===================
如何为重载方法都实现回调？
比如以下两个方法都需要回调：
public interface Hello {
String hello(String name, int age, String country);
String hello(String name, int age);
}
按照上面所说的，他们的回调方法都映射到:
void hello(String);
这样会造成回调错误，因此需要使用一个注解来说明回调方法名：
@CallbackTarget("helloCallback")
public interface Hello {
@CallbackTargetMethod("hello0")
public String hello(String name, int age, String country);
@CallbackTargetMethod("hello1")
public String hello(String name, int age);
}
对应的，回调类的实现：
public class HelloCallback {
public void hello0(String returnValue) {
System.out.println(returnValue);
}
public void hello1(String returnValue) {
System.out.println("hello1:"+returnValue);
}
}
注意如果不使用注解，系统寻找默认的方法。注解同样也可以用于非重载的方法。
另外一种回调的实现
如果不希望使用注解，那么还有另外一种方式可供选择：
如果服务器端的方法是：
String hello(String name, int age);
那么客户端的接口可以写成（注意，Missian不要求服务器端和客户端使用同一个接口类，甚至接口名都可以不同，而只要求方法名及参数必须匹配）：
public interface Hello {
public String hello(String name, int age, Callback cb);
}
调用时：
Hello hello = (Hello)factory.create(Hello.class, "http://localhost:1235/hello");
Callback cb = ......
hello.hello("name", 80, cb);
即可以异步调用成功。
Future风格的异步实现
我个人非常喜欢Future这种方法，在Mina中就有大量的使用。同样Missian也提供了这样一个能力。提供了一个AysncFuture，即可以通过get()变成同步，也可以通过addListner()来监听，一旦返回值到达，就会出发监听器。
如果服务器端的方法是：
String hello(String name, int age);
那么客户端的接口可以写成（注意，Missian不要求服务器端和客户端使用同一个接口类，甚至接口名都可以不同，而只要求方法名及参数必须匹配）：
public interface Hello {
public AysncFuture<String> hello(String name, int age, Class<String> returnType);
}
调用时：
Hello hello = (Hello)factory.create(Hello.class, "http://localhost:1235/hello");
Async<String> future = hello.hello("name", 80, String.class);
如果想阻塞直到数据返回，那么：
String value = future.get();
System.out.println(value);
如果想通过监听器实现事件驱动：
AsyncListener listener = ....
future.addListener(listener);
分享到：
相关推荐
弥赛亚 一个java RPC框架，无模式风格
Spring 集 成ActiveMQ 配置 异步RPC框架 Missian ActiveMq-JMS简单实例使用tomcat
yolov5检测人脸和关键点，只依赖opencv库就可以运行，程序包含C++和Python两个版本的。 本套程序根据https://github.com/deepcam-cn/yolov5-face 里提供的训练模型.pt文件。转换成onnx文件， 然后使用opencv读取onnx文件做前向推理，onnx文件从百度云盘下载，下载 链接：https://pan.baidu.com/s/14qvEOB90CcVJwVC5jNcu3A 提取码：duwc 下载完成后，onnx文件存放目录里，C++版本的主程序是main_yolo.cpp，Python版本的主程序是main.py 。此外，还有一个main_export_onnx.py文件，它是读取pytorch训练模型.pt文件生成onnx文件的。 如果你想重新生成onnx文件，不能直接在该目录下运行的，你需要把文件拷贝到https://github.com/deepcam-cn/yolov5-face 的主目录里运行，就可以生成onnx文件。
文件操作、数据分析和网络编程等。Python社区提供了大量的第三方库，如NumPy、Pandas和Requests，极大地丰富了Python的应用领域，从数据科学到Web开发。Python库的丰富性是Python成为最受欢迎的编程语言之一的关键原因之一。这些库不仅为初学者提供了快速入门的途径，而且为经验丰富的开发者提供了强大的工具，以高效率、高质量地完成复杂任务。例如，Matplotlib和Seaborn库在数据可视化领域内非常受欢迎，它们提供了广泛的工具和技术，可以创建高度定制化的图表和图形，帮助数据科学家和分析师在数据探索和结果展示中更有效地传达信息。
5-3
"Java八股文"是一个在程序员社群中流行的术语，特别是在准备技术面试时。它指的是一系列在Java编程面试中经常被问到的基础知识点、理论概念和技术细节。这个术语的命名来源于中国古代科举考试中的“八股文”，一种具有固定格式和套路的文章形式。 在Java编程的上下文中，"Java八股文"通常包括以下几个方面："Java八股文"是一个在程序员社群中流行的术语，特别是在准备技术面试时。它指的是一系列在Java编程面试中经常被问到的基础知识点、理论概念和技术细节。这个术语的命名来源于中国古代科举考试中的“八股文”，一种具有固定格式和套路的文章形式。 在Java编程的上下文中，"Java八股文"通常包括以下几个方面："Java八股文"是一个在程序员社群中流行的术语，特别是在准备技术面试时。它指的是一系列在Java编程面试中经常被问到的基础知识点、理论概念和技术细节。这个术语的命名来源于中国古代科举考试中的“八股文”，一种具有固定格式和套路的文章形式。 在Java编程的上下文中，"Java八股文"通常包括以下几个方面："Java八股文"是一个在程序员社群中流行的术语，特别是在准备技术面试时。它
麦肯锡咨询顾问必备宝典.ppt
蜉蝣优化算法MA MATLAB源码， 应用案例为函数极值求解以及优化svm进行分类，代码注释详细，可结合自身需求进行应用
运营主播-课程网盘链接提取码下载 .txt
麦肯锡：xxTII整合营销策略.ppt
文件操作、数据分析和网络编程等。Python社区提供了大量的第三方库，如NumPy、Pandas和Requests，极大地丰富了Python的应用领域，从数据科学到Web开发。Python库的丰富性是Python成为最受欢迎的编程语言之一的关键原因之一。这些库不仅为初学者提供了快速入门的途径，而且为经验丰富的开发者提供了强大的工具，以高效率、高质量地完成复杂任务。例如，Matplotlib和Seaborn库在数据可视化领域内非常受欢迎，它们提供了广泛的工具和技术，可以创建高度定制化的图表和图形，帮助数据科学家和分析师在数据探索和结果展示中更有效地传达信息。
基于matlab虚拟体和人工势场相结合的编队控制算法实现对多个智能体的有效控制源码.zip
抖音快手挂载小程序-课程网盘链接提取码下载 .txt
OpenCV（Open Source Computer Vision Library）是一个开源的计算机视觉和机器学习软件库，由一系列C函数和少量C++类构成，同时提供了Python、Java、MATLAB等语言的接口。它支持在Linux、Windows、Android和Mac OS等多种操作系统上运行，并且具有高效的图像处理和计算机视觉算法，广泛应用于目标检测、人脸识别、图像分割、机器视觉等领域。 OpenCV的主要特点包括： 跨平台：OpenCV支持多种操作系统，并且可以通过不同的编程语言进行访问。 高效：OpenCV实现了许多图像处理和计算机视觉方面的通用算法，并且针对各种处理器进行了优化。 开源：OpenCV是一个开源项目，任何人都可以免费使用和修改其代码。 功能强大：OpenCV提供了丰富的视觉处理算法，包括特征检测、目标跟踪、图像分割、3D重建等。 OpenCV的发展历史可以追溯到1999年，当时Intel公司启动了CVL（Computer Vision Library）项目，旨在开发一个通用的计算机视觉库。随着时间的推移，OpenCV逐渐发展成为一个功能强大且广泛应用
基于MPC模型预测控制从原理到代码的matlab实现源码+文档说明.zip
XXX公司组织结构诊断报告.ppt
麦肯锡培训手册(2).ppt
麦肯锡方法 PPT.pps
java八股文
wireshark安装教程入门 Wireshark 是一款网络协议分析软件。 它可以捕获网络中的数据包，并对这些数据包进行详细的分析和解读，以直观的形式展示网络通信的内容。通过 Wireshark，用户可以查看数据包的源地址、目标地址、协议类型、数据内容等信息，帮助人们深入了解网络中发生的各种活动，如网络故障排查、网络性能评估、安全分析等，是网络工程师、安全研究人员等经常使用的重要工具。