1

13693261870

2022-12-12 0eee8acf970b2a656b558b5e903c7bda4fb27d6a

1

 src/main/java/com/lf/server/controller/other/FloatServerController.java

@@ -52,7 +52,7 @@

            res.getWriter().write(strRes);
        } catch (Exception ex) {
            String str = ex.getMessage();
            log.error(ex.getMessage(), ex);
        }
    }


 src/main/java/com/lf/server/helper/EnumHelper.java

@@ -50,6 +50,7 @@
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        }

        return result;
    }


 src/main/java/com/lf/server/helper/GdalHelper.java

@@ -129,7 +129,7 @@
                break;
            }
        } catch (Exception ex) {
            ex.printStackTrace();
            log.error(ex.getMessage(), ex);
        }
    }

@@ -192,8 +192,8 @@
                //layerDto.setCount(count);
                //layerDto.setMap(mapList);
            }
        } catch (Exception e) {
            e.printStackTrace();
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        } finally {
            if (dataSource != null) {
                dataSource.delete();

 src/main/java/com/lf/server/helper/RsaHelper.java

@@ -1,6 +1,8 @@
package com.lf.server.helper;

import org.apache.commons.codec.binary.Base64;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.core.io.ClassPathResource;

import javax.crypto.Cipher;
@@ -30,12 +32,20 @@
     */
    private static String publicKey;

    /**
     * 密钥算法
     */
    private static final String KEY_ALGORITHM = "RSA";

    /**
     * RSA密钥长度：1024 或 2048
     */
    private static final int DEFAULT_RSA_KEY_SIZE = 1024;

    /**
     * 日志
     */
    private final static Log log = LogFactory.getLog(RsaHelper.class);

    /**
     * 生成公私钥
@@ -145,8 +155,8 @@
            // 得到私钥字符串
            String pri = new String(Base64.encodeBase64(keyPair.getPrivate().getEncoded()));
            result.put("privateKey", pri);
        } catch (GeneralSecurityException e) {
            e.printStackTrace();
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
        }

        return result;

 src/main/java/com/lf/server/service/all/WebSocketService.java

@@ -23,21 +23,21 @@
        System.out.println("websocket 加载");
    }

    private static Logger log = LoggerFactory.getLogger(WebSocketService.class);
    private final static Logger log = LoggerFactory.getLogger(WebSocketService.class);

    private static final AtomicInteger ONLINE_COUNT = new AtomicInteger(0);

    /**
     * 用来存放每个客户端对应的Session对象（线程安全Set）
     */
    private static CopyOnWriteArraySet<Session> SessionSet = new CopyOnWriteArraySet<Session>();
    private final static CopyOnWriteArraySet<Session> SESSION_SET = new CopyOnWriteArraySet<Session>();

    /**
     * 连接建立成功调用的方法
     */
    @OnOpen
    public void onOpen(Session session) {
        SessionSet.add(session);
        SESSION_SET.add(session);

        int cnt = ONLINE_COUNT.incrementAndGet();
        log.info("有连接加入，当前连接数为：{}", cnt);
@@ -49,7 +49,7 @@
     */
    @OnClose
    public void onClose(Session session) {
        SessionSet.remove(session);
        SESSION_SET.remove(session);

        int cnt = ONLINE_COUNT.decrementAndGet();
        log.info("有连接关闭，当前连接数为：{}", cnt);
@@ -75,7 +75,6 @@
    @OnError
    public void onError(Session session, Throwable error) {
        log.error("发生错误：{}，Session ID： {}", error.getMessage(), session.getId());
        error.printStackTrace();
    }

    /**
@@ -87,9 +86,8 @@
    public static void sendMessage(Session session, String message) {
        try {
            session.getBasicRemote().sendText(String.format("%s", message));
        } catch (IOException e) {
            log.error("发送消息出错：{}", e.getMessage());
            e.printStackTrace();
        } catch (Exception ex) {
            log.error("发送消息出错：{}", ex.getMessage());
        }
    }

@@ -100,7 +98,7 @@
     * @throws IOException
     */
    public static void broadCastInfo(String message) throws IOException {
        for (Session session : SessionSet) {
        for (Session session : SESSION_SET) {
            if (session.isOpen()) {
                sendMessage(session, message);
            }
@@ -116,7 +114,7 @@
     */
    public static void sendMessage(String message, String sessionId) throws IOException {
        Session session = null;
        for (Session s : SessionSet) {
        for (Session s : SESSION_SET) {
            if (s.getId().equals(sessionId)) {
                session = s;
                break;
@@ -126,7 +124,7 @@
        if (session != null) {
            sendMessage(session, message);
        } else {
            log.warn("没有找到你指定ID的会话：{}", sessionId);
            log.info("没有找到你指定ID的会话：{}", sessionId);
        }
    }
}

 src/main/java/com/lf/server/service/sys/UserService.java

@@ -5,7 +5,10 @@
import com.lf.server.helper.RsaHelper;
import com.lf.server.helper.StringHelper;
import com.lf.server.mapper.sys.UserMapper;
import com.lf.server.service.all.CommonsFileuploadService;
import com.lf.server.service.all.RedisService;
import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@@ -30,6 +33,8 @@

    @Autowired
    TokenService tokenService;

    private final static Log log = LogFactory.getLog(UserService.class);

    @Override
    public Integer selectCount(String uname) {
@@ -154,6 +159,7 @@

            return null;
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
            return "解密失败";
        }
    }
@@ -182,6 +188,7 @@

            return null;
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
            return "解密失败";
        }
    }
@@ -222,6 +229,7 @@

            return null;
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
            return "解密失败";
        }
    }
@@ -269,6 +277,7 @@

            return null;
        } catch (Exception ex) {
            log.error(ex.getMessage(), ex);
            return "解密失败";
        }
    }