java搭建finagle(2)

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

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

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

如下面代码：

namespace java com.test.finagle.demo
service Hello{

string helloString(1:string para)
i32 helloInt(1:i32 para)
bool helloBoolean(1: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<String> helloString(String para) {
return Future.value(para);
}

public Future<Integer> helloInt(int para) {
return Future.value(para);
}

public Future<Boolean> helloBoolean(boolean para) {
return Future.value(para);
}

public Future<Void> helloVoid() {
return Future.value(null);
}

public Future<String> 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<ThriftClientRequest, byte[]> 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文件 的镜像

<?xml version="1.0" encoding="UTF-8"?>
<settings xmlns="http://maven.apache.org/SETTINGS/1.0.0"
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"> <pluginGroups>
</pluginGroups>
<proxies>

<proxy>
<id>ss</id>
<active>false</active>
<protocol>socks5</protocol>
<host>127.0.0.1</host>
<port>1080</port>
</proxy>
</proxies>
<servers>
</servers>
<mirrors>
<mirror>
<id>nexus</id>
<name>nexus</name>
<url>http://maven.oschina.net/content/groups/public</url>
<mirrorOf>*</mirrorOf>
</mirror>
</mirrors></settings>