commit
af53284a4d
14 changed files with 643 additions and 0 deletions
@ -0,0 +1,37 @@ |
|||||
|
HELP.md |
||||
|
.gradle |
||||
|
build/ |
||||
|
!gradle/wrapper/gradle-wrapper.jar |
||||
|
!**/src/main/**/build/ |
||||
|
!**/src/test/**/build/ |
||||
|
|
||||
|
### STS ### |
||||
|
.apt_generated |
||||
|
.classpath |
||||
|
.factorypath |
||||
|
.project |
||||
|
.settings |
||||
|
.springBeans |
||||
|
.sts4-cache |
||||
|
bin/ |
||||
|
!**/src/main/**/bin/ |
||||
|
!**/src/test/**/bin/ |
||||
|
|
||||
|
### IntelliJ IDEA ### |
||||
|
.idea |
||||
|
*.iws |
||||
|
*.iml |
||||
|
*.ipr |
||||
|
out/ |
||||
|
!**/src/main/**/out/ |
||||
|
!**/src/test/**/out/ |
||||
|
|
||||
|
### NetBeans ### |
||||
|
/nbproject/private/ |
||||
|
/nbbuild/ |
||||
|
/dist/ |
||||
|
/nbdist/ |
||||
|
/.nb-gradle/ |
||||
|
|
||||
|
### VS Code ### |
||||
|
.vscode/ |
||||
@ -0,0 +1,39 @@ |
|||||
|
plugins { |
||||
|
id 'org.springframework.boot' version '2.6.4' |
||||
|
id 'io.spring.dependency-management' version '1.0.11.RELEASE' |
||||
|
id 'java' |
||||
|
} |
||||
|
|
||||
|
group = 'com.aiprose' |
||||
|
version = '0.0.1-SNAPSHOT' |
||||
|
sourceCompatibility = '1.8' |
||||
|
|
||||
|
configurations { |
||||
|
compileOnly { |
||||
|
extendsFrom annotationProcessor |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
repositories { |
||||
|
maven { url "https://maven.aliyun.com/repository/public" } |
||||
|
// maven { url "http://maven.aiprose.com/nexus/content/repositories/public/" } |
||||
|
mavenCentral() |
||||
|
} |
||||
|
|
||||
|
dependencies { |
||||
|
// implementation 'org.springframework.boot:spring-boot-starter-data-jpa' |
||||
|
// implementation 'org.springframework.boot:spring-boot-starter-data-redis-reactive' |
||||
|
implementation 'org.springframework.boot:spring-boot-starter-webflux' |
||||
|
implementation 'org.springframework.boot:spring-boot-starter-websocket' |
||||
|
implementation 'com.alibaba:fastjson:1.2.79' |
||||
|
implementation group: 'org.apache.commons', name: 'commons-lang3', version: '3.12.0' |
||||
|
compileOnly 'org.projectlombok:lombok' |
||||
|
runtimeOnly 'mysql:mysql-connector-java' |
||||
|
annotationProcessor 'org.projectlombok:lombok' |
||||
|
testImplementation 'org.springframework.boot:spring-boot-starter-test' |
||||
|
testImplementation 'io.projectreactor:reactor-test' |
||||
|
} |
||||
|
|
||||
|
tasks.named('test') { |
||||
|
useJUnitPlatform() |
||||
|
} |
||||
@ -0,0 +1,234 @@ |
|||||
|
#!/bin/sh |
||||
|
|
||||
|
# |
||||
|
# Copyright © 2015-2021 the original authors. |
||||
|
# |
||||
|
# Licensed 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. |
||||
|
# |
||||
|
|
||||
|
############################################################################## |
||||
|
# |
||||
|
# Gradle start up script for POSIX generated by Gradle. |
||||
|
# |
||||
|
# Important for running: |
||||
|
# |
||||
|
# (1) You need a POSIX-compliant shell to run this script. If your /bin/sh is |
||||
|
# noncompliant, but you have some other compliant shell such as ksh or |
||||
|
# bash, then to run this script, type that shell name before the whole |
||||
|
# command line, like: |
||||
|
# |
||||
|
# ksh Gradle |
||||
|
# |
||||
|
# Busybox and similar reduced shells will NOT work, because this script |
||||
|
# requires all of these POSIX shell features: |
||||
|
# * functions; |
||||
|
# * expansions «$var», «${var}», «${var:-default}», «${var+SET}», |
||||
|
# «${var#prefix}», «${var%suffix}», and «$( cmd )»; |
||||
|
# * compound commands having a testable exit status, especially «case»; |
||||
|
# * various built-in commands including «command», «set», and «ulimit». |
||||
|
# |
||||
|
# Important for patching: |
||||
|
# |
||||
|
# (2) This script targets any POSIX shell, so it avoids extensions provided |
||||
|
# by Bash, Ksh, etc; in particular arrays are avoided. |
||||
|
# |
||||
|
# The "traditional" practice of packing multiple parameters into a |
||||
|
# space-separated string is a well documented source of bugs and security |
||||
|
# problems, so this is (mostly) avoided, by progressively accumulating |
||||
|
# options in "$@", and eventually passing that to Java. |
||||
|
# |
||||
|
# Where the inherited environment variables (DEFAULT_JVM_OPTS, JAVA_OPTS, |
||||
|
# and GRADLE_OPTS) rely on word-splitting, this is performed explicitly; |
||||
|
# see the in-line comments for details. |
||||
|
# |
||||
|
# There are tweaks for specific operating systems such as AIX, CygWin, |
||||
|
# Darwin, MinGW, and NonStop. |
||||
|
# |
||||
|
# (3) This script is generated from the Groovy template |
||||
|
# https://github.com/gradle/gradle/blob/master/subprojects/plugins/src/main/resources/org/gradle/api/internal/plugins/unixStartScript.txt |
||||
|
# within the Gradle project. |
||||
|
# |
||||
|
# You can find Gradle at https://github.com/gradle/gradle/. |
||||
|
# |
||||
|
############################################################################## |
||||
|
|
||||
|
# Attempt to set APP_HOME |
||||
|
|
||||
|
# Resolve links: $0 may be a link |
||||
|
app_path=$0 |
||||
|
|
||||
|
# Need this for daisy-chained symlinks. |
||||
|
while |
||||
|
APP_HOME=${app_path%"${app_path##*/}"} # leaves a trailing /; empty if no leading path |
||||
|
[ -h "$app_path" ] |
||||
|
do |
||||
|
ls=$( ls -ld "$app_path" ) |
||||
|
link=${ls#*' -> '} |
||||
|
case $link in #( |
||||
|
/*) app_path=$link ;; #( |
||||
|
*) app_path=$APP_HOME$link ;; |
||||
|
esac |
||||
|
done |
||||
|
|
||||
|
APP_HOME=$( cd "${APP_HOME:-./}" && pwd -P ) || exit |
||||
|
|
||||
|
APP_NAME="Gradle" |
||||
|
APP_BASE_NAME=${0##*/} |
||||
|
|
||||
|
# Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script. |
||||
|
DEFAULT_JVM_OPTS='"-Xmx64m" "-Xms64m"' |
||||
|
|
||||
|
# Use the maximum available, or set MAX_FD != -1 to use that value. |
||||
|
MAX_FD=maximum |
||||
|
|
||||
|
warn () { |
||||
|
echo "$*" |
||||
|
} >&2 |
||||
|
|
||||
|
die () { |
||||
|
echo |
||||
|
echo "$*" |
||||
|
echo |
||||
|
exit 1 |
||||
|
} >&2 |
||||
|
|
||||
|
# OS specific support (must be 'true' or 'false'). |
||||
|
cygwin=false |
||||
|
msys=false |
||||
|
darwin=false |
||||
|
nonstop=false |
||||
|
case "$( uname )" in #( |
||||
|
CYGWIN* ) cygwin=true ;; #( |
||||
|
Darwin* ) darwin=true ;; #( |
||||
|
MSYS* | MINGW* ) msys=true ;; #( |
||||
|
NONSTOP* ) nonstop=true ;; |
||||
|
esac |
||||
|
|
||||
|
CLASSPATH=$APP_HOME/gradle/wrapper/gradle-wrapper.jar |
||||
|
|
||||
|
|
||||
|
# Determine the Java command to use to start the JVM. |
||||
|
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 |
||||
|
if [ ! -x "$JAVACMD" ] ; then |
||||
|
die "ERROR: JAVA_HOME is set to an invalid directory: $JAVA_HOME |
||||
|
|
||||
|
Please set the JAVA_HOME variable in your environment to match the |
||||
|
location of your Java installation." |
||||
|
fi |
||||
|
else |
||||
|
JAVACMD=java |
||||
|
which java >/dev/null 2>&1 || die "ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. |
||||
|
|
||||
|
Please set the JAVA_HOME variable in your environment to match the |
||||
|
location of your Java installation." |
||||
|
fi |
||||
|
|
||||
|
# Increase the maximum file descriptors if we can. |
||||
|
if ! "$cygwin" && ! "$darwin" && ! "$nonstop" ; then |
||||
|
case $MAX_FD in #( |
||||
|
max*) |
||||
|
MAX_FD=$( ulimit -H -n ) || |
||||
|
warn "Could not query maximum file descriptor limit" |
||||
|
esac |
||||
|
case $MAX_FD in #( |
||||
|
'' | soft) :;; #( |
||||
|
*) |
||||
|
ulimit -n "$MAX_FD" || |
||||
|
warn "Could not set maximum file descriptor limit to $MAX_FD" |
||||
|
esac |
||||
|
fi |
||||
|
|
||||
|
# Collect all arguments for the java command, stacking in reverse order: |
||||
|
# * args from the command line |
||||
|
# * the main class name |
||||
|
# * -classpath |
||||
|
# * -D...appname settings |
||||
|
# * --module-path (only if needed) |
||||
|
# * DEFAULT_JVM_OPTS, JAVA_OPTS, and GRADLE_OPTS environment variables. |
||||
|
|
||||
|
# For Cygwin or MSYS, switch paths to Windows format before running java |
||||
|
if "$cygwin" || "$msys" ; then |
||||
|
APP_HOME=$( cygpath --path --mixed "$APP_HOME" ) |
||||
|
CLASSPATH=$( cygpath --path --mixed "$CLASSPATH" ) |
||||
|
|
||||
|
JAVACMD=$( cygpath --unix "$JAVACMD" ) |
||||
|
|
||||
|
# Now convert the arguments - kludge to limit ourselves to /bin/sh |
||||
|
for arg do |
||||
|
if |
||||
|
case $arg in #( |
||||
|
-*) false ;; # don't mess with options #( |
||||
|
/?*) t=${arg#/} t=/${t%%/*} # looks like a POSIX filepath |
||||
|
[ -e "$t" ] ;; #( |
||||
|
*) false ;; |
||||
|
esac |
||||
|
then |
||||
|
arg=$( cygpath --path --ignore --mixed "$arg" ) |
||||
|
fi |
||||
|
# Roll the args list around exactly as many times as the number of |
||||
|
# args, so each arg winds up back in the position where it started, but |
||||
|
# possibly modified. |
||||
|
# |
||||
|
# NB: a `for` loop captures its iteration list before it begins, so |
||||
|
# changing the positional parameters here affects neither the number of |
||||
|
# iterations, nor the values presented in `arg`. |
||||
|
shift # remove old arg |
||||
|
set -- "$@" "$arg" # push replacement arg |
||||
|
done |
||||
|
fi |
||||
|
|
||||
|
# Collect all arguments for the java command; |
||||
|
# * $DEFAULT_JVM_OPTS, $JAVA_OPTS, and $GRADLE_OPTS can contain fragments of |
||||
|
# shell script including quotes and variable substitutions, so put them in |
||||
|
# double quotes to make sure that they get re-expanded; and |
||||
|
# * put everything else in single quotes, so that it's not re-expanded. |
||||
|
|
||||
|
set -- \ |
||||
|
"-Dorg.gradle.appname=$APP_BASE_NAME" \ |
||||
|
-classpath "$CLASSPATH" \ |
||||
|
org.gradle.wrapper.GradleWrapperMain \ |
||||
|
"$@" |
||||
|
|
||||
|
# Use "xargs" to parse quoted args. |
||||
|
# |
||||
|
# With -n1 it outputs one arg per line, with the quotes and backslashes removed. |
||||
|
# |
||||
|
# In Bash we could simply go: |
||||
|
# |
||||
|
# readarray ARGS < <( xargs -n1 <<<"$var" ) && |
||||
|
# set -- "${ARGS[@]}" "$@" |
||||
|
# |
||||
|
# but POSIX shell has neither arrays nor command substitution, so instead we |
||||
|
# post-process each arg (as a line of input to sed) to backslash-escape any |
||||
|
# character that might be a shell metacharacter, then use eval to reverse |
||||
|
# that process (while maintaining the separation between arguments), and wrap |
||||
|
# the whole thing up as a single "set" statement. |
||||
|
# |
||||
|
# This will of course break if any of these variables contains a newline or |
||||
|
# an unmatched quote. |
||||
|
# |
||||
|
|
||||
|
eval "set -- $( |
||||
|
printf '%s\n' "$DEFAULT_JVM_OPTS $JAVA_OPTS $GRADLE_OPTS" | |
||||
|
xargs -n1 | |
||||
|
sed ' s~[^-[:alnum:]+,./:=@_]~\\&~g; ' | |
||||
|
tr '\n' ' ' |
||||
|
)" '"$@"' |
||||
|
|
||||
|
exec "$JAVACMD" "$@" |
||||
@ -0,0 +1,89 @@ |
|||||
|
@rem |
||||
|
@rem Copyright 2015 the original author or authors. |
||||
|
@rem |
||||
|
@rem Licensed under the Apache License, Version 2.0 (the "License"); |
||||
|
@rem you may not use this file except in compliance with the License. |
||||
|
@rem 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, software |
||||
|
@rem distributed under the License is distributed on an "AS IS" BASIS, |
||||
|
@rem WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
||||
|
@rem See the License for the specific language governing permissions and |
||||
|
@rem limitations under the License. |
||||
|
@rem |
||||
|
|
||||
|
@if "%DEBUG%" == "" @echo off |
||||
|
@rem ########################################################################## |
||||
|
@rem |
||||
|
@rem Gradle startup script for Windows |
||||
|
@rem |
||||
|
@rem ########################################################################## |
||||
|
|
||||
|
@rem Set local scope for the variables with windows NT shell |
||||
|
if "%OS%"=="Windows_NT" setlocal |
||||
|
|
||||
|
set DIRNAME=%~dp0 |
||||
|
if "%DIRNAME%" == "" set DIRNAME=. |
||||
|
set APP_BASE_NAME=%~n0 |
||||
|
set APP_HOME=%DIRNAME% |
||||
|
|
||||
|
@rem Resolve any "." and ".." in APP_HOME to make it shorter. |
||||
|
for %%i in ("%APP_HOME%") do set APP_HOME=%%~fi |
||||
|
|
||||
|
@rem Add default JVM options here. You can also use JAVA_OPTS and GRADLE_OPTS to pass JVM options to this script. |
||||
|
set DEFAULT_JVM_OPTS="-Xmx64m" "-Xms64m" |
||||
|
|
||||
|
@rem Find java.exe |
||||
|
if defined JAVA_HOME goto findJavaFromJavaHome |
||||
|
|
||||
|
set JAVA_EXE=java.exe |
||||
|
%JAVA_EXE% -version >NUL 2>&1 |
||||
|
if "%ERRORLEVEL%" == "0" goto execute |
||||
|
|
||||
|
echo. |
||||
|
echo ERROR: JAVA_HOME is not set and no 'java' command could be found in your PATH. |
||||
|
echo. |
||||
|
echo Please set the JAVA_HOME variable in your environment to match the |
||||
|
echo location of your Java installation. |
||||
|
|
||||
|
goto fail |
||||
|
|
||||
|
:findJavaFromJavaHome |
||||
|
set JAVA_HOME=%JAVA_HOME:"=% |
||||
|
set JAVA_EXE=%JAVA_HOME%/bin/java.exe |
||||
|
|
||||
|
if exist "%JAVA_EXE%" goto execute |
||||
|
|
||||
|
echo. |
||||
|
echo ERROR: JAVA_HOME is set to an invalid directory: %JAVA_HOME% |
||||
|
echo. |
||||
|
echo Please set the JAVA_HOME variable in your environment to match the |
||||
|
echo location of your Java installation. |
||||
|
|
||||
|
goto fail |
||||
|
|
||||
|
:execute |
||||
|
@rem Setup the command line |
||||
|
|
||||
|
set CLASSPATH=%APP_HOME%\gradle\wrapper\gradle-wrapper.jar |
||||
|
|
||||
|
|
||||
|
@rem Execute Gradle |
||||
|
"%JAVA_EXE%" %DEFAULT_JVM_OPTS% %JAVA_OPTS% %GRADLE_OPTS% "-Dorg.gradle.appname=%APP_BASE_NAME%" -classpath "%CLASSPATH%" org.gradle.wrapper.GradleWrapperMain %* |
||||
|
|
||||
|
:end |
||||
|
@rem End local scope for the variables with windows NT shell |
||||
|
if "%ERRORLEVEL%"=="0" goto mainEnd |
||||
|
|
||||
|
:fail |
||||
|
rem Set variable GRADLE_EXIT_CONSOLE if you need the _script_ return code instead of |
||||
|
rem the _cmd.exe /c_ return code! |
||||
|
if not "" == "%GRADLE_EXIT_CONSOLE%" exit 1 |
||||
|
exit /b 1 |
||||
|
|
||||
|
:mainEnd |
||||
|
if "%OS%"=="Windows_NT" endlocal |
||||
|
|
||||
|
:omega |
||||
@ -0,0 +1 @@ |
|||||
|
rootProject.name = 'im' |
||||
@ -0,0 +1,13 @@ |
|||||
|
package com.aiprose.im; |
||||
|
|
||||
|
import org.springframework.boot.SpringApplication; |
||||
|
import org.springframework.boot.autoconfigure.SpringBootApplication; |
||||
|
|
||||
|
@SpringBootApplication |
||||
|
public class ImApplication { |
||||
|
|
||||
|
public static void main(String[] args) { |
||||
|
SpringApplication.run(ImApplication.class, args); |
||||
|
} |
||||
|
|
||||
|
} |
||||
@ -0,0 +1,23 @@ |
|||||
|
package com.aiprose.im; |
||||
|
|
||||
|
import lombok.Builder; |
||||
|
import lombok.Data; |
||||
|
import lombok.NoArgsConstructor; |
||||
|
|
||||
|
import java.io.Serializable; |
||||
|
|
||||
|
/** |
||||
|
* @author yanpeng |
||||
|
* @version 1.0 |
||||
|
* @desc TODO |
||||
|
* @company 北京中经网软件有限公司 |
||||
|
* @date 2022/2/25 15:12 |
||||
|
*/ |
||||
|
@Data |
||||
|
public class MsgVo implements Serializable { |
||||
|
private String sendUserId; |
||||
|
private String receiveUserId; |
||||
|
private String message; |
||||
|
// 1在线用户列表 2点对点消息
|
||||
|
private Integer msgType; |
||||
|
} |
||||
@ -0,0 +1,21 @@ |
|||||
|
package com.aiprose.im.config; |
||||
|
|
||||
|
import org.springframework.context.annotation.Bean; |
||||
|
import org.springframework.context.annotation.Configuration; |
||||
|
import org.springframework.web.socket.server.standard.ServerEndpointExporter; |
||||
|
|
||||
|
/** |
||||
|
* @author yanpeng |
||||
|
* @version 1.0 |
||||
|
* @desc TODO |
||||
|
* @company 北京中经网软件有限公司 |
||||
|
* @date 2022/2/25 13:45 |
||||
|
*/ |
||||
|
@Configuration |
||||
|
public class WebSocketConfig { |
||||
|
|
||||
|
@Bean |
||||
|
public ServerEndpointExporter serverEndpointExporter(){ |
||||
|
return new ServerEndpointExporter(); |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,81 @@ |
|||||
|
package com.aiprose.im.socket; |
||||
|
|
||||
|
import com.aiprose.im.MsgVo; |
||||
|
import com.alibaba.fastjson.JSON; |
||||
|
import com.alibaba.fastjson.JSONObject; |
||||
|
import lombok.extern.slf4j.Slf4j; |
||||
|
import org.apache.commons.lang3.StringUtils; |
||||
|
import org.springframework.stereotype.Component; |
||||
|
import org.springframework.web.bind.annotation.PathVariable; |
||||
|
|
||||
|
import javax.websocket.*; |
||||
|
import javax.websocket.server.PathParam; |
||||
|
import javax.websocket.server.ServerEndpoint; |
||||
|
import java.util.Map; |
||||
|
import java.util.Set; |
||||
|
import java.util.concurrent.ConcurrentHashMap; |
||||
|
|
||||
|
/** |
||||
|
* @author yanpeng |
||||
|
* @version 1.0 |
||||
|
* @desc TODO |
||||
|
* @company 北京中经网软件有限公司 |
||||
|
* @date 2022/2/25 13:49 |
||||
|
*/ |
||||
|
@Slf4j |
||||
|
@Component |
||||
|
@ServerEndpoint("/ws/imserver/{user}") |
||||
|
public class WebSocket { |
||||
|
|
||||
|
// TODO 分布式环境放到redis中
|
||||
|
private static Map<String,Session> sessions = new ConcurrentHashMap<>(); |
||||
|
|
||||
|
@OnOpen |
||||
|
public void open(@PathParam("user") String user, Session session){ |
||||
|
sessions.put(user,session); |
||||
|
log.info(user+"连接成功"); |
||||
|
MsgVo msgVo = new MsgVo(); |
||||
|
msgVo.setMsgType(1); |
||||
|
Set<String> strings = sessions.keySet(); |
||||
|
String onlineUsers = JSON.toJSONString(strings); |
||||
|
msgVo.setMessage(onlineUsers); |
||||
|
sendMessage(msgVo); |
||||
|
} |
||||
|
|
||||
|
@OnMessage |
||||
|
public void message(@PathParam("user") String user, String message){ |
||||
|
log.info("收到消息{}",message); |
||||
|
MsgVo msgVo = JSONObject.parseObject(message,MsgVo.class); |
||||
|
if(StringUtils.isBlank(msgVo.getReceiveUserId())){ |
||||
|
return; |
||||
|
} |
||||
|
if(StringUtils.isBlank(msgVo.getMessage())){ |
||||
|
return; |
||||
|
} |
||||
|
msgVo.setMsgType(2); |
||||
|
sendMessage(msgVo); |
||||
|
} |
||||
|
|
||||
|
|
||||
|
@OnClose |
||||
|
public void close(@PathParam("user") String user){ |
||||
|
sessions.remove(user); |
||||
|
log.info(user+"关闭会话"); |
||||
|
} |
||||
|
|
||||
|
@OnError |
||||
|
public void close(Session session,Throwable error){ |
||||
|
log.error(error.getMessage()); |
||||
|
} |
||||
|
|
||||
|
private void sendMessage(MsgVo msgVo){ |
||||
|
// TODO 保存小心
|
||||
|
if(StringUtils.isNotBlank(msgVo.getReceiveUserId())){ // p2p
|
||||
|
sessions.get(msgVo.getReceiveUserId()).getAsyncRemote().sendText(JSON.toJSONString(msgVo)); |
||||
|
}else{ // 群发
|
||||
|
for(Session item : sessions.values()){ |
||||
|
item.getAsyncRemote().sendText(JSON.toJSONString(msgVo)); |
||||
|
} |
||||
|
} |
||||
|
} |
||||
|
} |
||||
@ -0,0 +1,2 @@ |
|||||
|
server: |
||||
|
port: 8999 |
||||
@ -0,0 +1,30 @@ |
|||||
|
<!DOCTYPE html> |
||||
|
<html lang="en"> |
||||
|
<head> |
||||
|
<meta charset="UTF-8"> |
||||
|
<title>Title</title> |
||||
|
</head> |
||||
|
<body> |
||||
|
<button onclick="sendHandler('zhangsan')">给zhangsan发送消息</button> |
||||
|
<button onclick="sendHandler('wangwu')">给wangwu发送消息</button> |
||||
|
<script> |
||||
|
var ws = new WebSocket("ws://192.168.0.70:8999/ws/imserver/lisi") |
||||
|
ws.open = function (msg){ |
||||
|
console.log("open:"+msg) |
||||
|
} |
||||
|
|
||||
|
ws.onmessage = function (msg){ |
||||
|
console.log("message:"+msg) |
||||
|
} |
||||
|
|
||||
|
function sendHandler(userid){ |
||||
|
var param = {} |
||||
|
param.sendUserId = 'lisi' |
||||
|
param.receiveUserId = userid |
||||
|
param.message = '来自 lisi 消息' |
||||
|
param.msgType = 1 |
||||
|
ws.send(JSON.stringify(param)) |
||||
|
} |
||||
|
</script> |
||||
|
</body> |
||||
|
</html> |
||||
@ -0,0 +1,30 @@ |
|||||
|
<!DOCTYPE html> |
||||
|
<html lang="en"> |
||||
|
<head> |
||||
|
<meta charset="UTF-8"> |
||||
|
<title>Title</title> |
||||
|
</head> |
||||
|
<body> |
||||
|
<button onclick="sendHandler('zhangsan')">给zhangsan发送消息</button> |
||||
|
<button onclick="sendHandler('lisi')">给lisi发送消息</button> |
||||
|
<script> |
||||
|
var ws = new WebSocket("ws://192.168.0.70:8999/ws/imserver/wangwu") |
||||
|
ws.open = function (msg){ |
||||
|
console.log("open:"+msg) |
||||
|
} |
||||
|
|
||||
|
ws.onmessage = function (msg){ |
||||
|
console.log("message:"+msg) |
||||
|
} |
||||
|
|
||||
|
function sendHandler(userid){ |
||||
|
var param = {} |
||||
|
param.sendUserId = 'wangwu' |
||||
|
param.receiveUserId = userid |
||||
|
param.message = '来自 wangwu 消息' |
||||
|
param.msgType = 1 |
||||
|
ws.send(JSON.stringify(param)) |
||||
|
} |
||||
|
</script> |
||||
|
</body> |
||||
|
</html> |
||||
@ -0,0 +1,30 @@ |
|||||
|
<!DOCTYPE html> |
||||
|
<html lang="en"> |
||||
|
<head> |
||||
|
<meta charset="UTF-8"> |
||||
|
<title>Title</title> |
||||
|
</head> |
||||
|
<body> |
||||
|
<button onclick="sendHandler('lisi')">给lisi发送消息</button> |
||||
|
<button onclick="sendHandler('wangwu')">给wangwu发送消息</button> |
||||
|
<script> |
||||
|
var ws = new WebSocket("ws://192.168.0.70:8999/ws/imserver/zhangsan") |
||||
|
ws.open = function (msg){ |
||||
|
console.log("open:"+msg) |
||||
|
} |
||||
|
|
||||
|
ws.onmessage = function (msg){ |
||||
|
console.log("message:"+msg) |
||||
|
} |
||||
|
|
||||
|
function sendHandler(userid){ |
||||
|
var param = {} |
||||
|
param.sendUserId = 'zhangsan' |
||||
|
param.receiveUserId = userid |
||||
|
param.message = '来自 zhangsan 消息' |
||||
|
param.msgType = 1 |
||||
|
ws.send(JSON.stringify(param)) |
||||
|
} |
||||
|
</script> |
||||
|
</body> |
||||
|
</html> |
||||
@ -0,0 +1,13 @@ |
|||||
|
package com.aiprose.im; |
||||
|
|
||||
|
import org.junit.jupiter.api.Test; |
||||
|
import org.springframework.boot.test.context.SpringBootTest; |
||||
|
|
||||
|
@SpringBootTest |
||||
|
class ImApplicationTests { |
||||
|
|
||||
|
@Test |
||||
|
void contextLoads() { |
||||
|
} |
||||
|
|
||||
|
} |
||||
Loading…
Reference in new issue