package apriori;
option java_package = "dave.apriori.protos";
option java_outer_classname = "AprioriProtos";
option java_generic_services = true;
option java_generate_equals_and_hash = true;
option optimize_for = SPEED;
message AprioriRequest {
required int32 length = 1;
required float support = 2;
}
message AprioriResponse {
message FrequentSet {
required bytes fset = 3;
required int32 support = 4;
}
required int32 count = 5;
repeated FrequentSet fsets = 6;
}
message SpecialRequest {
repeated bytes fsets = 7;
}
message SpecialResponse {
repeated int32 supportCount = 8;
}
message HelloRequest{
required bytes hellostr = 9;
}
message HelloResponse{
required bytes helloresp = 10;
}
service Apriori {
rpc getFrequentSet(AprioriRequest)
returns (AprioriResponse);
rpc getSepecialSupport(SpecialRequest)
returns (SpecialResponse);
rpc sayHello(HelloRequest)
returns (HelloResponse);
}
定义了三个service,一个是获得该region所有的频繁项集,另一个是获取某个项集在该region的计数,最后是测试用的sayHello。 定义好了之后,用protoc –java_out=. Apriori.proto命令就可以在当前目录下生成相应的java文件,再导入到项目中就可以编写服务器和客户端了。 部署过程和源代码已上传,有需要的朋友可在http://download.csdn.net/detail/xanxus46/8801857下载