• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java ClientGlobal类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.csource.fastdfs.ClientGlobal的典型用法代码示例。如果您正苦于以下问题:Java ClientGlobal类的具体用法?Java ClientGlobal怎么用?Java ClientGlobal使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



ClientGlobal类属于org.csource.fastdfs包,在下文中一共展示了ClientGlobal类的9个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: afterPropertiesSet

import org.csource.fastdfs.ClientGlobal; //导入依赖的package包/类
@Override
public void afterPropertiesSet() throws Exception {
  log.debug("准备加载FastDFS配置文件:{}", localConfigurePath);
  if (localConfigurePath == null) {
    throw new Exception("本地FastDFS配置文件不能为空,需要指定为某个具体的文件资源");
  }
  if (localConfigurePath.getFile() == null) {
    throw new Exception("本地FastDFS配置文件不存在,需要指定为某个具体的文件资源");
  }
  ClientGlobal.init(localConfigurePath.getFile().getAbsolutePath());
  log.debug("已加载FastDFS配置文件");
  File localTempPath = new File(localTempFilePath);
  if (!localTempPath.exists()) {
    localTempPath.mkdirs();
  }
  poolConfig.setMaxTotal(1000);//
  poolConfig.setMaxIdle(100); // 最多多少个空闲的
  poolConfig.setMinIdle(100);
  poolConfig.setMaxWaitMillis(10000);
  poolConfig.setTestOnBorrow(true);
  poolConfig.setTestOnReturn(true);
  genericObjectPool.setConfig(poolConfig);
  AbstractFileProcessor.initFastDFSService(this);
}
 
开发者ID:devpage,项目名称:fastdfs-quickstart,代码行数:25,代码来源:FastDFSService.java


示例2: afterPropertiesSet

import org.csource.fastdfs.ClientGlobal; //导入依赖的package包/类
@Override
public void afterPropertiesSet() throws Exception {
	File confFile = File.createTempFile("fastdfs", ".conf");
	PrintWriter confWriter = new PrintWriter(new FileWriter(confFile));
	confWriter.println("tracker_server=" + trackerServer);
	confWriter.close();
	ClientGlobal.init(confFile.getAbsolutePath());
	confFile.delete();
	TrackerGroup trackerGroup = ClientGlobal.g_tracker_group;
	trackerClient = new TrackerClient(trackerGroup);

	logger.info("Init FastDFS with tracker_server : {}", trackerServer);

}
 
开发者ID:xubinux,项目名称:xbin-store,代码行数:15,代码来源:FastdfsStorageService.java


示例3: main

import org.csource.fastdfs.ClientGlobal; //导入依赖的package包/类
/**
* entry point
* @param args comand arguments
*     <ul><li>args[0]: config filename</li></ul>
*/
@SuppressWarnings("rawtypes")
public static void main(String args[]) {
    if (args.length < 1) {
        System.out.println("Error: Must have 1 parameter: config filename");
        return;
    }

    System.out.println("java.version=" + System.getProperty("java.version"));

    try {
        ClientGlobal.init(args[0]);
        System.out.println("network_timeout=" + ClientGlobal.g_network_timeout + "ms");
        System.out.println("charset=" + ClientGlobal.g_charset);

        file_ids = new java.util.concurrent.ConcurrentLinkedQueue();

        for (int i = 0; i < 10; i++) {
            (new UploadThread(i)).start();
        }

        for (int i = 0; i < 20; i++) {
            (new DownloadThread(i)).start();
        }
    } catch (Exception ex) {
        ex.printStackTrace();
    }
}
 
开发者ID:iBase4J,项目名称:iBase4J-Common,代码行数:33,代码来源:TestLoad.java


示例4: main

import org.csource.fastdfs.ClientGlobal; //导入依赖的package包/类
/**
* entry point
* @param args comand arguments
*     <ul><li>args[0]: config filename</li></ul>
*     <ul><li>args[1]: local filename to upload</li></ul>
*/
public static void main(String args[]) {
    if (args.length < 2) {
        System.out.println("Error: Must have 2 parameters, one is config filename, "
            + "the other is the local filename to upload");
        return;
    }

    System.out.println("java.version=" + System.getProperty("java.version"));

    String conf_filename = args[0];
    String local_filename = args[1];

    try {
        ClientGlobal.init(conf_filename);
        System.out.println("network_timeout=" + ClientGlobal.g_network_timeout + "ms");
        System.out.println("charset=" + ClientGlobal.g_charset);

        TrackerClient tracker = new TrackerClient();
        TrackerServer trackerServer = tracker.getConnection();
        StorageServer storageServer = null;
        StorageClient1 client = new StorageClient1(trackerServer, storageServer);

        NameValuePair[] metaList = new NameValuePair[1];
        metaList[0] = new NameValuePair("fileName", local_filename);
        String fileId = client.upload_file1(local_filename, null, metaList);
        System.out.println("upload success. file id is: " + fileId);

        int i = 0;
        while (i++ < 10) {
            byte[] result = client.download_file1(fileId);
            System.out.println(i + ", download result is: " + result.length);
        }

        trackerServer.close();
    } catch (Exception ex) {
        ex.printStackTrace();
    }
}
 
开发者ID:iBase4J,项目名称:iBase4J-Common,代码行数:45,代码来源:Test.java


示例5: main

import org.csource.fastdfs.ClientGlobal; //导入依赖的package包/类
/**
	* entry point
	* @param args comand arguments
	*     <ul><li>args[0]: config filename</li></ul>
	*/
  @SuppressWarnings("rawtypes")
public static void main(String args[])
  {
  	if (args.length < 1)
  	{
  		System.out.println("Error: Must have 1 parameter: config filename");
  		return;
  	}
  	
  	System.out.println("java.version=" + System.getProperty("java.version"));
  	  
  	try
  	{
  		ClientGlobal.init(args[0]);
  		System.out.println("network_timeout=" + ClientGlobal.g_network_timeout + "ms");
  		System.out.println("charset=" + ClientGlobal.g_charset);
  		  		
  		file_ids = new java.util.concurrent.ConcurrentLinkedQueue();
  		
  		for (int i=0; i<10; i++)
  		{
  			(new UploadThread(i)).start();
  		}
  		
  		for (int i=0; i<20; i++)
  		{
  			(new DownloadThread(i)).start();
  		}
		}
  	catch(Exception ex)
  	{
  		ex.printStackTrace();
  	}
  }
 
开发者ID:guokezheng,项目名称:automat,代码行数:40,代码来源:TestLoad.java


示例6: setConfigFile

import org.csource.fastdfs.ClientGlobal; //导入依赖的package包/类
public void setConfigFile(String configFile) throws FileNotFoundException, IOException, MyException {
	this.configFile = configFile;
	ClientGlobal.init(this.configFile);
}
 
开发者ID:yinwq0558,项目名称:jfdfs,代码行数:5,代码来源:JfdfsPoolConfig.java


示例7: setConfigIs

import org.csource.fastdfs.ClientGlobal; //导入依赖的package包/类
public void setConfigIs(InputStream configIs) throws IOException, MyException {
	this.configIs = configIs;
	ClientGlobal.init(this.configIs);
}
 
开发者ID:yinwq0558,项目名称:jfdfs,代码行数:5,代码来源:JfdfsPoolConfig.java


示例8: main

import org.csource.fastdfs.ClientGlobal; //导入依赖的package包/类
/**
* entry point
* @param args comand arguments
*     <ul><li>args[0]: config filename</li></ul>
*     <ul><li>args[1]: local filename to upload</li></ul>
*/
 public static void main(String args[])
 {
 	if (args.length < 2)
 	{
 		System.out.println("Error: Must have 2 parameters, one is config filename, "
 		                 + "the other is the local filename to upload");
 		return;
 	}
 	
 	System.out.println("java.version=" + System.getProperty("java.version"));
 	  
 	String conf_filename = args[0];
 	String local_filename = args[1];
 	
 	try
 	{
 		ClientGlobal.init(conf_filename);
 		System.out.println("network_timeout=" + ClientGlobal.g_network_timeout + "ms");
 		System.out.println("charset=" + ClientGlobal.g_charset);

       TrackerClient tracker = new TrackerClient();
       TrackerServer trackerServer = tracker.getConnection();
       StorageServer storageServer = null;
       StorageClient1 client = new StorageClient1(trackerServer, storageServer);

       NameValuePair[] metaList = new NameValuePair[1];
       metaList[0] = new NameValuePair("fileName", local_filename);
       String fileId = client.upload_file1(local_filename, null, metaList);
       System.out.println("upload success. file id is: " + fileId);

       int i = 0;
       while (i++ < 10) {
               byte[] result = client.download_file1(fileId);
               System.out.println(i + ", download result is: " + result.length);
       }
       
 		trackerServer.close();
 	}
 	catch(Exception ex)
 	{
 		ex.printStackTrace();
 	}
 }
 
开发者ID:guokezheng,项目名称:automat,代码行数:50,代码来源:Test.java


示例9: initFastDFSClient

import org.csource.fastdfs.ClientGlobal; //导入依赖的package包/类
private static void initFastDFSClient() throws MyException {
    String[] szTrackerServers;
    String[] parts;

    ClientGlobal.g_connect_timeout = PropertiesUtil.getInt("fastDFS.connect_timeout",
        ClientGlobal.DEFAULT_CONNECT_TIMEOUT);
    if (ClientGlobal.g_connect_timeout < 0) {
        ClientGlobal.g_connect_timeout = ClientGlobal.DEFAULT_CONNECT_TIMEOUT;
    }
    ClientGlobal.g_connect_timeout *= 1000; // millisecond

    ClientGlobal.g_network_timeout = PropertiesUtil.getInt("fastDFS.network_timeout",
        ClientGlobal.DEFAULT_NETWORK_TIMEOUT);
    if (ClientGlobal.g_network_timeout < 0) {
        ClientGlobal.g_network_timeout = ClientGlobal.DEFAULT_NETWORK_TIMEOUT;
    }
    ClientGlobal.g_network_timeout *= 1000; // millisecond

    ClientGlobal.g_charset = PropertiesUtil.getString("fastDFS.charset");
    if (ClientGlobal.g_charset == null || ClientGlobal.g_charset.length() == 0) {
        ClientGlobal.g_charset = "ISO8859-1";
    }

    szTrackerServers = PropertiesUtil.getString("fastDFS.tracker_server").split(",");
    if (szTrackerServers == null) {
        throw new MyException("item \"tracker_server\" in  not found");
    }

    InetSocketAddress[] tracker_servers = new InetSocketAddress[szTrackerServers.length];
    for (int i = 0; i < szTrackerServers.length; i++) {
        parts = szTrackerServers[i].split("\\:", 2);
        if (parts.length != 2) {
            throw new MyException(
                "the value of item \"tracker_server\" is invalid, the correct format is host:port");
        }

        tracker_servers[i] = new InetSocketAddress(parts[0].trim(), Integer.parseInt(parts[1].trim()));
    }
    ClientGlobal.g_tracker_group = new TrackerGroup(tracker_servers);

    ClientGlobal.g_tracker_http_port = PropertiesUtil.getInt("fastDFS.http.tracker_http_port", 80);
    ClientGlobal.g_anti_steal_token = PropertiesUtil.getBoolean("fastDFS.http.anti_steal_token", false);
    if (ClientGlobal.g_anti_steal_token) {
        ClientGlobal.g_secret_key = PropertiesUtil.getString("fastDFS.http.secret_key");
    }
}
 
开发者ID:tb544731152,项目名称:iBase4J,代码行数:47,代码来源:FileManager.java



注:本文中的org.csource.fastdfs.ClientGlobal类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java SchedulerSignaler类代码示例发布时间:2022-05-22
下一篇:
Java InvertedRadixTree类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap