Azureus源码剖析(一)

简介:
整个项目运行的起点在com.aelitis.azureus.ui.Main这个类中,它只有一个main主方法,运用Java的反射机制来调用真正的起始点类org.gudy.azureus2.ui.swt.Main的实例对象。

代码如下:

复制代码
            final Class startupClass = Class.forName("org.gudy.azureus2.ui.swt.Main");

            final Constructor constructor = startupClass.getConstructor(new Class[] {
                String[].class
            });
            
            constructor.newInstance(new Object[] {
                args
            });
复制代码
而在org.gudy.azureus2.ui.swt.Main这个类中有一个成员变量
StartServer startServer
它是一个监听服务器,对本地的6880端口进行监听,监听的对象是torrent种子文件的URL地址,在它的构造函数中有如下语句:

    socket = new ServerSocket(6880, 50, InetAddress.getByName("127.0.0.1")); //种子文件监听服务器
        
        state = STATE_LISTENING; //服务器状态设置为“监听中”  
对此我们来做个小实验,通过tcp连接到Azureus的种子文件监听服务器上,向它传递待下载的种子文件列表,从而让Azureus去下载。

复制代码
package com.vista.test;

import java.io.IOException;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

/**
 * 
 * @author phinecos
 * @since 2009-5-6
 *
 */
public class MyClass
{
    private String[] files = null;
    public MyClass(String[] files)
    {
        this.files = files;
    }
    @Override
    public String toString() 
    {
        StringBuilder sb = new StringBuilder();
        for (String file: files)
        {
            sb.append(file);
        }
        return sb.toString();
    }
    public void sendMessage()
    {
        Socket socket = null;
        PrintWriter pw = null;
        String msg = "StartSocket: passing startup args to already-running Azureus java process listening on [127.0.0.1: 6880]";
        String IpAddr = "127.0.0.1";
        int port = 6880;
        final String ACCESS_STRING = "Azureus Start Server Access";
        
        try 
        {
            socket = new Socket(IpAddr,port);
            pw = new PrintWriter(new OutputStreamWriter(socket.getOutputStream(),"UTF8"));
            StringBuffer buffer = new StringBuffer(ACCESS_STRING + ";args;");
            
            for (int i = 0; i < files.length; ++i)
            {
                String file = files[i].replaceAll("&","&&").replaceAll(";","&;");//字符转义
                buffer.append(file);
                buffer.append(';');
            }
            pw.println(buffer.toString());
            pw.flush();

        } 
        catch (UnknownHostException e)
        {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } 
        catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        finally
        {
            try
            {
                if (pw != null)
                    pw.close();
            }
            catch(Exception e){}
            
            try 
            {
                if (socket != null)
                    socket.close();
            } 
            catch (IOException e) {}
        }
        
    }
}
复制代码
 

复制代码

package com.vista.test;

import java.lang.reflect.Constructor;

/**
 * 
 * @author phinecos
 * @since 2009-5-6
 *
 */
public class Main 
{

    /**
     * @param args
     * @throws ClassNotFoundException 
     */
    public static void main(String[] args)
    {
        try 
        {
            final Class myClass = Class.forName("com.vista.test.MyClass");
            final Constructor myConstructor = myClass.getConstructor(new Class[]{String[].class});
            String[] torrents = {"c:\\1001.torrent", "c:\\1002.torrent"};//种子文件列表
            MyClass c1 = (MyClass)myConstructor.newInstance(new Object[]{torrents});
            System.out.println(c1.toString());
            c1.sendMessage();
        } 
        catch (Exception e) 
        {
            e.printStackTrace();
        }

    }

}
复制代码


本文转自Phinecos(洞庭散人)博客园博客,原文链接:http://www.cnblogs.com/phinecos/archive/2009/05/06/1450909.html,如需转载请自行联系原作者

目录
相关文章
|
10月前
|
存储 机器学习/深度学习 算法
源码剖析之ConcurrentHashMap
​ JDK8中ConcurrentHashMap的结构是:数组+链表+红黑树。 ​ 因为在hash冲突严重的情况下,链表的查询效率是O(n),所以jdk8中改成了单个链表的个数大于8时,数组长度小于64就扩容,数组长度大于等于64,则链表会转换为红黑树,这样以空间换时间,查询效率会变O(nlogn)。 ​ 红黑树在Node数组内部存储的不是一个TreeNode对象,而是一个TreeBin对象,TreeBin内部维持着一个红黑树。 ​ 在JDK8中ConcurrentHashMap最经点的实现是使用CAS+synchronized+volatile 来保证并发安全
83 0
源码剖析之ConcurrentHashMap
|
存储 SQL 算法
Sentinel源码剖析之执行流程
Sentinel主要用来流控,熔断降级保护目标资源用的,常用集成SCG,SpringBoot,SprinMVC这些,但底层本质没变,但是体现形式上会有差别。例如SCG底层是Netty 和 SpringWebFlux 采用Reactor Stream处理,SpringBoot内部通过AOP处理流控这些。
357 0
|
存储 SQL 分布式计算
【源码解读】| LiveListenerBus源码解读(下)
【源码解读】| LiveListenerBus源码解读
136 0
【源码解读】| LiveListenerBus源码解读(下)
|
缓存 分布式计算 监控
【源码解读】| LiveListenerBus源码解读(上)
【源码解读】| LiveListenerBus源码解读
140 0
【源码解读】| LiveListenerBus源码解读(上)
|
存储 分布式计算 监控
【源码解读】|SparkEnv源码解读
【源码解读】|SparkEnv源码解读
108 0

热门文章

最新文章