Browse Source

认证可以直传userId

master
zy_Java 5 years ago
parent
commit
e4fd56d893
  1. 8
      ccmq/src/main/java/com/ccsens/ccmq/lowlevel/message/MessageHandler.java
  2. 1
      ccmq/src/main/java/com/ccsens/ccmq/lowlevel/message/client/AuthMessage.java
  3. 26
      ccmq/src/main/java/wiki/tall/ccmq/common/util/ImgUtil.java
  4. 2
      ccmq/src/main/resources/application-prod.properties
  5. 2
      ccmq/src/main/resources/application.properties
  6. 6
      eureka/pom.xml

8
ccmq/src/main/java/com/ccsens/ccmq/lowlevel/message/MessageHandler.java

@ -258,8 +258,12 @@ public class MessageHandler {
boolean authSuccess = false;
AuthMessage inSysData = JacksonUtil.jsonToBean(data, AuthMessage.class);
if(null != inSysData.getData()){
if(StrUtil.isNotEmpty(inSysData.getData().getToken())) {
String userId = getUserService().getUserIdByToken(inSysData.getData().getToken());
if(StrUtil.isNotEmpty(inSysData.getData().getToken()) || StrUtil.isNotEmpty(inSysData.getData().getUserId())) {
String userId = inSysData.getData().getUserId();
System.out.println(userId);
if(StrUtil.isEmpty(userId)){
userId = getUserService().getUserIdByToken(inSysData.getData().getToken());
}
if(StrUtil.isNotEmpty(userId)){
ChannelManager.authChannel(ChannelManager.getCurrentChannel(),userId,inSysData.getData().getMajor(),inSysData.getData().getMinor(), inSysData.getMessage());
onClientOnLine(MessageConstant.DomainType.User,userId);

1
ccmq/src/main/java/com/ccsens/ccmq/lowlevel/message/client/AuthMessage.java

@ -16,6 +16,7 @@ public class AuthMessage extends ServerMessage {
@Getter
public static class Data{
private String token;
private String userId;
// 主版本号
private int major;
// 此版本号

26
ccmq/src/main/java/wiki/tall/ccmq/common/util/ImgUtil.java

@ -1,13 +1,13 @@
package wiki.tall.ccmq.common.util;
import sun.font.FontDesignMetrics;
import java.awt.*;
public class ImgUtil {
public static int getStringWidth(String text,Font f){
FontMetrics fm = FontDesignMetrics.getMetrics(f);
int w = fm.stringWidth(text);
return w;
}
}
//package wiki.tall.ccmq.common.util;
//
//import sun.font.FontDesignMetrics;
//
//import java.awt.*;
//
//public class ImgUtil {
// public static int getStringWidth(String text,Font f){
// FontMetrics fm = FontDesignMetrics.getMetrics(f);
// int w = fm.stringWidth(text);
// return w;
// }
//}

2
ccmq/src/main/resources/application-prod.properties

@ -14,7 +14,7 @@ spring.servlet.multipart.max-request-size=100MB
spring.redis.database=0
spring.redis.host=127.0.0.1
spring.redis.port=6379
spring.redis.password=
spring.redis.password=areowqr!@43ef
spring.redis.timeout=1000ms
spring.redis.jedis.pool.max-active=200
spring.redis.jedis.pool.max-wait=-1ms

2
ccmq/src/main/resources/application.properties

@ -1,5 +1,5 @@
# 选择开发环境{dev|test|prod}
spring.profiles.active=prod
spring.profiles.active=test
# 设置应用名
spring.application.name=tall-message

6
eureka/pom.xml

@ -28,12 +28,6 @@
<version>2.1.6</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>de.codecentric</groupId>
<artifactId>spring-boot-admin-server</artifactId>
<version>2.1.6</version>
<scope>compile</scope>
</dependency>
</dependencies>

Loading…
Cancel
Save