/** * FTP Server 启动 */ public void start() { FtpServerFactory serverFactory = new FtpServerFactory(); ListenerFactory factory = new ListenerFactory(); // set the port of the listener factory.setPort(21); if (LOG.isInfoEnabled()) { LOG.info("----------------Ftp server 端口21----------------------------"); } // replace the default listener serverFactory.addListener("default", factory.createListener()); //设置用户配置信息 PropertiesUserManagerFactory userManagerFactory = new PropertiesUserManagerFactory(); userManagerFactory.setFile(SysConfig.getInstance().getConfigFile()); if (LOG.isInfoEnabled()) { LOG.info("----------------Ftp server 设置用户配置信息----------------------------"); } //注册FTP事件监听 Map<String, Ftplet> ftplets = new LinkedHashMap<String, Ftplet>(); ftplets.put(FtpletNotification.class.getName(), new FtpletNotification()); serverFactory.setFtplets(ftplets); if (LOG.isInfoEnabled()) { LOG.info("----------------Ftp server 注册FTP事件监听----------------------------"); } serverFactory.setUserManager(userManagerFactory.createUserManager()); if (LOG.isInfoEnabled()) { LOG.info("----------------Ftp server 准备启动----------------------------"); } // start the server server = serverFactory.createServer(); try { server.start(); port = serverFactory.getListener("default").getPort(); serverAddress = serverFactory.getListener("default").getServerAddress(); if(serverAddress == null) { try { serverAddress= InetAddress.getLocalHost().getHostAddress(); } catch (UnknownHostException e) { e.printStackTrace(); } } if (LOG.isInfoEnabled()) { LOG.info("----------------Ftp serverAddress----------------------------" + serverAddress); } if (LOG.isInfoEnabled()) { LOG.info("----------------Ftp server 启动成功----------------------------"); } } catch (FtpException e) { e.printStackTrace(); if (LOG.isErrorEnabled()) { LOG.error("FTP server 启动失败 ", e); } } } 转载请保留固定链接: https://linuxeye.com/program/526.html |