多文件自平衡云传输（五）资源管理中心篇 —————

资源管理中心

RegisterServer
IRegister
Register
CheckAlive

资源注册中心功能
1.接收注册任务
2.接收注销任务
3.提供给资源接收端合理的资源节点列表。

对于资源管理中心来说，同服务发现的资源注册中心，和资源注册的功能相同。

RegisterServer

资源管理中心的启动入口类

public class RegisterServer{private int rpcPort;private Register rt;private rmiServer rs;private Object lock;private rmiCilent rc;private CilentProxy cp;private volatile NetNode currentNode;public RegisterServer() {          rs = new rmiServer();  lock = new Object();rt = new Register();cp = new CilentProxy();rc = new rmiCilent();rc.setIce(new CheckProviderException());cp.setRmicilent(rc);}public void setRpcPort(int port) {this.rpcPort = port;rs.setPort(this.rpcPort);}public void shudown() {   rs.close();}    public void start() {rs.start();}public void checkRobustness() {Set<NetNode> nodeList = rt.getAllNode();Iterator<NetNode> list = nodeList.iterator();while(list.hasNext()) {currentNode = list.next();rc.setId(currentNode.getIp());rc.setPort(currentNode.getPort());Iserver server = cp.getProxy(Iserver.class);server.robustness();  }}  class CheckProviderException implements ICilentException{@Overridepublic void peerAbnormalDrop() {rt.logOutServer(currentNode);}       }}

IRegister

/*
*注册中心的功能接口
*1.注册资源
*2.注销资源
*3.提供节点列表
*/
public interface IRegister {List<NetNode> getServerList(String serverDemand);void registServer(NetNode serverNode, List<String> ResourceName);void logOutServer(NetNode serverNode);}

Register

资源管理中心的功能实现类

@rmiInterface(rmiter= {IRegister.class})
public class Register implements IRegister{private static final Map<String, List<NetNode>> serverMap = new ConcurrentHashMap<String, List<NetNode>>();private static final Map<NetNode,Object> serverNodeMap = new ConcurrentHashMap<NetNode, Object>();private static final Object object= new Object();public Register() {}public Set<NetNode> getAllNode(){return serverNodeMap.keySet();}@Overridepublic List<NetNode> getServerList(String serverDemand) {return  serverMap.get(serverDemand); }public void Rew(INetNode node) {System.out.println(node);}@Overridepublic void registServer(NetNode serverNode, List<String> resourceName) {if(resourceName == null) {return;}    serverNodeMap.put(serverNode, object);for(String one : resourceName) {          if(!serverMap.containsKey(one)) {List<NetNode> nodeList = new ArrayList<NetNode>();nodeList.add(serverNode);serverMap.put(one, nodeList);}else {List<NetNode> nodeList = serverMap.get(one);nodeList.add(serverNode);}      }       }@Overridepublic void logOutServer(NetNode serverNode) {Set<String> keys = serverMap.keySet();Iterator<String> keyIter = keys.iterator();serverNodeMap.remove(serverNode);while(keyIter.hasNext()) {String key = keyIter.next();List<NetNode> nodeList =serverMap.get(key);Iterator<NetNode> values = nodeList.iterator();while(values.hasNext()) {NetNode one = values.next();values.remove();if(nodeList.isEmpty()) {keyIter.remove();}}}}
}

CheckAlive

/** 用于检测资源提供端的健壮性*/
public class CheckAlive {private RegisterServer rs;private Timer timer;public CheckAlive() {        timer = new Timer();timer.setIevent(new check());}public void setRegister(RegisterServer rs) {this.rs = rs;}public void startCheak() {    timer.start();  }public void stopCheak() {timer.stop();}class check implements IEvent{      @Overridepublic void dealEvent() { rs.checkRobustness();           }}}

多文件传输是基于服务发现框架的，多以对于资源管理中心的功能是相同的，区别在于在服务发现框架中，提供者和注册中心采用的是长连接的模式，在多文件传输中我们采用的是短连接的方式。
所有对于资源管理中心来讲，既是一个短连接的服务端，也是短连接的客户端，因为资源管理中心需要链接发送端（资源提供端）检测是否还能够给记性提供资源的服务。

多文件自平衡云传输（五）资源管理中心篇 —————— 开开开山怪相关推荐

在线web免登陆云传输工具推荐【青蛙快传】
一个比较好用的文件或者文本云传输工具,在线web版的,重要的是不需要登录,不需要登录,不需要登录! 优点1:无需登录,急速快传优点2:手机电脑互传文件优点3:不用安装软件,仅一个网址青蛙快传 h ...
[Java]分布式自平衡多文件云传输
[Java]分布式自平衡多文件云传输概述基本思想节点 Receiver接收方资源分配及节点选择策略类接收服务器端口池资源请求类短连接资源请求接口资源信息类资源节点关系表(资源管理中心 ...
电脑与云服务器传输文件,电脑与云服务器传输文件
电脑与云服务器传输文件内容精选换一换当创建文件系统后,您需要使用云服务器来挂载该文件系统,以实现多个云服务器共享使用文件系统的目的.本章节以Windows 2012版本操作系统为例进行CIFS类 ...
手机服务器文件,手机查看云服务器文件
手机查看云服务器文件内容精选换一换华为云帮助中心,为用户提供产品简介.价格说明.购买指南.用户指南.API参考.最佳实践.常见问题.视频帮助等技术文档,帮助您快速上手使用华为云服务. 密钥对鉴权 ...
云服务器怎么拷贝和删除文件,怎样给云服务器拷贝文件
怎样给云服务器拷贝文件内容精选换一换本章节主要介绍云硬盘.弹性文件服务.对象存储服务等存储服务,让您更好的了解这些存储服务. 云服务器备份:云服务器备份可以对普通服务器进行整机备份或部分磁盘备份 ...
http服务器如何传输文件,http服务器如何传输文件
http服务器如何传输文件内容精选换一换华为云主机迁移服务帮助中心,为用户提供产品简介.快速入门.用户指南.API参考.最佳实践.常见问题.视频帮助等技术文档,帮助您快速上手使用主机迁移服务. ...
ecs服务器网站文件放在哪里,云服务器ecs文件放哪里
云服务器ecs文件放哪里内容精选换一换要访问您的文件系统,如果是Linux云服务器,您需要在Linux云服务器上安装NFS客户端后使用挂载命令挂载文件系统:如果是Windows云服务器,您需要在 ...
弹性服务器怎么上传文件,上传哪个文件夹弹性云服务器
上传哪个文件夹弹性云服务器内容精选换一换华为云帮助中心,为用户提供产品简介.价格说明.购买指南.用户指南.API参考.最佳实践.常见问题.视频帮助等技术文档,帮助您快速上手使用华为云服务. 本节 ...
怎么把本地的文件传给服务器,怎么把本地文件传给云服务器
怎么把本地文件传给云服务器内容精选换一换本文介绍如何在 Linux 系统的本地机器上使用 FTP 服务,将文件从本地上传到云服务器中.已在待上传文件的云服务器中搭建 FTP 服务.如果您的云服务 ...
文件上传打满服务器带宽,文件上传云服务器带宽选择
文件上传云服务器带宽选择内容精选换一换弹性云服务器支持通过内网访问OBS,OBS可供用户存储任意类型的数据.将图片.视频等数据存储至OBS后,在ECS上可以访问OBS,下载桶中的图片或视频等数 ...

多文件自平衡云传输（五）资源管理中心篇 —————— 开开开山怪

资源管理中心

RegisterServer

IRegister

Register

CheckAlive

多文件自平衡云传输（五）资源管理中心篇 —————— 开开开山怪相关推荐

最新文章

热门文章

多文件自平衡云传输 （五）资源管理中心篇 —————— 开开开山怪

资源管理中心

RegisterServer

IRegister

Register

CheckAlive

多文件自平衡云传输 （五）资源管理中心篇 —————— 开开开山怪相关推荐

最新文章

热门文章

多文件自平衡云传输（五）资源管理中心篇 —————— 开开开山怪

多文件自平衡云传输（五）资源管理中心篇 —————— 开开开山怪相关推荐