- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
RMI:远程方法调用(Remote Method Invocation),只适用于 Java 语言。也就是说,各台计算上使用的语言都必须是 Java。
实现机制:在本地(客户端),直接操作的是服务端接口在本地的副本(称为stub),通过stub来充当服务端的接口。例如,如果客户端 L 对象药调用服务端接口 R 中 method() 方法,那么是无法在客户端直接写成L.method()。因此,就必须先将服务端的 method() 的接口 R 在本地复制一份( 即stub),然后才能写成L.method()。可以发现,在 RMI 通信时,客户端接口借助的是 stub,而服务端为了便于组织管理服务端商的各个接口,以及为了便于和客户端通信,服务端也设置了一个辅助对象 skeleton。即 RMI 通信过程,实际是客户端 stub 和 服务端的 skeleton 在直接交互,如下图所示。
1 客户端与服务端之间通过 Socket 交互信息。
a 客户端先以字符串的形式定义好需要请求的接口名("remote.procedure.call.server.RMIService",)然后再将此字符串通过反射,解析出请求的接口名、方法名、方法参数等信息,并将这些信息通过对象流 ObjectOutputStream 发送给服务端。
b 服务端逐个解析这些信息,并通过反射中 invoke() 方法调用服务端上被请求的方法。
2 因为服务端可能存在多个提供方法的接口,因此服务端需要一个“服务注册中心”来统一管理这些接口;当客户端请求某一个接口时,“服务注册中心”就可以立刻获取并提供那个接口。其中,“服务注册中心”可以是一个 Map,其中 Key 存放着接口的名字,value 就是响应方法的接口对象。
3 “服务注册中心”根据客户端请求,找到相应接口后(通过map.get(接口名)),通过该接口的实现类提供方法(即执行实现类中的方法)。
4 服务完毕,服务端再将返回值通过对象流传给客户端。
5 因为不同的服务会返回不同的数据类型给客户端,因此客户端需要通过动态代理来接收服务端的返回值。
package rmi.server;
// 服务端上,提供服务的接口
public interface RMIService {
String sayHi(String name);
}
package rmi.server;
// 服务端上,提供服务接口的实现类
public class RMIServiceImpl implements RMIService {
@Override
public String sayHi(String name) {
return "hi," + name;
}
}
package rmi.server;
/**
* @className: ServerCenter
* @description: 服务注册中心接口
* @date: 2022/5/14
* @author: cakin
*/
public interface ServerCenter {
// 启动服务
void start();
// 关闭服务
void stop();
// 注册服务
void register(Class service, Class serviceImpl);
}
package rmi.server;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.reflect.Method;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.HashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
// 服务注册中心实现类
public class ServerCenterImpl implements ServerCenter {
// map:服务端的所有可供客户端访问的接口,都注册到该 map 中
// key: 接口的名字(如"RMIService"),value:真正的提供服务的类(如RMIServiceImpl类)
private static HashMap<String, Class> serviceRegiser = new HashMap<>();
// 服务端的端口号
private static int port;
// 线程池:线程池中存在多个线程对象,每个线程对象都可以处理一个客户请求
private static ExecutorService executor
= Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
// 是否开启服务
private static volatile boolean isRunning = false;
public ServerCenterImpl(int port) {
this.port = port;
}
// 开启服务端服务
@Override
public void start() {
ServerSocket server = null;
try {
server = new ServerSocket();
server.bind(new InetSocketAddress(port));
} catch (IOException e1) {
e1.printStackTrace();
}
isRunning = true;
// 客户端每次请求一次请求,服务端从线程池中启动一个线程对象去处理
while (true) {
// 具体的服务内容:接收客户端请求,处理请求,并返回结果
System.out.println("服务已启动...");
Socket socket = null;
try {
socket = server.accept(); // 等待客户端连接
} catch (IOException e) {
e.printStackTrace();
}
// 启动一个线程 去处理客户请求
executor.execute(new ServiceTask(socket));
}
}
// 关闭服务
@Override
public void stop() {
isRunning = false;
executor.shutdown();
}
// 将接口名和接口实现类一一对应,以便于接收到请求时,能及时获取到对应的服务实现类
@Override
public void register(Class service, Class serviceImpl) {
serviceRegiser.put(service.getName(), serviceImpl);
}
// 处理请求的线程
private static class ServiceTask implements Runnable {
private Socket socket;
public ServiceTask() {
}
public ServiceTask(Socket socket) {
this.socket = socket;
}
// 具体的处理逻辑
@Override
public void run() {
ObjectOutputStream output = null;
ObjectInputStream input = null;
try {
// 接收到客户端的各个请求参数(接口名、方法名、参数类型、参数值)
input = new ObjectInputStream(socket.getInputStream());
// 因为 ObjectInputStream 对发送数据的顺序有严格要求,因此必须按照发送的顺序逐个接收
// 请求的接口名
String serviceName = input.readUTF();
// 请求的方法名
String methodName = input.readUTF();
// 请求方法的参数类型
Class[] parameterTypes = (Class[]) input.readObject();
// 请求方法的参数名
Object[] arguments = (Object[]) input.readObject();
// 根据客户请求,到服务注册中心 map 中找到与之对应的具体接口(即RMIService)
Class ServiceClass = serviceRegiser.get(serviceName);
// 构建请求的方法
Method method = ServiceClass.getMethod(methodName, parameterTypes);
// 执行该方法
Object result = method.invoke(ServiceClass.newInstance(), arguments);
// 将执行完毕的返回值,返回给客户端
output = new ObjectOutputStream(socket.getOutputStream());
output.writeObject(result);
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
if (output != null)
output.close();
if (input != null)
input.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
}
}
package rmi.client;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;
import java.net.InetSocketAddress;
import java.net.Socket;
public class RMIClient {
/**
* 功能描述:获取代表服务端接口的动态代理对象(RMIService)
*
* @param serviceInterface:请求的接口名
* @param addr:待请求服务端的ip:端口
* @author cakin
* @date 2022/5/14
*/
@SuppressWarnings("unchecked")
public static <T> T getRemoteProxyObj(Class serviceInterface,
InetSocketAddress addr) {
/*
newProxyInstance(a,b,c)中,前两个参数的含义如下:
a:类加载器 :需要代理那个对象的类加载器
b:用于表示需要代理的对象提供了哪些方法。Java是单继承、多实现,
因此,如果某一个对象实现了多个接口,那么该对象就拥有其全部接口的所有方法,因此是一个接口数组。
例如,如果有A implements B接口,c接口,并且B接口中有3个方法,C接口中有2个方法,那么A的对象就拥有5个方法(暂不考虑A自身提供的方法)
*/
return (T) Proxy.newProxyInstance(serviceInterface.getClassLoader(),
new Class<?>[]{serviceInterface}, new InvocationHandler() {
/**
* 功能描述:
*
* @author cakin
* @date 2022/5/14
* @param proxy:代理的对象
* @param method:哪个方法(sayHi(参数列表))
* @param args:参数列表
* @return T
*/
@Override
public Object invoke(Object proxy, Method method, Object[] args) {
// 客户端向服务端发送请求:请求某一个具体的接口
Socket socket = new Socket();
ObjectOutputStream output = null;
ObjectInputStream input = null;
try {
// addr包含了要访问的服务端的Ip和端口
socket.connect(addr);
// 通过序列化流(对象流)向服务端发送请求
output = new ObjectOutputStream(socket.getOutputStream());
// 发送请求的接口名
output.writeUTF(serviceInterface.getName());
// 发送请求的方法名
output.writeUTF(method.getName());
// 发送请求的方法的参数的类型
output.writeObject(method.getParameterTypes());
// 发送请求的方法的参数值
output.writeObject(args);
// 等待服务端处理...
// 接收服务端处理后的返回值
input = new ObjectInputStream(socket.getInputStream());
return input.readObject();
} catch (Exception e) {
e.printStackTrace();
return null;
} finally {
try {
if (output != null) output.close();
if (input != null) input.close();
} catch (Exception e) {
e.printStackTrace();
}
}
}
});
}
}
package rmi.test;
import rmi.server.RMIService;
import rmi.server.RMIServiceImpl;
import rmi.server.ServerCenter;
import rmi.server.ServerCenterImpl;
public class TestRMIServer {
public static void main(String[] args) {
// 用线程的形式启动服务
new Thread(() -> {
// 服务中心
ServerCenter server = new ServerCenterImpl(9999);
// 将 RMIService 接口及实现类,注册到服务中心
server.register(RMIService.class, RMIServiceImpl.class);
server.start();
}).start();
}
}
package rmi.test;
import rmi.client.RMIClient;
import rmi.server.RMIService;
import java.net.InetSocketAddress;
// 先启动服务端,再启动客户端,就能看到客户端成功的调用了服务端上的 sayHi() 方法。
public class TestRMIClient {
public static void main(String[] args) throws ClassNotFoundException {
// 调用远程的 rmi.server.RMIService 接口,并执行接口中的 sayHi() 方法
RMIService service = RMIClient.getRemoteProxyObj(
Class.forName("rmi.server.RMIService" ) ,
new InetSocketAddress("127.0.0.1", 9999)) ;
System.out.println( service.sayHi("zs") ) ;
}
}
hi,zs
我有以下功能: function addChange(result, bill) { for (var i=0;i
这是网站: www.wearethefirehouse.com/phasetest 如果您慢慢滚动,您会注意到一旦菜单栏完全不透明,nav li 元素就会全部从 Enzo 300 跳起来(如在没有导航
美好的一天。对于当前的项目,我需要知道数据类型如何表示为字节。例如,如果我使用: long three = 500;var bytes = BitConverter.GetBytes(three);
请解释 JVM 是如何在底层收集 ThreadDump 的。 我不明白它如何收集脱离 CPU 的线程的堆栈跟踪(等待磁盘 IO、网络、非自愿上下文切换)。 例如,linux perf 仅收集有关 on
开始学习 R,如果能帮助我理解 R 如何决定不同向量的类别,我将不胜感激。我初始化 vec <- c(1:6)当我执行 class(vec)我得到“整数”。为什么它不是“数字”,因为我认为 R 中的整
我有一个透明的 UIView,几乎覆盖了整个屏幕。我在顶部留下了 50 像素。它是 View Controller View 的 subview 。 在UIView下面有一个继承自UIView的MyV
我很好奇对象是如何在 Nodejs 中显示的,在本例中是 Promise。使用 console.log(promiseObject) 时,输出的类型为 {状态:待处理} 这对我来说似乎很奇怪,因为在该
当您在 Windows Azure 中使用表服务 API 时,幕后到底在做什么?我想我在某处读到这没有使用 SQL Server。它是否执行哈希表,然后过滤器真的像映射/减少操作一样运行?我对这些东西
如何查看函数 concat 中的代码?它是如何做的?有没有人有代码的副本或在浏览器控制台中查看它的方法? console.dir 不给我访问权限 console.dir(Array.prototype
我是 C++ 的新手,所以如果这个问题的答案显而易见,我深表歉意。 我一直在编写 STL 样式的自定义数据结构,以此来提高我的技能。 (我实际上也确实需要这种结构,但出于学习目的,我有点过分了。) 此
我正在尝试使用 log4j appender 将日志发送到 GrayLog2 (log4j2-gelf)。所以我将我的依赖项添加到我的 pom.xml 配置 log4j2.xml 来配置我的 appe
我正在使用带有 vector 的 priority_queue 作为底层容器。但是我希望堆的大小非常大。我知道动态 vector 容量调整大小的问题。所以我正在寻找方法来为我的priority_que
我有一个 SqlDataAdapter,它填充了 21 行数据(4 列)。驱动它的 sproc 在几秒钟内在 SQL Mgmt Studio 中返回,但 .Fill() 需要 5 分钟。 Ar
我想实现一个屏幕控制按钮,按下它可以作为 GUI 交互的修饰符。 这对于 MouseArea 是不可能的,因为该 API 只能处理一个鼠标区域中的一个触摸点。 该限制不适用于 MultiPointTo
我试图将图像和 div 层置于包含 div 的中心,但到目前为止我无法让它从列的左侧移动。我尝试了几种不同的方法,但就是无法让它移动。即使 margin auto 技巧也不起作用,我怀疑这是因为 bo
需要明确的是,我不是在询问 HDFS 中的权限设置,而是在 ext3 中或在 HDFS 运行于其上的各个数据节点机器上使用的任何文件系统中。 p> 我知道我们设置了 sudo chown hduser
我在服务器上创建了一个枚举,其中手动设置了整数值,而不是默认从 0 开始递增 public enum UserType { Anonymous = 0, Customer = 10,
如果显示框架图像,我们能否使以下 Google map 具有交互性。 Vie
我有一个顶部有自定义状态栏的布局 [在 Apple 的状态栏下方],然后是 UIScrollview 在中间部分从左到右分页,然后我有一个 UIView 底部有一些自定义按钮。一个简单的三 Pane
事情是这样的。我有一个 MVC 操作,在该操作上,我应用了自定义 ActionFilterAttribute 来使反序列化工作。现在,我想要做的是根据在此 View 中设置的 ViewBag.Titl
我是一名优秀的程序员,十分优秀!