资讯专栏INFORMATION COLUMN

上云采购季！| 2核2G4M爆款云服务器低至59元/年，更有多台、长期优惠，快来选购！

立即前往
首页/文章专栏/org.csource.common.MyException: item “tracker_serv

org.csource.common.MyException: item “tracker_serv

不知名网友 / 1681人阅读

摘要：异常已解决背景自己写的博客项目使用使用工具类初始化配置进行测试，代码如下使用加载配置文件生成对应的输入流使用对象加载输入流工具类初始化配置进行测试，代码如下

org.csource.common.MyException: item “tracker_server” in null not found异常已解决

背景

自己写的博客项目使用fastDfs 使用java工具类A初始化fdfs配置进行测试，代码如下

</>复制代码 
  2. ClassPathResource cpr = new ClassPathResource("fastdfs.properties");
  3. ClientGlobal.init(cpr.getClassLoader().getResource("fdfs_client.conf").toURI().getPath());
  4. Properties properties = new Properties();
  5. // 使用ClassLoader加载properties配置文件生成对应的输入流
  6. InputStream in = cpr.getInputStream();
  7. // 使用properties对象加载输入流
  8. properties.load(in);
  9. ClientGlobal.initByProperties(properties);
  10. TrackerGroup trackerGroup = ClientGlobal.g_tracker_group;
  11. trackerClient = new TrackerClient(trackerGroup);

工具类B初始化fdfs配置进行测试，代码如下

</>复制代码 
  1. private static final String CONF_FILENAME = Thread.currentThread().getContextClassLoader()
  2. .getResource("fdfs_client.conf").getPath();
  3. --------------------------------------------
  4. ClientGlobal.init(CONF_FILENAME);

使用这两种方式都是去读取配置文件fdfs_client.conf，但是本地都正常，服务器上（CentOS7.6）不行，报错内容如下

</>复制代码 
  1. java.lang.NullPointerException        at java.io.File.(File.java:277)        at org.csource.common.IniFileReader.loadFromOsFileSystemOrClasspathAsStream(IniFileReader.java:45)        at org.csource.common.IniFileReader.loadFromFile(IniFileReader.java:150)        at org.csource.common.IniFileReader.(IniFileReader.java:30)        at org.csource.fastdfs.ClientGlobal.init(ClientGlobal.java:91)        at com.blog.utils.FastDFSClientUtils.(FastDFSClientUtils.java:51)        at com.blog.controller.FastDFSController.upload(FastDFSController.java:53)        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)        at java.lang.reflect.Method.invoke(Method.java:498)        at org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:197)        at org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:141)        at org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:106)        at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895)        at org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:808)        at org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)        at org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1064)        at org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:963)        at org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1006)        at org.springframework.web.servlet.FrameworkServlet.doPost(FrameworkServlet.java:909)        at javax.servlet.http.HttpServlet.service(HttpServlet.java:681)        at org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:883)        at javax.servlet.http.HttpServlet.service(HttpServlet.java:764)        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:227)        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)        at org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53)        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)        at org.apache.shiro.web.servlet.AbstractShiroFilter.executeChain(AbstractShiroFilter.java:449)        at org.apache.shiro.web.servlet.AbstractShiroFilter$1.call(AbstractShiroFilter.java:365)        at org.apache.shiro.subject.support.SubjectCallable.doCall(SubjectCallable.java:90)        at org.apache.shiro.subject.support.SubjectCallable.call(SubjectCallable.java:83)        at org.apache.shiro.subject.support.DelegatingSubject.execute(DelegatingSubject.java:387)        at org.apache.shiro.web.servlet.AbstractShiroFilter.doFilterInternal(AbstractShiroFilter.java:362)        at org.apache.shiro.web.servlet.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:125)        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)        at org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:100)        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)        at org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:93)        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)        at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:201)        at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:119)        at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:189)        at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:162)        at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:197)        at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:97)        at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:542)        at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:135)        at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)        at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:78)        at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:357)        at org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:382)        at org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:65)        at org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:893)        at org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1726)        at org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)        at org.apache.tomcat.util.threads.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1191)        at org.apache.tomcat.util.threads.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:659)        at org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)        at java.lang.Thread.run(Thread.java:748)09:13:42,711 [http-nio-8000-exec-1] ERROR com.blog.utils.FastDFSClientUtils  - org.csource.common.MyException: item "tracker_server" in null not found2021-11-24 21:13:42.712  INFO 2498 --- [nio-8000-exec-1] com.blog.controller.FastDFSController    : ---文件类型--->jpg09:13:42,714 [http-nio-8000-exec-1] ERROR com.blog.utils.FastDFSClientUtils  - java.lang.NullPointerException

主要报错内容 org.csource.common.MyException: item “tracker_server” in null not found

解决办法

不使用读取配置文件的方法，直接把fdfs的配置写入工具类进行加载
代码如下

</>复制代码 
  1. Properties props = new Properties();props.put(ClientGlobal.PROP_KEY_TRACKER_SERVERS,"82.157.172.63:22122");props.put(ClientGlobal.PROP_KEY_CONNECT_TIMEOUT_IN_SECONDS,3);props.put(ClientGlobal.PROP_KEY_NETWORK_TIMEOUT_IN_SECONDS,30);ClientGlobal.initByProperties(props);TrackerClient trackerClient=new TrackerClient();

完成工具类代码

</>复制代码 
  1. public class FastDFSClientUtils {
  2. private static Logger logger = Logger.getLogger(FastDFSClientUtils.class);
  3. private static TrackerClient trackerClient;
  4. //加载文件
  5. static {
  6. try {
  7. //加载fasetdfs配置项
  8. Properties props = new Properties();
  9. props.put(ClientGlobal.PROP_KEY_TRACKER_SERVERS,"82.157.172.63:22122");
  10. props.put(ClientGlobal.PROP_KEY_CONNECT_TIMEOUT_IN_SECONDS,3);
  11. props.put(ClientGlobal.PROP_KEY_NETWORK_TIMEOUT_IN_SECONDS,30);
  12. ClientGlobal.initByProperties(props);
  13. trackerClient=new TrackerClient();//
  14. /*第二种init方法  该方法我测试本地可以，服务器上不行。各位如使用自行测试//
  15. ClassPathResource cpr = new ClassPathResource("fastdfs.properties");//
  16. ClientGlobal.init(cpr.getClassLoader().getResource("fdfs_client.conf").toURI().getPath());////
  17. Properties properties = new Properties();//
  18. // 使用ClassLoader加载properties配置文件生成对应的输入流//
  19. InputStream in = cpr.getInputStream();//
  20. // 使用properties对象加载输入流//
  21. properties.load(in);//
  22. ClientGlobal.initByProperties(properties);////
  23. TrackerGroup trackerGroup = ClientGlobal.g_tracker_group;//
  24. trackerClient = new TrackerClient(trackerGroup);////
  25. System.out.println("------>"+trackerClient.getTrackerServer().getInetSocketAddress());
  26. } catch (Exception e) {
  27. logger.error(e);
  28. }
  29. }
  30. /**
  31.  * 方法名称：上传方法
  32.  * 概要说明：
  33.  * @param file 文件
  34.  * @param path 路径
  35.  * @return 上传成功返回id，失败返回null
  36.  */
  37. public static String upload(File file, String path) {
  38. TrackerServer trackerServer = null;
  39. StorageServer storageServer = null;
  40. StorageClient1 storageClient1 = null;
  41. FileInputStream fis = null;
  42. try {
  43. NameValuePair[] meta_list = null; // new NameValuePair[0];
  44. fis = new FileInputStream(file);
  45. byte[] file_buff = null;
  46. if (fis != null) {
  47. int len = fis.available();
  48. file_buff = new byte[len];
  49. fis.read(file_buff);
  50. }
  51. trackerServer = trackerClient.getTrackerServer();
  52. if (trackerServer == null) {
  53. logger.error("getConnection return null");
  54. }
  55. storageServer = trackerClient.getStoreStorage(trackerServer);
  56. storageClient1 = new StorageClient1(trackerServer, storageServer);
  57. String fileid = storageClient1.upload_file1(file_buff, getFileExt(path), meta_list);
  58. return fileid;
  59. } catch (Exception ex) {
  60. logger.error(ex);
  61. return null;
  62. } finally {
  63. if (fis != null) {
  64. try {
  65. fis.close();
  66. } catch (IOException e) {
  67. logger.error(e);
  68. }
  69. }
  70. storageClient1 = null;
  71. }
  72. }
  73. /**
  74.  * 方法名称：上传方法
  75.  * 概要说明：
  76.  * @param data 数据
  77.  * @param extName 路径
  78.  * @return 上传成功返回id，失败返回null
  79.  */
  80. public static String upload(byte[] data, String extName) {
  81. TrackerServer trackerServer = null;
  82. StorageServer storageServer = null;
  83. StorageClient1 storageClient1 = null;
  84. try {
  85. NameValuePair[] meta_list = null; // new NameValuePair[0];
  86. trackerServer = trackerClient.getTrackerServer();
  87. if (trackerServer == null) {
  88. logger.error("getConnection return null");
  89. }
  90. storageServer = trackerClient.getStoreStorage(trackerServer);
  91. storageClient1 = new StorageClient1(trackerServer, storageServer);
  92. String fileid = storageClient1.upload_file1(data, extName, meta_list);
  93. return fileid;
  94. } catch (Exception ex) {
  95. logger.error(ex);
  96. return null;
  97. } finally {
  98. storageClient1 = null;
  99. }
  100. }
  101. /**
  102.  * 方法名称：下载方法
  103.  * 概要说明：通过文件id进行下载
  104.  * @param fileId 文件id
  105.  * @return 返回InputStream
  106.  */
  107. public static InputStream download(String groupName, String fileId) {
  108. TrackerServer trackerServer = null;
  109. StorageServer storageServer = null;
  110. StorageClient1 storageClient1 = null;
  111. try {
  112. trackerServer = trackerClient.getTrackerServer();
  113. if (trackerServer == null) {
  114. logger.error("getConnection return null");
  115. }
  116. storageServer = trackerClient.getStoreStorage(trackerServer, groupName);
  117. storageClient1 = new StorageClient1(trackerServer, storageServer);
  118. byte[] bytes = storageClient1.download_file1(fileId);
  119. InputStream inputStream = new ByteArrayInputStream(bytes);
  120. return inputStream;
  121. } catch (Exception ex) {
  122. logger.error(ex);
  123. return null;
  124. } finally {
  125. storageClient1 = null;
  126. }
  127. }
  128. /**
  129.  * 方法名称：删除方法
  130.  * 概要说明：根据id来删除一个文件
  131.  * @param fileId 文件id
  132.  * @return 删除成功返回0，非0则操作失败，返回错误代码
  133.  */
  134. public static int delete(String groupName, String fileId) {
  135. TrackerServer trackerServer = null;
  136. StorageServer storageServer = null;
  137. StorageClient1 storageClient1 = null;
  138. try {
  139. trackerServer = trackerClient.getTrackerServer();
  140. if (trackerServer == null) {
  141. logger.error("getConnection return null");
  142. }
  143. storageServer = trackerClient.getStoreStorage(trackerServer, groupName);
  144. storageClient1 = new StorageClient1(trackerServer, storageServer);
  145. int result = storageClient1.delete_file1(fileId);
  146. return result;
  147. } catch (Exception ex) {
  148. logger.error(ex);
  149. return 0;
  150. } finally {
  151. storageClient1 = null;
  152. }
  153. }
  154. /**
  155.  * 方法名称：
  156.  * 概要说明：
  157.  * @param oldFileId 旧文件id
  158.  * @param file 新文件
  159.  * @param path 新文件路径
  160.  * @ret           
  161.                
  162.                                            
  163.                        
  164.
云服务器 GPU云服务器 items item Item02 item2

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/125286.html

相关文章

  • 30秒的PHP代码片段（1）数组 - Array

    摘要：排列如果所提供的函数返回的数量等于数组中成员数量的总和，则函数返回，否则返回。平铺数组将数组降为一维数组根据给定的函数对数组的元素进行分组。使用给定的回调筛选数组。相关文章秒的代码片段数学秒的代码片段字符串函数 本文来自GitHub开源项目 点我跳转 30秒的PHP代码片段 showImg(https://segmentfault.com/img/bVbnR1I?w=2800&h=12...

    dunizb 评论0 收藏0

  • Python3网络爬虫实战---30、解析库的使用：PyQuery

    摘要：父节点我们可以用方法来获取某个节点的父节点，我们用一个实例来感受一下运行结果在这里我们首先用选取了为的节点，然后调用了方法，得到其父节点，类型依然是类型。 上一篇文章：Python3网络爬虫实战---29、解析库的使用：BeautifulSoup下一篇文章：Python3网络爬虫实战---31、数据存储：文件存储 在上一节我们介绍了 BeautifulSoup 的使用，它是一个非常强...

    IntMain 评论0 收藏0

  • Javascript js递归函数 树结构

    摘要：近期项目用到大量的树结构，比如目录树文章标记动态生成树结构，实现的过程是基于的框架，结合数据驱动应用递归函数实现数据结构的增删改查一切思绪的来源，结合官方提供的树形图实例，可以轻松实现自定义开源树结构，上优秀的开源插件我都看过，都是基于树形 近期项目用到大量的树结构，比如目录树、文章标记动态生成树结构，实现的过程是基于vue的框架，结合vue数据驱动应用递归函数实现数据结构的增删改查 ...

    junbaor 评论0 收藏0

  • React Reflux

    摘要：概念是根据的创建的单向数据流类库。的单向数据流模式主要由和组成。数据更新成功后，还是通过事件机制传递的组件当中，并更新。整个过程的对接是通过事件驱动的。标识如果首字母大写就会识别不了，例如将上面的改成。 概念 Reflux是根据React的flux创建的单向数据流类库。 Reflux的单向数据流模式主要由actions和stores组成。例如，当组件list新增item时，会调用ac...

    ormsf 评论0 收藏0

  • scrapy汽车之家车型的简单爬取

    摘要：汽车之家车型的简单爬取名字自定义配置重新定义起始爬取点所有首字母按照首字母，组合对应的页面，压入根据，抓取页面定义默认的抓取函数品牌编号品牌名品牌品牌小类别品牌小类别对应的页面品牌小类别的编号品牌小类别名品牌小类别对应的页面的 汽车之家车型的简单爬取spider # -*- coding: utf-8 -*- import scrapy from scrapy import Reque...

    zhangfaliang 评论0 收藏0

发表评论

登陆后可评论

0条评论

不知名网友

男|高级讲师
我要私信

TA的文章

阅读更多
最新活动
阅读需要支付1元查看
<