上篇文章是1年前写的惭愧惭愧，今天一个同事问我要demo然后看了下文章 好吧主要的代码 没写出来，今天补充下

上篇地址：http://www.cnblogs.com/rufus-hua/p/4159278.html

上篇写到 在 thrift文件夹里 新建 hello.thrift文件

如下面代码：

namespace java com.test.finagle.demo

service Hello{

string helloString(:string para)

i32 helloInt(:i32 para)

bool helloBoolean(:bool para)

void helloVoid()

string helloNull()

}

然后 点击编译 ，(如果不报错的)会看到在 target文件夹里生成 target\generated-sources\thrift\scrooge\com\test\finagle\demo 下面生成的hello.java文件 很好.

然后新建java文件 继承生成文件里的ServerIface接口

如代码：

public class HelloImpl implements Hello.ServiceIface {

public Future helloString(String para) {

return Future.value(para);

}

public Future helloInt(int para) {

return Future.value(para);

}

public Future helloBoolean(boolean para) {

return Future.value(para);

}

public Future helloVoid() {

return Future.value(null);

}

public Future helloNull() {

return Future.value(null);

}

}

ok 最后一步main 方法：

public class App {

static ListeningServer server;

public static void main(String[] args) {

Integer port = 9801;//这是 finagle 真正的监听地址

String zkHosts="127.0.0.1:9000";//这是zk服务器的地址 我这里只有一台 如果多台；分割

String zkPath="/soa/test/finagle";

try {

System.out.println("zkHosts:" + zkHosts + "\tzkPath:" + zkPath+"\tport:"+port);

Hello.ServiceIface iface=new HelloImpl();

server = Thrift.serveIface(new InetSocketAddress(port), iface);

String zkFullPath = String.format("zk!%s!%s!0", zkHosts, zkPath);

server.announce(zkFullPath);

System.out.println("finagle server start");

Runtime.getRuntime().addShutdownHook(new Thread() {

@Override

public void run() {

App.close();

}

});

Await.ready(server);

} catch (Exception e) {

e.printStackTrace();

System.exit(-1);

}

}

public static void close() {

System.out.println("finagle server shutdown");

server.close();

}

}

下面上 client 端代码：(注：客户端是不用关心服务端真正的ip只需要确保zk能用就行  有个概念叫服务发现)

String zkHosts="127.0.0.1:9000";

String zkPath="/soa/test/finagle";

String zkFullPath = String.format("zk!%s!%s", zkHosts, zkPath);

ServiceFactory factory = Thrift.newClient(zkFullPath);

Hello.ServiceIface helloClient = new Hello.ServiceToClient(factory.toService(), new TBinaryProtocol.Factory());

String ret = helloClient.helloString("test").get();

Assert.assertEquals("test", ret);

最后附上 demo下载地址 http://pan.baidu.com/s/1kTKsYDT

ps: 最后 记得修改 maven的setting文件 的镜像

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/SETTINGS/1.0.0 http://maven.apache.org/xsd/settings-1.0.0.xsd">

ss

false

socks5

127.0.0.1

1080

nexus

nexus

http://maven.oschina.net/content/groups/public

*

java搭建finagle(1)

1.新建maven项目 2.pom文件添加依赖 添加3个主要依赖com.twitter

Java搭建WebSocket的两种方式

下面分别介绍搭建方法:一.直接使用Java EE的api进行搭建.一共3个步骤:1.添加依赖    javax

Java——搭建自己的RESTful API服务器(SpringBoot、Groovy)

这又是一篇JavaWeb相关的博客,内容涉及: SpringBoot:微框架,提供快速构建服务的功能 SpringMVC:Struts的替代者 MyBatis:数据库操作库 Groovy:能与Java ...

从零开始学 Java - 搭建 Spring MVC 框架

没有什么比一个时代的没落更令人伤感的了 整个社会和人都在追求创新.进步.成长,没有人愿意停步不前,一个个老事物慢慢从我们生活中消失掉真的令人那么伤感么?或者说被取代?我想有些是的,但有些东西其实并不是 ...

手把手教你用新浪云容器 Java 搭建自己的网站

经过一段时间的开发,更新,迭代,新浪云容器 Java 环境逐渐成熟起来,相比过去的 Java 运行环境,可用性和易用性都得到了大量的提升.同时也收到了不少用户反馈的使用问题,特此在这篇文章里综合介绍一 ...

056 Java搭建kafka环境

1.使用Java项目搭建 2.新目录 3.添加项目支持 4.添加mavem与scala 5.修改pom <?xml version="1.0" encoding=" ...

java搭建 SpringMVC&plus;Mybatis&lpar;SMM&rpar;&plus;mybatis-generate

搭建SSM系统,首先要了解整个过程: 1.创建spring-mvc项目 2.在maven中添加要引用的jar包(使用框架都是较新的版本:) 3. jdbc.xml +spring-mybatis.xm ...

这一次，我连 web&period;xml 都不要了，纯 Java 搭建 SSM 环境&excl;

在 Spring Boot 项目中,正常来说是不存在 XML 配置,这是因为 Spring Boot 不推荐使用 XML ,注意,并非不支持,Spring Boot 推荐开发者使用 Java 配置来搭 ...

随机推荐

解决GitLab提交MergeRequest时，提示502 GitLab is not responding&period;的问题

最近使用GitLab提交MergeRequest时,提示502 GitLab is not responding. 使用gitlab-ctl tail查看错误信息如下: 2014/10/28 11:5 ...

&lbrack;轉&rsqb;redis&semi;mongodb&semi;memcache三者的性能比較

先说我自己用的情况: 最先用的memcache ,用于键值对关系的服务器端缓存,用于存储一些常用的不是很大,但需要快速反应的数据 然后,在另一个地方,要用到redis,然后就去研究了下redis. 一 ...

Gradle系列教程之依赖管理&lpar;转&rpar;

转自Lippi-浮生志 :http://ezlippi.com/blog/2015/05/gradle-dependency-management.html 这一章我将介绍Gradle对依赖管理的强大 ...

常用的rpm和yum的一些命令

常用的rpm命令  rpm -qa | grep coreutils

用Dalvik指令集写个java类

Dalvik指令集 .class public LCalculate;#定义类名 .super Ljava/lang/Object;#定义父类 .method public static main([ ...

Ext&period;Array 方法

1. Ext.Array.clean(arr); 过滤数组中的空元素 var arr = [1,"",2,"",3]; Ext.clean(arr); // [ ...

FindLetter 类——查找文件中特定的字符，每一行开头为某一个字符，则跳过

/*统计除了>之外的行里面CHED四个字母总数*/ #include #include #include

JavaScript 高级

在线JS编辑 JS 编写规范 阮一峰 ES 6 阮一峰 廖雪峰 操作文件