添加连接ftp的连接模式

errorFile/新建文本文档.txt

+java.net.SocketException: Connection reset\r\n\tat java.net.SocketInputStream.read(SocketInputStream.java:209)\r\n\tat java.net.SocketInputStream.read(SocketInputStream.java:141)\r\n\tat sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284)\r\n\tat sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326)\r\n\tat sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178)\r\n\tat java.io.InputStreamReader.read(InputStreamReader.java:184)\r\n\tat java.io.BufferedReader.fill(BufferedReader.java:161)\r\n\tat java.io.BufferedReader.read(BufferedReader.java:182)\r\n\tat org.apache.commons.net.io.CRLFLineReader.readLine(CRLFLineReader.java:58)\r\n\tat org.apache.commons.net.ftp.FTP.__getReply(FTP.java:321)\r\n\tat org.apache.commons.net.ftp.FTP.__getReply(FTP.java:300)\r\n\tat org.apache.commons.net.ftp.FTP._connectAction_(FTP.java:438)\r\n\tat org.apache.commons.net.ftp.FTPClient._connectAction_(FTPClient.java:962)\r\n\tat org.apache.commons.net.ftp.FTPClient._connectAction_(FTPClient.java:950)\r\n\tat org.apache.commons.net.SocketClient._connect(SocketClient.java:244)\r\n\tat org.apache.commons.net.SocketClient.connect(SocketClient.java:202)\r\n\tat com.fhkj.oltinspection.util.FTPUtil.loginFtp(FTPUtil.java:44)\r\n\tat com.fhkj.oltinspection.service.impl.FtpServiceImpl.loginFtp(FtpServiceImpl.java:33)\r\n\tat com.fhkj.oltinspection.service.impl.FtpServiceImpl$$FastClassBySpringCGLIB$$84aacc25.invoke(<generated>)\r\n\tat org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)\r\n\tat org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:749)\r\n\tat org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)\r\n\tat org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:294)\r\n\tat org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:98)\r\n\tat org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)\r\n\tat org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688)\r\n\tat com.fhkj.oltinspection.service.impl.FtpServiceImpl$$EnhancerBySpringCGLIB$$49ccb52.loginFtp(<generated>)\r\n\tat com.fhkj.oltinspection.controller.FtpController.loginFTP(FtpController.java:30)\r\n\tat sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)\r\n\tat sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)\r\n\tat sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\r\n\tat java.lang.reflect.Method.invoke(Method.java:498)\r\n\tat org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:189)\r\n\tat org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138)\r\n\tat org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:102)\r\n\tat org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895)\r\n\tat org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:800)\r\n\tat org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)\r\n\tat org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1038)\r\n\tat org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:942)\r\n\tat org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1005)\r\n\tat org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:897)\r\n\tat javax.servlet.http.HttpServlet.service(HttpServlet.java:634)\r\n\tat org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:882)\r\n\tat javax.servlet.http.HttpServlet.service(HttpServlet.java:741)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:99)\r\n\tat org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:92)\r\n\tat org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:93)\r\n\tat org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:200)\r\n\tat org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat com.fhkj.oltinspection.config.SimpleCORSFilter.doFilter(SimpleCORSFilter.java:34)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:200)\r\n\tat org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)\r\n\tat org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:490)\r\n\tat org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139)\r\n\tat org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)\r\n\tat org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74)\r\n\tat org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343)\r\n\tat org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:408)\r\n\tat org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)\r\n\tat org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:834)\r\n\tat org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1415)\r\n\tat org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)\r\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\r\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\r\n\tat org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)\r\n\tat java.lang.Thread.run(Thread.java:745)\r\n"
+java.net.SocketException: Connection reset\r\n\tat java.net.SocketInputStream.read(SocketInputStream.java:209)\r\n\tat java.net.SocketInputStream.read(SocketInputStream.java:141)\r\n\tat sun.nio.cs.StreamDecoder.readBytes(StreamDecoder.java:284)\r\n\tat sun.nio.cs.StreamDecoder.implRead(StreamDecoder.java:326)\r\n\tat sun.nio.cs.StreamDecoder.read(StreamDecoder.java:178)\r\n\tat java.io.InputStreamReader.read(InputStreamReader.java:184)\r\n\tat java.io.BufferedReader.fill(BufferedReader.java:161)\r\n\tat java.io.BufferedReader.read(BufferedReader.java:182)\r\n\tat org.apache.commons.net.io.CRLFLineReader.readLine(CRLFLineReader.java:58)\r\n\tat org.apache.commons.net.ftp.FTP.__getReply(FTP.java:321)\r\n\tat org.apache.commons.net.ftp.FTP.__getReply(FTP.java:300)\r\n\tat org.apache.commons.net.ftp.FTP._connectAction_(FTP.java:438)\r\n\tat org.apache.commons.net.ftp.FTPClient._connectAction_(FTPClient.java:962)\r\n\tat org.apache.commons.net.ftp.FTPClient._connectAction_(FTPClient.java:950)\r\n\tat org.apache.commons.net.SocketClient._connect(SocketClient.java:244)\r\n\tat org.apache.commons.net.SocketClient.connect(SocketClient.java:202)\r\n\tat com.fhkj.oltinspection.util.FTPUtil.loginFtp(FTPUtil.java:44)\r\n\tat com.fhkj.oltinspection.service.impl.FtpServiceImpl.loginFtp(FtpServiceImpl.java:33)\r\n\tat com.fhkj.oltinspection.service.impl.FtpServiceImpl$$FastClassBySpringCGLIB$$84aacc25.invoke(<generated>)\r\n\tat org.springframework.cglib.proxy.MethodProxy.invoke(MethodProxy.java:218)\r\n\tat org.springframework.aop.framework.CglibAopProxy$CglibMethodInvocation.invokeJoinpoint(CglibAopProxy.java:749)\r\n\tat org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:163)\r\n\tat org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:294)\r\n\tat org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:98)\r\n\tat org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:186)\r\n\tat org.springframework.aop.framework.CglibAopProxy$DynamicAdvisedInterceptor.intercept(CglibAopProxy.java:688)\r\n\tat com.fhkj.oltinspection.service.impl.FtpServiceImpl$$EnhancerBySpringCGLIB$$49ccb52.loginFtp(<generated>)\r\n\tat com.fhkj.oltinspection.controller.FtpController.loginFTP(FtpController.java:30)\r\n\tat sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)\r\n\tat sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)\r\n\tat sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)\r\n\tat java.lang.reflect.Method.invoke(Method.java:498)\r\n\tat org.springframework.web.method.support.InvocableHandlerMethod.doInvoke(InvocableHandlerMethod.java:189)\r\n\tat org.springframework.web.method.support.InvocableHandlerMethod.invokeForRequest(InvocableHandlerMethod.java:138)\r\n\tat org.springframework.web.servlet.mvc.method.annotation.ServletInvocableHandlerMethod.invokeAndHandle(ServletInvocableHandlerMethod.java:102)\r\n\tat org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.invokeHandlerMethod(RequestMappingHandlerAdapter.java:895)\r\n\tat org.springframework.web.servlet.mvc.method.annotation.RequestMappingHandlerAdapter.handleInternal(RequestMappingHandlerAdapter.java:800)\r\n\tat org.springframework.web.servlet.mvc.method.AbstractHandlerMethodAdapter.handle(AbstractHandlerMethodAdapter.java:87)\r\n\tat org.springframework.web.servlet.DispatcherServlet.doDispatch(DispatcherServlet.java:1038)\r\n\tat org.springframework.web.servlet.DispatcherServlet.doService(DispatcherServlet.java:942)\r\n\tat org.springframework.web.servlet.FrameworkServlet.processRequest(FrameworkServlet.java:1005)\r\n\tat org.springframework.web.servlet.FrameworkServlet.doGet(FrameworkServlet.java:897)\r\n\tat javax.servlet.http.HttpServlet.service(HttpServlet.java:634)\r\n\tat org.springframework.web.servlet.FrameworkServlet.service(FrameworkServlet.java:882)\r\n\tat javax.servlet.http.HttpServlet.service(HttpServlet.java:741)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:231)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat org.apache.tomcat.websocket.server.WsFilter.doFilter(WsFilter.java:53)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat org.springframework.web.filter.RequestContextFilter.doFilterInternal(RequestContextFilter.java:99)\r\n\tat org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat org.springframework.web.filter.FormContentFilter.doFilterInternal(FormContentFilter.java:92)\r\n\tat org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat org.springframework.web.filter.HiddenHttpMethodFilter.doFilterInternal(HiddenHttpMethodFilter.java:93)\r\n\tat org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:200)\r\n\tat org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:107)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat com.fhkj.oltinspection.config.SimpleCORSFilter.doFilter(SimpleCORSFilter.java:34)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:193)\r\n\tat org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:166)\r\n\tat org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:200)\r\n\tat org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:96)\r\n\tat org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:490)\r\n\tat org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:139)\r\n\tat org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:92)\r\n\tat org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:74)\r\n\tat org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:343)\r\n\tat org.apache.coyote.http11.Http11Processor.service(Http11Processor.java:408)\r\n\tat org.apache.coyote.AbstractProcessorLight.process(AbstractProcessorLight.java:66)\r\n\tat org.apache.coyote.AbstractProtocol$ConnectionHandler.process(AbstractProtocol.java:834)\r\n\tat org.apache.tomcat.util.net.NioEndpoint$SocketProcessor.doRun(NioEndpoint.java:1415)\r\n\tat org.apache.tomcat.util.net.SocketProcessorBase.run(SocketProcessorBase.java:49)\r\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142)\r\n\tat java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617)\r\n\tat org.apache.tomcat.util.threads.TaskThread$WrappingRunnable.run(TaskThread.java:61)\r\n\tat java.lang.Thread.run(Thread.java:745)\r\n"
\ No newline at end of file

pom.xml

@@ -64,6 +64,11 @@
             <artifactId>Java-WebSocket</artifactId>  
             <version>1.3.5</version>  
         </dependency>
+		<dependency>
+            <groupId>commons-net</groupId>
+            <artifactId>commons-net</artifactId>
+            <version>3.6</version>
+        </dependency>
 	</dependencies>
 
 	<build>

src/main/java/com/fhkj/oltinspection/controller/FtpController.java

+package com.fhkj.oltinspection.controller;
+
+import com.fhkj.oltinspection.entity.FtpConfigEntity;
+import com.fhkj.oltinspection.pojo.Result;
+import com.fhkj.oltinspection.service.FtpService;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @author huyi 
+ * @see 操作ftp的接口
+ */
+@RestController
+@RequestMapping (value = "/ftp")
+public class FtpController {
+    @Autowired
+    private FtpService ftpSetvice;
+    /**
+     * @param
+     * @return Result
+     * @see 登录ftp的接口
+     */
+    @GetMapping (value = "/loginFtp")
+    public Result loginFTP () {
+
+        return ftpSetvice.loginFtp(1);
+    }
+
+    @PostMapping (value = "/addFtpConfig")
+    public Result addFtpConfig () {
+        FtpConfigEntity ftpConfigEntity = new FtpConfigEntity();
+        ftpConfigEntity.setHost ("10.109.21.8");
+        ftpConfigEntity.setPort (21);
+        ftpConfigEntity.setUsername("GEPON");
+        ftpConfigEntity.setPassword("GEPON");
+        return ftpSetvice.saveFtpConfigEntity(ftpConfigEntity);
+    }
+}
\ No newline at end of file

src/main/java/com/fhkj/oltinspection/controller/PushInfoController.java

@@ -20,7 +20,7 @@ import java.util.concurrent.CopyOnWriteArraySet;
 @Component
 public class PushInfoController {
     // 静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。
-    private static int onlineCount = 0;
+    private static int onlineCount = 0; 
     // concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。
     private static CopyOnWriteArraySet<PushInfoController> webSocketSet = new CopyOnWriteArraySet<PushInfoController>();
     // 与某个客户端的连接会话，需要通过它来给客户端发送数据

src/main/java/com/fhkj/oltinspection/entity/FtpConfigEntity.java

+package com.fhkj.oltinspection.entity;
+
+import javax.persistence.Column;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.Table;
+
+@Entity
+@Table (name = "ftp_config_entity")
+public class FtpConfigEntity {
+    @Id
+    @GeneratedValue (strategy = GenerationType.AUTO)
+    private Integer id;
+    @Column (name = "host")
+    private String host;
+    @Column (name = "port")
+    private Integer port;
+    @Column (name= "username")
+    private String username;
+    @Column (name = "password")
+    private String password;
+
+    /**
+     * @return the id
+     */
+    public Integer getId() {
+        return id;
+    }
+
+    /**
+     * @param id the id to set
+     */
+    public void setId(Integer id) {
+        this.id = id;
+    }
+    /**
+     * @return the host
+     */
+    public String getHost() {
+        return host;
+    }
+    /**
+     * @param host the host to set
+     */
+    public void setHost(String host) {
+        this.host = host;
+    }
+    /**
+     * @return the port
+     */
+    public Integer getPort() {
+        return port;
+    }
+    /**
+     * @param port the port to set
+     */
+    public void setPort(Integer port) {
+        this.port = port;
+    }
+    /**
+     * @return the username
+     */
+    public String getUsername() {
+        return username;
+    }
+
+    /**
+     * @param username the username to set
+     */
+    public void setUsername(String username) {
+        this.username = username;
+    }
+    /**
+     * @return the password
+     */
+    public String getPassword() {
+        return password;
+    }
+    /**
+     * @param password the password to set
+     */
+    public void setPassword(String password) {
+        this.password = password;
+    }
+    public String toString () {
+        return "host:" + this.host + ", port:" + this.port + ", username:" + this.username + ", password:" + this.password;
+    }
+}
\ No newline at end of file

src/main/java/com/fhkj/oltinspection/repository/FtpConfigRepository.java

+package com.fhkj.oltinspection.repository;
+
+import java.util.Optional;
+
+import com.fhkj.oltinspection.entity.FtpConfigEntity;
+
+import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.JpaSpecificationExecutor;
+import org.springframework.stereotype.Repository;
+
+@Repository
+public interface FtpConfigRepository extends JpaRepository <FtpConfigEntity, Integer> , JpaSpecificationExecutor <FtpConfigEntity> {
+    public Optional<FtpConfigEntity> findById (Integer id);
+}
\ No newline at end of file

src/main/java/com/fhkj/oltinspection/service/FtpService.java

+package com.fhkj.oltinspection.service;
+
+import com.fhkj.oltinspection.entity.FtpConfigEntity;
+import com.fhkj.oltinspection.pojo.Result;
+
+public interface FtpService {
+
+    public Result saveFtpConfigEntity (FtpConfigEntity ftpConfigEntity);
+
+    public Result loginFtp (Integer id);
+}
\ No newline at end of file

src/main/java/com/fhkj/oltinspection/service/impl/FtpServiceImpl.java

+package com.fhkj.oltinspection.service.impl;
+
+import java.util.Optional;
+
+import javax.transaction.Transactional;
+
+import com.fhkj.oltinspection.entity.FtpConfigEntity;
+import com.fhkj.oltinspection.pojo.Result;
+import com.fhkj.oltinspection.repository.FtpConfigRepository;
+import com.fhkj.oltinspection.service.FtpService;
+import com.fhkj.oltinspection.util.FTPUtil;
+import com.fhkj.oltinspection.util.PackageExceptionUtil;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+@Transactional
+public class FtpServiceImpl implements FtpService {
+
+    @Autowired
+    private FtpConfigRepository ftpConfigRepository;
+
+    /**
+     * @param Intger(id)
+     * @return Result
+     * @see 登录ftp
+     */
+    @Override
+    public Result loginFtp(Integer id) {
+        Optional<FtpConfigEntity> ftpConfigEntityOptional = ftpConfigRepository.findById(id);
+        if (ftpConfigEntityOptional.isPresent()) {
+            return FTPUtil.loginFtp(ftpConfigEntityOptional.get());
+        } else {
+            return new Result ("未能查询到frp登录所需的信息", false);
+        }
+    }
+
+    @Override
+    public Result saveFtpConfigEntity(FtpConfigEntity ftpConfigEntity) {
+        try {
+            FtpConfigEntity fce = ftpConfigRepository.save(ftpConfigEntity);
+            if (null == fce.getId() || 0 == fce.getId()) {
+                return new Result ("保存失败", false);
+            } else {
+                return new Result ("保存成功", true);
+            }
+        } catch (Exception e) {
+            return new Result ("保存失败", PackageExceptionUtil.exceptionToString(e));
+        }
+    }
+
+}
\ No newline at end of file

src/main/java/com/fhkj/oltinspection/util/FTPUtil.java

+package com.fhkj.oltinspection.util;
+
+import java.io.IOException;
+import java.util.Arrays;
+
+import com.fhkj.oltinspection.entity.FtpConfigEntity;
+import com.fhkj.oltinspection.pojo.Result;
+
+import org.apache.commons.net.ftp.FTPClient;
+
+/**
+ * @author 胡懿
+ * @see 这个了用来操作ftp
+ */
+public class FTPUtil {
+    /**
+     * @see 用来来登录ftp
+     * @param com.fhkj.oltinspection.entity.FtpConfigEntity
+     * @exception IOException
+     * @return Result
+     */
+    public static Result loginFtp(FtpConfigEntity ftpConfigEntity) {
+        if (ftpConfigEntity == null) {
+            return new Result("在数据库中未能获取到ftp的连接配置信息", false);
+        }
+        String host = ftpConfigEntity.getHost();
+        Integer port = ftpConfigEntity.getPort();
+        String username = ftpConfigEntity.getUsername();
+        String password = ftpConfigEntity.getPassword();
+        if (null == host || "".equals(host.trim())) {
+            return new Result("IP为空", false);
+        }
+        if (null == port || "0".equals(port)) {
+            return new Result("port为空", false);
+        }
+        if (null == username || "".equals(username.trim())) {
+            return new Result("username为空", false);
+        }
+        if (null == password || "".equals(password.trim())) {
+            return new Result("password为空", false);
+        }
+        FTPClient ftpClient = new FTPClient(); // 创建ftp连接对象
+        try {
+            ftpClient.connect (host, port); // 设置ip和端口
+            ftpClient.login (username, password); // 设置用户名和密码
+            String[] ftpFileNames = ftpClient.listNames();
+            System.out.println(Arrays.toString(ftpFileNames));
+            if (ftpClient.isConnected()) { // 判断ftp是否连接
+                ftpClient.logout(); // 退出ftp登录
+                ftpClient.disconnect(); // 关闭连接
+            }
+        } catch (IOException e) {
+            return new Result("出现连接异常", PackageExceptionUtil.exceptionToString(e));
+        }
+        return new Result();
+    }
+}
\ No newline at end of file

src/main/java/com/fhkj/oltinspection/util/PackageExceptionUtil.java

+package com.fhkj.oltinspection.util;
+
+import java.io.PrintWriter;
+import java.io.StringWriter;
+import java.io.Writer;
+
+/**
+ * @author
+ * @see 这个类用来处理Exception的信息
+ */
+public class PackageExceptionUtil {
+    /**
+     * @param Exception
+     * @return String
+     * @see 这个类会返回e.printstacktrace()输出到控制台的字符串
+     */
+    public static String exceptionToString (Exception e) {
+        Writer writer = new StringWriter ();
+        e.printStackTrace (new PrintWriter(writer));
+        return writer.toString ();
+    }
+}
\ No newline at end of file

src/main/resources/test.html

@@ -60,7 +60,7 @@
 				alert(message);
 				websocket.send(message);
 			}
-			document.onclick = function () {
+			document.getElementById("send").onclick = function () {
 				send();
 			}
 		</script>