文档章节

RPC实验

Zero零_度
 Zero零_度
发布于 2014/12/21 20:16
字数 140
阅读 339
收藏 3
rpc
package com.rpc;
import java.io.IOException;
import org.apache.hadoop.ipc.VersionedProtocol;
public interface MyRPCProtocol extends VersionedProtocol {
 public static final long versionID = 4L;
 
 String hello(String name);
}
class MyRPCProtocolImpl implements MyRPCProtocol {
 
 @Override
 public long getProtocolVersion(String arg0, long arg1) throws IOException {
  return MyRPCProtocol.versionID;
 }
 @Override
 public String hello(String name) {
  return "hello " + name;
 }
 
}
package com.rpc;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
import org.apache.hadoop.ipc.RPC.Server;
public class MyServer {
 
 public static int PORT = 3333;
 
 public static void main(String[] args) throws Exception {
  final Server server = RPC.getServer(new MyRPCProtocolImpl(), "localhost", MyServer.PORT, new Configuration());
  server.start();
 }
 
}
package com.rpc;
import java.net.InetSocketAddress;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
public class MyClient {
 
 public static void main(String[] args) throws Exception {
  final InetSocketAddress inetSocketAddress = new InetSocketAddress("localhost", MyServer.PORT);
  MyRPCProtocol rpc = (MyRPCProtocol)RPC.getProxy(MyRPCProtocol.class, MyRPCProtocol.versionID, inetSocketAddress, new Configuration());
  String str = rpc.hello("习大大");
  System.out.println(str);
  RPC.stopProxy(rpc);
 }
 
}

依赖包:hadoop-core-1.2.1、commons-configuration-1.6、commons-lang-2.4、commons-logging-1.1.1

© 著作权归作者所有

共有 人打赏支持
Zero零_度
粉丝 69
博文 1253
码字总数 256245
作品 0
程序员
私信 提问
RPC框架实践之:Apache Thrift

一、概述 RPC(Remote Procedure Call)即 远程过程调用,说的这么抽象,其实简化理解就是一个节点如何请求另一节点所提供的服务。在文章 微服务调用链追踪中心搭建 一文中模拟出来的调用链:...

CodeSheep
05/14
0
0
新课上线|Python实现图片拼接与混合、XML-RPC文件共享程序等

关注「实验楼」,每天分享一个项目教程 最近又上线了哪些新课程?快来看看吧~ 会 员 课 一、《Python3 实现图片拼接与混合》 课程来源:selfim 课程简介:本课程主要是利用 Python 的第三方...

moy37rqw1jarn33bgzk
05/12
0
0
以太坊—JSON RPC API

Geth 使用JSON数据格式, JSON-RPC协议作为客户端和网络进行交互的方法。 Geth 1.4 的 pub/sub 是实验性质的, 同样, Partity 1.6 也是。 JavaScript API 使用web3.js和etherenum节点交互时...

十一月不远
07/23
0
0
ISA2006发布Exchange服务器 RPC OVER HTTPS

ISA2006发布Exchange服务器 RPC OVER HTTPS 实验拓扑图 计算机都是windows sp1 计算机都信任Denver颁发的证书 1 在Denver上 安装http代理rpc,让Exchange有解封装能力 在Denver上开始——程序...

余二五
2017/11/22
0
0
mysql分批次插入VS一次性插入

由于临近考试,需要从前端页面将整个学校的学生信息通过Excel导入到数据库中。导入3万数据,先是进行各种数据校验,然后才进行入库操作。ito401三张表,云平台一张表。结果运行不到一半页面就...

qq_26545305
2017/12/14
0
0

没有更多内容

加载失败,请刷新页面

加载更多

java框架学习日志-7(静态代理和JDK代理)

静态代理 我们平时去餐厅吃饭,不是直接告诉厨师做什么菜的,而是先告诉服务员点什么菜,然后由服务员传到给厨师,相当于服务员是厨师的代理,我们通过代理让厨师炒菜,这就是代理模式。代理...

白话
今天
14
0
Flink Window

1.Flink窗口 Window Assigner分配器。 窗口可以是时间驱动的(Time Window,例如:每30秒钟),也可以是数据驱动的(Count Window,例如:每一百个元素)。 一种经典的窗口分类可以分成: 翻...

满小茂
今天
9
0
my.ini

1

architect刘源源
今天
10
0
docker dns

There is a opensource application that solves this issue, it's called DNS Proxy Server It's a DNS server that solves containers hostnames, if could not found a hostname that mat......

kut
今天
10
0
寻找数学的广度——《这才是数学》读书笔记2700字

寻找数学的广度——《这才是数学》读书笔记2700字: 文|程哲。数学学习方式之广:国内外数学教育方面的专家,进行了很多种不同的数学学习方式尝试,如数学绘本、数学游戏、数学实验、数学步道...

原创小博客
今天
21
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部