多文件并发传输-------资源中心

mfct 资源中心

我们这个系统由三大部分组成： 资源中心发送方节点接收方节点
资源中心与发送方、接收方采用的都是短链接
短链接的实现
因为他们需要注册资源注销节点获取节点列表等在接收到对方传来的信息之后，我们便可以将双方的连接断开

资源的接收方、发送方之间要不停的发送当一个发送端我完成了他的发送之后，我们才可以关掉他们之间的通信信道但是当整个的发送工作结束之后就可以关闭接受端
他们之间采用的是长连接

在资源中心我们可以读取配置文件：如文件分割的最大长度、参与发送端的最大个数等进行配置

private void loadResourceAllocationStrategy() {
          String rasString =  PropertiesParser.value("ResourceAllocationStrategy");
          if (rasString != null) {
               try {
//                  利用配置 来进行设置
                    Class<?> klass =  Class.forName(rasString);
                    resourceAllocationStrategy =  (IResourceAllocationStrategy) klass.newInstance();
               } catch (Exception e) {
               }
          }
          String strMaxSectionLength =  PropertiesParser.value("maxSectionLength");
          if (strMaxSectionLength != null) {
               try {
                    int maxSectionLength = 0;
                    maxSectionLength =  Integer.valueOf(strMaxSectionLength);
                    resourceAllocationStrategy.setMaxSectionLength(maxSectionLength);
               } catch (Exception e) {
               }
          }
     }

资源中心我们提供的最重要的功能就是

进行资源的请求与发送
接收端对资源进行请求
我们可以先获取拥有资源的列表
然后进行资源分配策略的落实最后进行发送

public int requestResource(ResourceBaseInfo1 rbi, INetNode1  receiveNode) {
          List<INetNode1>   senderList=nodeSelectStrategy.selectNodeList(rbi);
          int sendCount=senderList.size();
          ResourceAllocation resourceAllocation =
                    new ResourceAllocation(rbi, receiveNode,  senderList);
          resourceAllocationStrategy.
                    allocationResource(rbi, receiveNode,  senderList);
          waitting = true;
          rmiServer.getThreadPool().execute((Runnable)  resourceAllocation);
          
          return sendCount;
     }

resourceAllocation 类里面的方法：
// 使用了短连接的远程方法调用并且启动了发送端

public void run() {
               
               /*
               // 为避免接收端异常掉线而造成while (waitting)的无限等待，
               // 有必要设置一个监视时钟，当超过最大等待时间后，放弃后续所有操作，
               // 并结束本线程。
               DidaDida dida = new DidaDida(20000);
               IDidaDidaAction didaAction = new  IDidaDidaAction() {
                    @Override
                    public void doSomething() {
                         dida.stop();
                         ok = false;
                         return;
                    }
               };
               dida.setAction(didaAction);
               dida.start();
               */
               List<SendSectionInfo1>   sendList=resourceAllocationStrategy.
                         allocationResource(rbi, receiver,  senderList);
//             得到了 发送的片段 发送节点、接收节点
               RMIClient client=new RMIClient();
               RMIClientProxy proxy=new RMIClientProxy();
               proxy.setRmiClient(client);
               IResourceSender  resourceSender=proxy.getProxy(IResourceSender.class);
               for(SendSectionInfo1 sendSection:sendList) {
                    INetNode1 sender =  sendSection.getSendNode();
                    client.setIp(sender.getIp());
                    client.setPort(sender.getPort());
                    resourceSender.sendSection(receiver,  sendSection.getRbi());
               }
          }
     }