Parcourir la source

转发demo

master
xuqm il y a 1 an
révision
0b53c916fd
27 fichiers modifiés avec 1411 ajouts et 0 suppressions
  1. +33
    -0
      .gitignore
  2. BIN
      .mvn/wrapper/maven-wrapper.jar
  3. +18
    -0
      .mvn/wrapper/maven-wrapper.properties
  4. +316
    -0
      mvnw
  5. +188
    -0
      mvnw.cmd
  6. +52
    -0
      pom.xml
  7. +32
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/GlobalCorsConfig.java
  8. +16
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/PushDemoApplication.java
  9. +17
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/controller/HelloController.java
  10. +54
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/json/GsonImplHelp.java
  11. +29
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/json/Json.java
  12. +18
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/AckSendMessage.java
  13. +16
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/BaseMessage.java
  14. +9
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/CallbackListener.java
  15. +7
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/ConnAckMessage.java
  16. +71
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/ConnectMessage.java
  17. +163
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/ImClient.java
  18. +10
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/ImClientInterface.java
  19. +104
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/Message.java
  20. +104
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/MsgType.java
  21. +9
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/OsType.java
  22. +16
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/PacketType.java
  23. +7
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/PangMessage.java
  24. +16
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/PingMessage.java
  25. +92
    -0
      src/main/java/cn/org/bjca/trust/pushdemo/message/SendMessage.java
  26. +1
    -0
      src/main/resources/application.properties
  27. +13
    -0
      src/test/java/cn/org/bjca/trust/pushdemo/PushDemoApplicationTests.java

+ 33
- 0
.gitignore Voir le fichier

@@ -0,0 +1,33 @@
HELP.md
target/
!.mvn/wrapper/maven-wrapper.jar
!**/src/main/**/target/
!**/src/test/**/target/

### STS ###
.apt_generated
.classpath
.factorypath
.project
.settings
.springBeans
.sts4-cache

### IntelliJ IDEA ###
.idea
*.iws
*.iml
*.ipr

### NetBeans ###
/nbproject/private/
/nbbuild/
/dist/
/nbdist/
/.nb-gradle/
build/
!**/src/main/**/build/
!**/src/test/**/build/

### VS Code ###
.vscode/

BIN
.mvn/wrapper/maven-wrapper.jar Voir le fichier


+ 18
- 0
.mvn/wrapper/maven-wrapper.properties Voir le fichier

@@ -0,0 +1,18 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
distributionUrl=https://repo.maven.apache.org/maven2/org/apache/maven/apache-maven/3.8.7/apache-maven-3.8.7-bin.zip
wrapperUrl=https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.1/maven-wrapper-3.1.1.jar

+ 316
- 0
mvnw Voir le fichier

@@ -0,0 +1,316 @@
#!/bin/sh
# ----------------------------------------------------------------------------
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# https://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
# ----------------------------------------------------------------------------

# ----------------------------------------------------------------------------
# Maven Start Up Batch script
#
# Required ENV vars:
# ------------------
# JAVA_HOME - location of a JDK home dir
#
# Optional ENV vars
# -----------------
# M2_HOME - location of maven2's installed home dir
# MAVEN_OPTS - parameters passed to the Java VM when running Maven
# e.g. to debug Maven itself, use
# set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
# MAVEN_SKIP_RC - flag to disable loading of mavenrc files
# ----------------------------------------------------------------------------

if [ -z "$MAVEN_SKIP_RC" ] ; then

if [ -f /usr/local/etc/mavenrc ] ; then
. /usr/local/etc/mavenrc
fi

if [ -f /etc/mavenrc ] ; then
. /etc/mavenrc
fi

if [ -f "$HOME/.mavenrc" ] ; then
. "$HOME/.mavenrc"
fi

fi

# OS specific support. $var _must_ be set to either true or false.
cygwin=false;
darwin=false;
mingw=false
case "`uname`" in
CYGWIN*) cygwin=true ;;
MINGW*) mingw=true;;
Darwin*) darwin=true
# Use /usr/libexec/java_home if available, otherwise fall back to /Library/Java/Home
# See https://developer.apple.com/library/mac/qa/qa1170/_index.html
if [ -z "$JAVA_HOME" ]; then
if [ -x "/usr/libexec/java_home" ]; then
export JAVA_HOME="`/usr/libexec/java_home`"
else
export JAVA_HOME="/Library/Java/Home"
fi
fi
;;
esac

if [ -z "$JAVA_HOME" ] ; then
if [ -r /etc/gentoo-release ] ; then
JAVA_HOME=`java-config --jre-home`
fi
fi

if [ -z "$M2_HOME" ] ; then
## resolve links - $0 may be a link to maven's home
PRG="$0"

# need this for relative symlinks
while [ -h "$PRG" ] ; do
ls=`ls -ld "$PRG"`
link=`expr "$ls" : '.*-> \(.*\)$'`
if expr "$link" : '/.*' > /dev/null; then
PRG="$link"
else
PRG="`dirname "$PRG"`/$link"
fi
done

saveddir=`pwd`

M2_HOME=`dirname "$PRG"`/..

# make it fully qualified
M2_HOME=`cd "$M2_HOME" && pwd`

cd "$saveddir"
# echo Using m2 at $M2_HOME
fi

# For Cygwin, ensure paths are in UNIX format before anything is touched
if $cygwin ; then
[ -n "$M2_HOME" ] &&
M2_HOME=`cygpath --unix "$M2_HOME"`
[ -n "$JAVA_HOME" ] &&
JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
[ -n "$CLASSPATH" ] &&
CLASSPATH=`cygpath --path --unix "$CLASSPATH"`
fi

# For Mingw, ensure paths are in UNIX format before anything is touched
if $mingw ; then
[ -n "$M2_HOME" ] &&
M2_HOME="`(cd "$M2_HOME"; pwd)`"
[ -n "$JAVA_HOME" ] &&
JAVA_HOME="`(cd "$JAVA_HOME"; pwd)`"
fi

if [ -z "$JAVA_HOME" ]; then
javaExecutable="`which javac`"
if [ -n "$javaExecutable" ] && ! [ "`expr \"$javaExecutable\" : '\([^ ]*\)'`" = "no" ]; then
# readlink(1) is not available as standard on Solaris 10.
readLink=`which readlink`
if [ ! `expr "$readLink" : '\([^ ]*\)'` = "no" ]; then
if $darwin ; then
javaHome="`dirname \"$javaExecutable\"`"
javaExecutable="`cd \"$javaHome\" && pwd -P`/javac"
else
javaExecutable="`readlink -f \"$javaExecutable\"`"
fi
javaHome="`dirname \"$javaExecutable\"`"
javaHome=`expr "$javaHome" : '\(.*\)/bin'`
JAVA_HOME="$javaHome"
export JAVA_HOME
fi
fi
fi

if [ -z "$JAVACMD" ] ; then
if [ -n "$JAVA_HOME" ] ; then
if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
# IBM's JDK on AIX uses strange locations for the executables
JAVACMD="$JAVA_HOME/jre/sh/java"
else
JAVACMD="$JAVA_HOME/bin/java"
fi
else
JAVACMD="`\\unset -f command; \\command -v java`"
fi
fi

if [ ! -x "$JAVACMD" ] ; then
echo "Error: JAVA_HOME is not defined correctly." >&2
echo " We cannot execute $JAVACMD" >&2
exit 1
fi

if [ -z "$JAVA_HOME" ] ; then
echo "Warning: JAVA_HOME environment variable is not set."
fi

CLASSWORLDS_LAUNCHER=org.codehaus.plexus.classworlds.launcher.Launcher

# traverses directory structure from process work directory to filesystem root
# first directory with .mvn subdirectory is considered project base directory
find_maven_basedir() {

if [ -z "$1" ]
then
echo "Path not specified to find_maven_basedir"
return 1
fi

basedir="$1"
wdir="$1"
while [ "$wdir" != '/' ] ; do
if [ -d "$wdir"/.mvn ] ; then
basedir=$wdir
break
fi
# workaround for JBEAP-8937 (on Solaris 10/Sparc)
if [ -d "${wdir}" ]; then
wdir=`cd "$wdir/.."; pwd`
fi
# end of workaround
done
echo "${basedir}"
}

# concatenates all lines of a file
concat_lines() {
if [ -f "$1" ]; then
echo "$(tr -s '\n' ' ' < "$1")"
fi
}

BASE_DIR=`find_maven_basedir "$(pwd)"`
if [ -z "$BASE_DIR" ]; then
exit 1;
fi

##########################################################################################
# Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
# This allows using the maven wrapper in projects that prohibit checking in binary data.
##########################################################################################
if [ -r "$BASE_DIR/.mvn/wrapper/maven-wrapper.jar" ]; then
if [ "$MVNW_VERBOSE" = true ]; then
echo "Found .mvn/wrapper/maven-wrapper.jar"
fi
else
if [ "$MVNW_VERBOSE" = true ]; then
echo "Couldn't find .mvn/wrapper/maven-wrapper.jar, downloading it ..."
fi
if [ -n "$MVNW_REPOURL" ]; then
jarUrl="$MVNW_REPOURL/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
else
jarUrl="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
fi
while IFS="=" read key value; do
case "$key" in (wrapperUrl) jarUrl="$value"; break ;;
esac
done < "$BASE_DIR/.mvn/wrapper/maven-wrapper.properties"
if [ "$MVNW_VERBOSE" = true ]; then
echo "Downloading from: $jarUrl"
fi
wrapperJarPath="$BASE_DIR/.mvn/wrapper/maven-wrapper.jar"
if $cygwin; then
wrapperJarPath=`cygpath --path --windows "$wrapperJarPath"`
fi

if command -v wget > /dev/null; then
if [ "$MVNW_VERBOSE" = true ]; then
echo "Found wget ... using wget"
fi
if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
wget "$jarUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath"
else
wget --http-user=$MVNW_USERNAME --http-password=$MVNW_PASSWORD "$jarUrl" -O "$wrapperJarPath" || rm -f "$wrapperJarPath"
fi
elif command -v curl > /dev/null; then
if [ "$MVNW_VERBOSE" = true ]; then
echo "Found curl ... using curl"
fi
if [ -z "$MVNW_USERNAME" ] || [ -z "$MVNW_PASSWORD" ]; then
curl -o "$wrapperJarPath" "$jarUrl" -f
else
curl --user $MVNW_USERNAME:$MVNW_PASSWORD -o "$wrapperJarPath" "$jarUrl" -f
fi

else
if [ "$MVNW_VERBOSE" = true ]; then
echo "Falling back to using Java to download"
fi
javaClass="$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.java"
# For Cygwin, switch paths to Windows format before running javac
if $cygwin; then
javaClass=`cygpath --path --windows "$javaClass"`
fi
if [ -e "$javaClass" ]; then
if [ ! -e "$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.class" ]; then
if [ "$MVNW_VERBOSE" = true ]; then
echo " - Compiling MavenWrapperDownloader.java ..."
fi
# Compiling the Java class
("$JAVA_HOME/bin/javac" "$javaClass")
fi
if [ -e "$BASE_DIR/.mvn/wrapper/MavenWrapperDownloader.class" ]; then
# Running the downloader
if [ "$MVNW_VERBOSE" = true ]; then
echo " - Running MavenWrapperDownloader.java ..."
fi
("$JAVA_HOME/bin/java" -cp .mvn/wrapper MavenWrapperDownloader "$MAVEN_PROJECTBASEDIR")
fi
fi
fi
fi
##########################################################################################
# End of extension
##########################################################################################

export MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-"$BASE_DIR"}
if [ "$MVNW_VERBOSE" = true ]; then
echo $MAVEN_PROJECTBASEDIR
fi
MAVEN_OPTS="$(concat_lines "$MAVEN_PROJECTBASEDIR/.mvn/jvm.config") $MAVEN_OPTS"

# For Cygwin, switch paths to Windows format before running java
if $cygwin; then
[ -n "$M2_HOME" ] &&
M2_HOME=`cygpath --path --windows "$M2_HOME"`
[ -n "$JAVA_HOME" ] &&
JAVA_HOME=`cygpath --path --windows "$JAVA_HOME"`
[ -n "$CLASSPATH" ] &&
CLASSPATH=`cygpath --path --windows "$CLASSPATH"`
[ -n "$MAVEN_PROJECTBASEDIR" ] &&
MAVEN_PROJECTBASEDIR=`cygpath --path --windows "$MAVEN_PROJECTBASEDIR"`
fi

# Provide a "standardized" way to retrieve the CLI args that will
# work with both Windows and non-Windows executions.
MAVEN_CMD_LINE_ARGS="$MAVEN_CONFIG $@"
export MAVEN_CMD_LINE_ARGS

WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain

exec "$JAVACMD" \
$MAVEN_OPTS \
$MAVEN_DEBUG_OPTS \
-classpath "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" \
"-Dmaven.home=${M2_HOME}" \
"-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \
${WRAPPER_LAUNCHER} $MAVEN_CONFIG "$@"

+ 188
- 0
mvnw.cmd Voir le fichier

@@ -0,0 +1,188 @@
@REM ----------------------------------------------------------------------------
@REM Licensed to the Apache Software Foundation (ASF) under one
@REM or more contributor license agreements. See the NOTICE file
@REM distributed with this work for additional information
@REM regarding copyright ownership. The ASF licenses this file
@REM to you under the Apache License, Version 2.0 (the
@REM "License"); you may not use this file except in compliance
@REM with the License. You may obtain a copy of the License at
@REM
@REM https://www.apache.org/licenses/LICENSE-2.0
@REM
@REM Unless required by applicable law or agreed to in writing,
@REM software distributed under the License is distributed on an
@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
@REM KIND, either express or implied. See the License for the
@REM specific language governing permissions and limitations
@REM under the License.
@REM ----------------------------------------------------------------------------

@REM ----------------------------------------------------------------------------
@REM Maven Start Up Batch script
@REM
@REM Required ENV vars:
@REM JAVA_HOME - location of a JDK home dir
@REM
@REM Optional ENV vars
@REM M2_HOME - location of maven2's installed home dir
@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a keystroke before ending
@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
@REM e.g. to debug Maven itself, use
@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
@REM ----------------------------------------------------------------------------

@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
@echo off
@REM set title of command window
title %0
@REM enable echoing by setting MAVEN_BATCH_ECHO to 'on'
@if "%MAVEN_BATCH_ECHO%" == "on" echo %MAVEN_BATCH_ECHO%

@REM set %HOME% to equivalent of $HOME
if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")

@REM Execute a user defined script before this one
if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
@REM check for pre script, once with legacy .bat ending and once with .cmd ending
if exist "%USERPROFILE%\mavenrc_pre.bat" call "%USERPROFILE%\mavenrc_pre.bat" %*
if exist "%USERPROFILE%\mavenrc_pre.cmd" call "%USERPROFILE%\mavenrc_pre.cmd" %*
:skipRcPre

@setlocal

set ERROR_CODE=0

@REM To isolate internal variables from possible post scripts, we use another setlocal
@setlocal

@REM ==== START VALIDATION ====
if not "%JAVA_HOME%" == "" goto OkJHome

echo.
echo Error: JAVA_HOME not found in your environment. >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error

:OkJHome
if exist "%JAVA_HOME%\bin\java.exe" goto init

echo.
echo Error: JAVA_HOME is set to an invalid directory. >&2
echo JAVA_HOME = "%JAVA_HOME%" >&2
echo Please set the JAVA_HOME variable in your environment to match the >&2
echo location of your Java installation. >&2
echo.
goto error

@REM ==== END VALIDATION ====

:init

@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
@REM Fallback to current working directory if not found.

set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir

set EXEC_DIR=%CD%
set WDIR=%EXEC_DIR%
:findBaseDir
IF EXIST "%WDIR%"\.mvn goto baseDirFound
cd ..
IF "%WDIR%"=="%CD%" goto baseDirNotFound
set WDIR=%CD%
goto findBaseDir

:baseDirFound
set MAVEN_PROJECTBASEDIR=%WDIR%
cd "%EXEC_DIR%"
goto endDetectBaseDir

:baseDirNotFound
set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
cd "%EXEC_DIR%"

:endDetectBaseDir

IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig

@setlocal EnableExtensions EnableDelayedExpansion
for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%

:endReadAdditionalConfig

SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
set WRAPPER_JAR="%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.jar"
set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain

set DOWNLOAD_URL="https://repo.maven.apache.org/maven2/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"

FOR /F "usebackq tokens=1,2 delims==" %%A IN ("%MAVEN_PROJECTBASEDIR%\.mvn\wrapper\maven-wrapper.properties") DO (
IF "%%A"=="wrapperUrl" SET DOWNLOAD_URL=%%B
)

@REM Extension to allow automatically downloading the maven-wrapper.jar from Maven-central
@REM This allows using the maven wrapper in projects that prohibit checking in binary data.
if exist %WRAPPER_JAR% (
if "%MVNW_VERBOSE%" == "true" (
echo Found %WRAPPER_JAR%
)
) else (
if not "%MVNW_REPOURL%" == "" (
SET DOWNLOAD_URL="%MVNW_REPOURL%/org/apache/maven/wrapper/maven-wrapper/3.1.0/maven-wrapper-3.1.0.jar"
)
if "%MVNW_VERBOSE%" == "true" (
echo Couldn't find %WRAPPER_JAR%, downloading it ...
echo Downloading from: %DOWNLOAD_URL%
)

powershell -Command "&{"^
"$webclient = new-object System.Net.WebClient;"^
"if (-not ([string]::IsNullOrEmpty('%MVNW_USERNAME%') -and [string]::IsNullOrEmpty('%MVNW_PASSWORD%'))) {"^
"$webclient.Credentials = new-object System.Net.NetworkCredential('%MVNW_USERNAME%', '%MVNW_PASSWORD%');"^
"}"^
"[Net.ServicePointManager]::SecurityProtocol = [Net.SecurityProtocolType]::Tls12; $webclient.DownloadFile('%DOWNLOAD_URL%', '%WRAPPER_JAR%')"^
"}"
if "%MVNW_VERBOSE%" == "true" (
echo Finished downloading %WRAPPER_JAR%
)
)
@REM End of extension

@REM Provide a "standardized" way to retrieve the CLI args that will
@REM work with both Windows and non-Windows executions.
set MAVEN_CMD_LINE_ARGS=%*

%MAVEN_JAVA_EXE% ^
%JVM_CONFIG_MAVEN_PROPS% ^
%MAVEN_OPTS% ^
%MAVEN_DEBUG_OPTS% ^
-classpath %WRAPPER_JAR% ^
"-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" ^
%WRAPPER_LAUNCHER% %MAVEN_CONFIG% %*
if ERRORLEVEL 1 goto error
goto end

:error
set ERROR_CODE=1

:end
@endlocal & set ERROR_CODE=%ERROR_CODE%

if not "%MAVEN_SKIP_RC%"=="" goto skipRcPost
@REM check for post script, once with legacy .bat ending and once with .cmd ending
if exist "%USERPROFILE%\mavenrc_post.bat" call "%USERPROFILE%\mavenrc_post.bat"
if exist "%USERPROFILE%\mavenrc_post.cmd" call "%USERPROFILE%\mavenrc_post.cmd"
:skipRcPost

@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
if "%MAVEN_BATCH_PAUSE%"=="on" pause

if "%MAVEN_TERMINATE_CMD%"=="on" exit %ERROR_CODE%

cmd /C exit /B %ERROR_CODE%

+ 52
- 0
pom.xml Voir le fichier

@@ -0,0 +1,52 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>3.0.4</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>
<groupId>com.example</groupId>
<artifactId>PushDemo</artifactId>
<version>0.0.1-SNAPSHOT</version>
<name>PushDemo</name>
<description>PushDemo</description>
<properties>
<java.version>17</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.eclipse.paho</groupId>
<artifactId>org.eclipse.paho.client.mqttv3</artifactId>
<version>1.2.5</version>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.9.0</version>
</dependency>

</dependencies>

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>

</project>

+ 32
- 0
src/main/java/cn/org/bjca/trust/pushdemo/GlobalCorsConfig.java Voir le fichier

@@ -0,0 +1,32 @@
package cn.org.bjca.trust.pushdemo;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.CorsRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;

@Configuration
public class GlobalCorsConfig {
@Bean
public WebMvcConfigurer corsConfigurer() {
return new WebMvcConfigurer() {
@Override
//重写父类提供的跨域请求处理的接口
public void addCorsMappings(CorsRegistry registry) {
//添加映射路径
registry.addMapping("/**")
//放行哪些原始域
.allowedOrigins("*")
//是否发送Cookie信息
.allowCredentials(false)
//放行哪些原始域(请求方式)
.allowedMethods("GET", "POST", "PUT", "DELETE")
//放行哪些原始域(头部信息)
.allowedHeaders("*")
//暴露哪些头部信息(因为跨域访问默认不能获取全部头部信息)
.exposedHeaders("Header1", "Header2");
}
};
}
}


+ 16
- 0
src/main/java/cn/org/bjca/trust/pushdemo/PushDemoApplication.java Voir le fichier

@@ -0,0 +1,16 @@
package cn.org.bjca.trust.pushdemo;

import cn.org.bjca.trust.pushdemo.message.ImClient;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class PushDemoApplication {

public static void main(String[] args) {
SpringApplication.run(PushDemoApplication.class, args);
ImClient client = new ImClient();
client.connect();
}

}

+ 17
- 0
src/main/java/cn/org/bjca/trust/pushdemo/controller/HelloController.java Voir le fichier

@@ -0,0 +1,17 @@
package cn.org.bjca.trust.pushdemo.controller;

import org.springframework.web.bind.annotation.*;

@RestController
@RequestMapping("hello")
public class HelloController {
@GetMapping("/{id}")
public String getById(@PathVariable Integer id) {
System.out.println("id ==> " + id);
return "{\n" +
" \"msg\": \"qdxorigin\",\n" +
" \"status\": \"200\",\n" +
" \"data\": \"Sbfuiaefhaikufhcsauik\"\n" +
"}";
}
}

+ 54
- 0
src/main/java/cn/org/bjca/trust/pushdemo/json/GsonImplHelp.java Voir le fichier

@@ -0,0 +1,54 @@
package cn.org.bjca.trust.pushdemo.json;

import com.google.gson.Gson;
import com.google.gson.JsonArray;
import com.google.gson.JsonElement;
import com.google.gson.JsonParser;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

/**
* Created by xuqm on 2016/6/3.
*/
public class GsonImplHelp extends Json {
private final Gson gson = new Gson();

@Override
public String toJson(Object src) {
return gson.toJson(src);

}

@Override
public <T> T toObject(String json, Class<T> claxx) {
return gson.fromJson(json, claxx);

}

@Override
public <T> T toObject(byte[] bytes, Class<T> claxx) {
return gson.fromJson(new String(bytes), claxx);

}

public <T> List<T> toList(String json, Class<T> clazz) {
JsonArray jsonArray = JsonParser.parseString(json).getAsJsonArray();

List<T> list = new ArrayList<>();
for (JsonElement jsonElement : jsonArray) {
list.add(gson.fromJson(jsonElement, clazz)); //cls
}

return list;


}

public static <T> List<T> stringToArray(String s, Class<T[]> cls) {
T[] array = new Gson().fromJson(s, cls);
return Arrays.asList(array);
}

}

+ 29
- 0
src/main/java/cn/org/bjca/trust/pushdemo/json/Json.java Voir le fichier

@@ -0,0 +1,29 @@
package cn.org.bjca.trust.pushdemo.json;

import java.util.List;

/**
* Created by xuqm on 2016/6/3.
*/
public abstract class Json {
private static Json json;

Json() {
}

public static Json get() {
if (json == null) {
json = new GsonImplHelp();
}
return json;
}

public abstract String toJson(Object src);

public abstract <T> T toObject(String json, Class<T> claxx);

public abstract <T> T toObject(byte[] bytes, Class<T> claxx);

public abstract <T> List<T> toList(String json, Class<T> claxx);

}

+ 18
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/AckSendMessage.java Voir le fichier

@@ -0,0 +1,18 @@
package cn.org.bjca.trust.pushdemo.message;

public class AckSendMessage extends BaseMessage {
public AckSendMessage(String messageId) {
super(PacketType.SENDACK);
this.messageId = messageId;
}

private String messageId;

public String getMessageId() {
return messageId;
}

public void setMessageId(String messageId) {
this.messageId = messageId;
}
}

+ 16
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/BaseMessage.java Voir le fichier

@@ -0,0 +1,16 @@
package cn.org.bjca.trust.pushdemo.message;

public abstract class BaseMessage {
private PacketType packetType;
public BaseMessage(PacketType packetType){
this.packetType = packetType;
}

public PacketType getPacketType() {
return packetType;
}

public void setPacketType(PacketType packetType) {
this.packetType = packetType;
}
}

+ 9
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/CallbackListener.java Voir le fichier

@@ -0,0 +1,9 @@
package cn.org.bjca.trust.pushdemo.message;

public interface CallbackListener {
void sendComplete(String msg);
void sendError(String msg);
void messageArrived(String msg);
void connected(String msg);
void connectError(String msg);
}

+ 7
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/ConnAckMessage.java Voir le fichier

@@ -0,0 +1,7 @@
package cn.org.bjca.trust.pushdemo.message;

public class ConnAckMessage extends BaseMessage {
public ConnAckMessage() {
super(PacketType.CONNACK);
}
}

+ 71
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/ConnectMessage.java Voir le fichier

@@ -0,0 +1,71 @@
package cn.org.bjca.trust.pushdemo.message;

public class ConnectMessage extends BaseMessage {
public ConnectMessage() {
super(PacketType.CONNECT);
}
private String sessionKey;
private OsType osType;
private String osVer;
private String sdkVer;
// private String deviceType;
private String token;
private String clientId;
private String deviceId;

public String getSessionKey() {
return sessionKey;
}

public void setSessionKey(String sessionKey) {
this.sessionKey = sessionKey;
}

public OsType getOsType() {
return osType;
}

public void setOsType(OsType osType) {
this.osType = osType;
}

public String getOsVer() {
return osVer;
}

public void setOsVer(String osVer) {
this.osVer = osVer;
}

public String getSdkVer() {
return sdkVer;
}

public void setSdkVer(String sdkVer) {
this.sdkVer = sdkVer;
}

public String getToken() {
return token;
}

public void setToken(String token) {
this.token = token;
}

public String getClientId() {
return clientId;
}

public void setClientId(String clientId) {
this.clientId = clientId;
}

public String getDeviceId() {
return deviceId;
}

public void setDeviceId(String deviceId) {
this.deviceId = deviceId;
}
}

+ 163
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/ImClient.java Voir le fichier

@@ -0,0 +1,163 @@
package cn.org.bjca.trust.pushdemo.message;

import cn.org.bjca.trust.pushdemo.json.GsonImplHelp;
import org.eclipse.paho.client.mqttv3.*;

import java.nio.charset.StandardCharsets;

public class ImClient implements ImClientInterface {

private boolean isConnecting = false;

private MqttClient client;
private MqttConnectOptions options;

@Override
public void connect() {
init();
mConnect();
}

@Override
public void reConnect() {
init();
mConnect();
}

@Override
public void disConnect() {

}

@Override
public boolean isConnect() {
return client.isConnected();
}

@Override
public boolean isConnecting() {
return isConnecting;
}

@Override
public void sendMessage(SendMessage msg) {

}

private void init() {
if (null == this.client) {
try {
this.client = new MqttClient("tcp://192.168.115.137:18883", "server" + System.currentTimeMillis());
} catch (MqttException e) {
throw new RuntimeException(e);
}
options = new MqttConnectOptions();
options.setCleanSession(true);
options.setUserName("server");
options.setPassword("server".toCharArray());
options.setAutomaticReconnect(true);
options.setKeepAliveInterval(20);
options.setConnectionTimeout(30);
client.setCallback(new MqttCallbackExtended() {
@Override
public void connectComplete(boolean b, String s) {
System.out.println("----------------------连接成功--------------------------" + b);
isConnecting = false;
MqttClient client1 = client;
try {
client1.subscribe("server", 2);
} catch (MqttException e) {
throw new RuntimeException(e);
}
}

@Override
public void connectionLost(Throwable throwable) {
System.out.println("----------------------掉线--------------------------");
}

@Override
public void messageArrived(String s, MqttMessage mqttMessage) {
// System.out.println(new String(mqttMessage.getPayload()));
String msg = new String(mqttMessage.getPayload());

BaseMessage message = GsonImplHelp.get().toObject(msg, PingMessage.class);

switch (message.getPacketType()) {
case SEND:
SendMessage sendMessage = GsonImplHelp.get().toObject(msg, SendMessage.class);
try {
System.out.println("----------------------消息到达--------------------------" + msg);
client.publish(sendMessage.getFromClientId(), GsonImplHelp.get().toJson(new AckSendMessage(sendMessage.getMessageId())).getBytes(StandardCharsets.UTF_8), 2, false);
} catch (MqttException e) {
System.out.printf("---------------" + e.getMessage());
}
try {
if (sendMessage.getToClientId().startsWith("G_")) {
SendMessage message1 = new SendMessage();
message1.setMessageId(sendMessage.getMessageId());
message1.setMessage(sendMessage.getMessage());
message1.setMessageType(sendMessage.getMessageType());
message1.setFromClientId(sendMessage.getToClientId());
message1.setTarget(sendMessage.getFromClientId());
message1.setToClientId("xuqm");
message1.setTimestamp(sendMessage.getTimestamp());
message1.setTenantNo(sendMessage.getTenantNo());
client.publish(message1.getToClientId(), GsonImplHelp.get().toJson(message1).getBytes(StandardCharsets.UTF_8), 2, false);
} else {
client.publish(sendMessage.getToClientId(), GsonImplHelp.get().toJson(sendMessage).getBytes(StandardCharsets.UTF_8), 2, false);
}
} catch (MqttException e) {
System.out.printf("---------------" + e.getMessage());
}
System.out.println("----------------------转发完成--------------------------");
break;
case SENDACK:
System.out.println("-------------消息送达---------------------");
break;
case PING:
try {
PingMessage pingMessage = GsonImplHelp.get().toObject(msg, PingMessage.class);
client.publish(pingMessage.getFromClientId(), GsonImplHelp.get().toJson(new PangMessage()).getBytes(StandardCharsets.UTF_8), 2, false);
} catch (MqttException e) {
}
break;
case DISCONNECT:
System.out.println("-------------用户注销---------------------");
break;
case CONNECT:
System.out.println("-------------用户连接请求---------------------");
ConnectMessage connectMessage = GsonImplHelp.get().toObject(msg, ConnectMessage.class);
try {
client.publish(connectMessage.getClientId(), GsonImplHelp.get().toJson(new ConnAckMessage()).getBytes(StandardCharsets.UTF_8), 2, false);
} catch (MqttException e) {
}
break;
}

}

@Override
public void deliveryComplete(IMqttDeliveryToken iMqttDeliveryToken) {

}
});
}
}

private void mConnect() {
if (isConnect() || isConnecting) return;
isConnecting = true;
if (!client.isConnected()) {
System.out.println("---------------------开始连接2----------------------");
try {
client.connect(options);
} catch (MqttException e) {
System.out.println("---------------------连接失败----------------------");
throw new RuntimeException(e);
}
this.isConnecting = false;
}

}
}

+ 10
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/ImClientInterface.java Voir le fichier

@@ -0,0 +1,10 @@
package cn.org.bjca.trust.pushdemo.message;

public interface ImClientInterface {
void connect();
void reConnect();
void disConnect();
boolean isConnect();
boolean isConnecting();
void sendMessage(SendMessage msg);
}

+ 104
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/Message.java Voir le fichier

@@ -0,0 +1,104 @@
package cn.org.bjca.trust.pushdemo.message;

public abstract class Message {
private String messageId;
private String from;
private String to;
private String tenantNo;
private MsgType type = MsgType.UNKNOWN;
private long timestamp;

private boolean parseError = false;


public String getTenantNo() {
return tenantNo;
}

public void setTenantNo(String tenantNo) {
this.tenantNo = tenantNo;
}

public String getMessageId() {
return messageId;
}

public void setMessageId(String messageId) {
this.messageId = messageId;
}

public String getFrom() {
return from;
}

public void setFrom(String from) {
this.from = from;
}

public String getTo() {
return to;
}

public void setTo(String to) {
this.to = to;
}

public MsgType getType() {
return this.type;
}

public void setType(MsgType type) {
this.type = type;
}

public boolean isParseError() {
return parseError;
}

public void setParseError(boolean parseError) {
this.parseError = parseError;
}

public long getTimestamp() {
return timestamp;
}

public void setTimestamp(long timestamp) {
this.timestamp = timestamp;
}

// public void parse(MsgType type, Object json) throws JSONException {
// if (json instanceof JSONObject) {
// JSONObject jsonObj = (JSONObject) json;
// this.setMessageId(jsonObj.getString("messageId"));
// this.setFrom(jsonObj.getString("from"));
// this.setTo(jsonObj.getString("to"));
// // this.setVersion(jsonObj.getString("version"));
// this.setTimestamp(jsonObj.getLong("timestamp"));
// }
//
// };

public void parse(MsgType type, SendMessage sendMessage) {
this.setType(type);
this.setMessageId(sendMessage.getMessageId());
this.setFrom(sendMessage.getFromClientId());
this.setTo(sendMessage.getToClientId());
this.setTimestamp(sendMessage.getTimestamp());
this.setTenantNo(sendMessage.getTenantNo());
}


public abstract String createContentJsonStr();

protected String addContentHeader(String jsonStr) {
/*
StringBuffer buffer = new StringBuffer();
buffer.append(this.getType().value());
buffer.append(jsonStr);
return buffer.toString();
*/
return jsonStr;
}

}

+ 104
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/MsgType.java Voir le fichier

@@ -0,0 +1,104 @@
package cn.org.bjca.trust.pushdemo.message;

public enum MsgType {

UNKNOWN(-1) /* 未知 */,
Text(1) /* 文本 对应:Text(1) */,
Voice(2) /* 语音 对应:Voice(2) */,
Image(3) /* 图片 对应:Picture(3) */,
Location(4) /* 位置 对应:Location(4) */,
Video(5) /* 视频 对应:Video(5) */,
VCard(6) /* 名片 对应:Vcard(6) */,
News(7) /* 多图文 对应:MultiHtml(8) */,
File(8) /* 文件 对应:File(9) */,
Link(9) /* 链接 */,
Music(10) /* 音乐 */,
At(11) /* @我 */,
PublicCard(12) /* 公众号名片消息 */,
Business(14), /* 业务消息 */
App(15), /* 应用消息 */
Other(10010), /* 自定义消息 */
//通知类消息
//系统级
OtherLogined(101) /* 未知 */,
ChangPassword(102) /* web端修改密码 */,
Cancel(110), /* 撤销消息 */
FriendRequest(121), /* A加B,B收到的。好友申请通知消息 */
FriendResponse(122), /* A加B,B通过验证或回复消息,给A发的好友添加成功通知消息 */
ContactAdded(123), //A加B,不用验证,给B的通知
ContactDeleted(124), /* A删除B,给B的通知。好友删除通知消息 */
UserAvatarChanged(125), /* 好友头像变更通知消息 */
UserNicknameChanged(126), /* 好友昵称变更通知消息 */
GroupMemberAdded(141), /* 群成员加入群消息 对应:GroupMemberAdded(20)*/
GroupMemberDeleted(142), /* 群成员退出群消息 对应:GroupDeleteMember(21)*/
GroupMemberExited(143), /* 用户主动退群: 群成员退出群消息 */
GroupNameChanged(144), /* 群名称变更消息 */
GroupLogoChanged(145), /* 群LOGO变更消息 */
GroupMemberNicknameChanged(146), /* 群成员昵称变更消息 */
ReadMessage(147), /* 已读消息 */
GroupSavedAsContact(148), /* 群保存通讯录 */
OrganizationChanged(161), /* 组织变更消息 */
OrganizationMemberChanged(162), /* 组织成员变更消息 */
UserJoinTenant(170),/* 用户加入租户 */
UserLeaveTenant(171),/* 用户退出租户 */
TodoTask(181), /* 待办消息 */
PublicListChanged(200), /* 公众号列表变更消息 */
PublicWebsiteListChanged(201), /* 应用列表变更消息 */
ThirdAppClassChanged(202), /* 应用分类变更消息 */
ThirdAppLogin(203), /* 第三方应用登录通知 */
UserDisabled(210), /* 用户禁用消息 */
addComment(211), /* 添加评论 */
deleteComment(242), /* 删除评论 */

/**
* pc 登陆 start
*/
LoginRequestMessage(230),/*登录请求*/
LoginWaittingMessage(231),/*等待登录*/
LoginWaittingCancelMessage(232),/*取消等待*/
LoginAuthorizationMessage(233),/*授权登录*/
LoginStatusMessage(234),/*登录状态*/
LoginQuitMessage(235),/*退出登录*/
/**
* pc 登陆 end
*/
/**
* 音频/视频消息 start
*/
AVMeetingInvite(250),/*邀请通知*/
AVMeetingRefuse(251),/*拒绝通知*/
AVMeetingCancel(252),/*取消通知*/
AVMeetingTimeout(253),/*超时通知*/
AVMeetingBusy(254),/*占线通知*/
AVMeetingSwitch(255),/*切换音频通知*/
AVMeetingConnected(256),/* 聊天已连接通知*/
MulAVMeetingInvite(260), /*群视频邀请*/
MulAVMeetingRefuse(261), /*群成员拒绝通知*/
MulAVMeetingCancel(262),/*取消通知*/
MulAVMeetingTimeOut(263),/*超时通知 */
/**
* 音频/视频消息 end
*/
Notify(999);


private int value = -1;

MsgType(final int value) {
this.value = value;
}

public int value() {
return this.value;
}

public static MsgType getValue(final int value) {
for (final MsgType type : MsgType.values()) {
if (type.value == value) {
return type;
}
}
return UNKNOWN;
}

}

+ 9
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/OsType.java Voir le fichier

@@ -0,0 +1,9 @@
package cn.org.bjca.trust.pushdemo.message;

public enum OsType {
IOS(1), ANDROID(2), WEB(3), WINDOWS(4), MAC(5), UNKNOWN(-1);

OsType(int value) {

}
}

+ 16
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/PacketType.java Voir le fichier

@@ -0,0 +1,16 @@
package cn.org.bjca.trust.pushdemo.message;

public enum PacketType {
CONNECT(10),
CONNACK(11),
SEND(20),
SENDACK(21),
PING(30),
PANG(31),
DISCONNECT(40),
UNKNOWN(-1);

PacketType(int i) {

}
}

+ 7
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/PangMessage.java Voir le fichier

@@ -0,0 +1,7 @@
package cn.org.bjca.trust.pushdemo.message;

public class PangMessage extends BaseMessage {
public PangMessage() {
super(PacketType.PANG);
}
}

+ 16
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/PingMessage.java Voir le fichier

@@ -0,0 +1,16 @@
package cn.org.bjca.trust.pushdemo.message;

public class PingMessage extends BaseMessage {
private String fromClientId;
public PingMessage() {
super(PacketType.PING);
}

public void setFromClientId(String fromClientId) {
this.fromClientId = fromClientId;
}

public String getFromClientId() {
return fromClientId;
}
}

+ 92
- 0
src/main/java/cn/org/bjca/trust/pushdemo/message/SendMessage.java Voir le fichier

@@ -0,0 +1,92 @@
package cn.org.bjca.trust.pushdemo.message;

import com.fasterxml.jackson.annotation.JsonIgnore;

public class SendMessage extends BaseMessage {
private String messageId;
private long timestamp;
private String toClientId;
private String target;
private int messageType;
private String message;
private String fromClientId;
private String tenantNo;

public String getTenantNo() {
return this.tenantNo;
}

public void setTenantNo(String tenantNo) {
this.tenantNo = tenantNo;
}

public SendMessage() {
super(PacketType.SEND);
}

public String getMessageId() {
return this.messageId;
}

public void setMessageId(String messageId) {
this.messageId = messageId;
}

public long getTimestamp() {
return this.timestamp;
}

public void setTimestamp(long timestamp) {
this.timestamp = timestamp;
}

public String getToClientId() {
return this.toClientId;
}

public void setToClientId(String toClientId) {
this.toClientId = toClientId;
}

public String getMessage() {
return this.message;
}

public void setMessage(String message) {
this.message = message;
}

@JsonIgnore
public boolean isValid() {
return true;
}

@JsonIgnore
public boolean equals(Object another) {
return another != null && another instanceof SendMessage ? this.messageId.equals(((SendMessage) another).messageId) : false;
}

public String getFromClientId() {
return this.fromClientId;
}

public void setFromClientId(String fromClientId) {
this.fromClientId = fromClientId;
}

public int getMessageType() {
return this.messageType;
}

public void setMessageType(int messageType) {
this.messageType = messageType;
}

public String getTarget() {
return target;
}

public void setTarget(String target) {
this.target = target;
}
}

+ 1
- 0
src/main/resources/application.properties Voir le fichier

@@ -0,0 +1 @@
server.port=8888

+ 13
- 0
src/test/java/cn/org/bjca/trust/pushdemo/PushDemoApplicationTests.java Voir le fichier

@@ -0,0 +1,13 @@
package cn.org.bjca.trust.pushdemo;

import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;

@SpringBootTest
class PushDemoApplicationTests {

@Test
void contextLoads() {
}

}

Chargement…
Annuler
Enregistrer