初试超轻量级actor框架――akka

akka的大名在之前学Scala的时候就时常听到，就连Scala作者都不得不赞叹它对actor实现的精妙。最近写一个服务端代码，对于接受到的请求需要查询后台多个数据库，这自然就想到用多线程来并行查询，然后把结果合并起来。这里最主要的就是多线程任务的执行以及执行结果的回调。这个时候突然回忆起用Scala时一个简单的“!”就实现了多线程调用的清爽和方便，那现在用java+akka框架是什么样呢？

先找到官方网站大概的翻阅了一下，惊讶的发现这个框架比想象中强太多了。一下载下来就看到很多高质量库，httpclient, netty, jetty, asm等等，这都不知道他具体想做成什么了。在官方看到一处说明，akka有两种使用方式，一种就是作为一个模块调用，另外一种就是作为一个服务。

看完文档后，感觉akka确实非常出色！实现了actor模式这点就不说了，首先就是有非常好的容错性，其次它居然还有对内存对象实现事务的功能，还有他能非常方便的实现远程调用以及线程间通讯，还能定制路由策略，对第三方框架的集成也非常好。基于上述的功能，akka完全有实力作为系统的核心框架，通过它简单的多线程调用方式和支持远程调用，实现一个分布式计算的系统非常容易。

最后还是给个小例子，代码很简单，只是用到的库非常多，放的位置也比较分散，自己慢慢找吧。

这个是TypedActor的接口：

  
 
 
import akka.dispatch.Future;  
   
  
   
   
  
  
public interface MathTypedActor {  

   
  
  
    public Future<Integer> square(int value);  

   
  
  }

这个是TypedActor的具体实现：

  
 
 
import akka.actor.TypedActor;  
   
  
  
import akka.dispatch.Future;  

   
  
   
   
  
  
public class MathTypedActorImpl extends TypedActor implements MathTypedActor {  

   
  
   
   
  
  
    @Override 

   
  
  
    public Future<Integer> square(int value) {  

   
  
  
        return future(value * value);  

   
  
      }  
   
  
   
   
  
  }

这是调用的main方法：

  
 
 
import akka.actor.TypedActor;  
   
  
  
import akka.dispatch.Future;  

   
  
   
   
  
  
public class MathTypedActorTest {  

   
  
   
   
  
  
    public static void main(String[] args) {  

   
  
          test();  
   
  
      }  
   
  
   
   
  
  
    private static void test() {  

   
  
  
        MathTypedActor math = TypedActor.newInstance(MathTypedActor.class, MathTypedActorImpl.class);  

   
  
  
        Future<Integer> future = math.square(10);  

   
  
          future.await();  
   
  
          Integer result = future.result().get();  
   
  
          System.out.println(result);  
   
  
          TypedActor.stop(math);        
   
  
      }  
   
  
   
   
  
  }

秒客网

初试超轻量级actor框架――akka

相关文章