在练习实现“hadooprpc”示例时,我经常遇到这个错误。根据前面类似的问题和答案,我检查了类路径中的jar文件,得到了hadoop common.jar,它显示类路径中的jar文件包含hadoop.conf.configuration.class。下面是构建rpcserver的代码:
* package rpc;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
import org.apache.hadoop.ipc.Server;
public class RPCServer implements MyBizable {
public String doSomething(String str) {
return str;
}
public static void main(String[] args) throws Exception {
Server server = new RPC.Builder(new Configuration())
.setProtocol(MyBizable.class)
.setInstance(new RPCServer())
.setBindAddress("***.***.***.***")
.setPort(****)
.build();
server.start();
}
}*
但这个错误还是出现了,有人知道怎么解决吗?任何帮助都将不胜感激!提前谢谢!
1条答案
按热度按时间ssm49v7z1#
你在用maven吗?如果是,则添加以下依赖项。