backend/java-mall
6
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

sns user websocke 去掉缓存。

Browse Source
This commit is contained in:
Jack 2025-09-11 23:53:43 +08:00
parent c7d107d951
commit 90b9f793a4
2 changed files with 19 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
mall-sns/src/main/java/com/suisung/mall/sns/service/impl/SnsUserMessageServiceImpl.java
View File

@ -44,7 +44,7 @@ import org.springframework.transaction.annotation.Transactional;
import java.io.UnsupportedEncodingException; import java.io.UnsupportedEncodingException;
import java.net.URLEncoder; import java.net.URLEncoder;
import java.util.*; import java.util.*;
import java.util.concurrent.TimeUnit; //import java.util.concurrent.TimeUnit;
import java.util.stream.Collectors; import java.util.stream.Collectors;
@ -74,8 +74,8 @@ public class SnsUserMessageServiceImpl extends BaseServiceImpl<SnsUserMessageMap
private SnsUserFriendService snsUserFriendService; private SnsUserFriendService snsUserFriendService;
@Autowired @Autowired
private ImService imService; private ImService imService;
@Autowired // @Autowired
private RedisTemplate<String, Object> redisTemplate; // private RedisTemplate<String, Object> redisTemplate;
@Override @Override
public Map getMsgCount() { public Map getMsgCount() {
@ -87,13 +87,13 @@ public class SnsUserMessageServiceImpl extends BaseServiceImpl<SnsUserMessageMap
} }
Integer userId = user.getId(); Integer userId = user.getId();
String cacheKey = "sns:user:message:unread:" + userId; // String cacheKey = "sns:user:message:unread:" + userId;
// 尝试从Redis缓存中获取数据 // // 尝试从Redis缓存中获取数据
Map cachedResult = (Map) redisTemplate.opsForValue().get(cacheKey); // Map cachedResult = (Map) redisTemplate.opsForValue().get(cacheKey);
if (cachedResult != null) { // if (cachedResult != null) {
return cachedResult; // return cachedResult;
} // }
QueryWrapper<SnsUserMessage> queryWrapper = new QueryWrapper<>(); QueryWrapper<SnsUserMessage> queryWrapper = new QueryWrapper<>();
queryWrapper.eq("user_id", userId).eq("message_kind", 2).eq("message_is_read", 0); queryWrapper.eq("user_id", userId).eq("message_kind", 2).eq("message_is_read", 0);
@ -123,8 +123,8 @@ public class SnsUserMessageServiceImpl extends BaseServiceImpl<SnsUserMessageMap
} }
} }
// 将结果缓存到Redis，缓存10秒 // // 将结果缓存到Redis，缓存10秒
redisTemplate.opsForValue().set(cacheKey, rs, 45, TimeUnit.SECONDS); // redisTemplate.opsForValue().set(cacheKey, rs, 45, TimeUnit.SECONDS);
return rs; return rs;
} }

16
pom.xml
View File

@ -558,20 +558,22 @@
<!--定义基础镜像--> <!--定义基础镜像-->
<!-- <baseImage>java:8</baseImage>--> <!-- <baseImage>java:8</baseImage>-->
<baseImage>openjdk:8-jre</baseImage> <baseImage>openjdk:8-jre</baseImage>
<!-- <baseImage>openjdk:8-jre-slim</baseImage>-->
<!--定义容器启动命令，注意不能换行--> <!--定义容器启动命令，注意不能换行-->
<entryPoint>["java", "-Dnacos.naming.cache.dir=/tmp/nacos/naming/", "-jar", "-Xms256m", "-Xmx512m", "-XX:MetaspaceSize=256m", "-XX:MaxMetaspaceSize=256m", "-XX:+UseContainerSupport", "-XX:MaxRAMPercentage=60.0", "-XX:+UseSerialGC", "-XX:MinHeapFreeRatio=40", "-XX:MaxHeapFreeRatio=60", "-XX:+PrintGCDetails", "-XX:+PrintGCDateStamps", "-Xloggc:./gc.log", "-XX:+UseGCLogFileRotation", "-XX:NumberOfGCLogFiles=5", "-XX:GCLogFileSize=10M", "-Dspring.profiles.active=${spring.profile}", "-Duser.timezone=Asia/Shanghai", "/${project.build.finalName}.jar"] <!-- <entryPoint>["java", "-jar", "-Xms256m", "-Xmx512m", "-XX:MetaspaceSize=256m", "-XX:MaxMetaspaceSize=256m", "-XX:+UseContainerSupport", "-XX:MaxRAMPercentage=60.0", "-XX:+UseSerialGC", "-XX:MinHeapFreeRatio=40", "-XX:MaxHeapFreeRatio=60", "-XX:+PrintGCDetails", "-XX:+PrintGCDateStamps", "-Xloggc:./gc.log", "-XX:+UseGCLogFileRotation", "-XX:NumberOfGCLogFiles=5", "-XX:GCLogFileSize=10M", "-Dspring.profiles.active=${spring.profile}", "-Duser.timezone=Asia/Shanghai", "/${project.build.finalName}.jar"]-->
<!-- </entryPoint>-->
<!--定义容器启动命令，注意不能换行-->
<entryPoint>["sh", "-c", "mkdir -p /tmp /app/temp /root/nacos/naming/public &amp;&amp; chmod -R 777 /tmp /app/temp /root/nacos &amp;&amp; java -Djava.io.tmpdir=/app/temp -Dnacos.naming.cache.dir=/root/nacos/naming -jar -Xms256m -Xmx512m -XX:MetaspaceSize=256m -XX:MaxMetaspaceSize=256m -XX:+UseContainerSupport -XX:MaxRAMPercentage=60.0 -XX:+UseSerialGC -XX:MinHeapFreeRatio=40 -XX:MaxHeapFreeRatio=60 -XX:+PrintGCDetails -XX:+PrintGCDateStamps -Xloggc:./gc.log -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=5 -XX:GCLogFileSize=10M -Dspring.profiles.active=${spring.profile} -Duser.timezone=Asia/Shanghai /${project.build.finalName}.jar"]
</entryPoint> </entryPoint>
<!--推送镜像仓库校验安全证书，无安全证书无法推送--> <!--推送镜像仓库校验安全证书，无安全证书无法推送-->
<dockerCertPath>${docker.ca}</dockerCertPath> <dockerCertPath>${docker.ca}</dockerCertPath>
<!-- 添加清理命令来过滤无用文件 --> <!-- 添加清理命令来过滤无用文件 -->
<runs> <!-- <runs>-->
<!-- 合并所有清理命令到单个RUN指令 --> <!-- &lt;!&ndash; 合并所有清理命令到单个RUN指令 &ndash;&gt;-->
<run>rm -rf /var/cache/apk/* &amp;&amp; rm -rf /root/.m2 &amp;&amp; find / -name "*.log" -type f -delete 2&gt;/dev/null || true &amp;&amp; find / -name "*test*" -type f -delete 2&gt;/dev/null || true &amp;&amp; find / -name "*.md" -type f -delete 2&gt;/dev/null || true &amp;&amp; rm -rf /tmp/* /var/tmp/* &amp;&amp; rm -rf /usr/share/doc/* /usr/share/man/* /usr/share/info/* &amp;&amp; rm -rf /var/cache/yum/* /var/cache/dnf/* 2&gt;/dev/null || true &amp;&amp; rm -rf /tmp/*.tar.gz /tmp/*.zip /app/*.tar.gz 2&gt;/dev/null || true &amp;&amp; apk del --purge vim curl wget tar gzip 2&gt;/dev/null || true &amp;&amp; rm -rf /root/.java /tmp/hsperfdata_* 2&gt;/dev/null || true &amp;&amp; find / -type d -empty -delete 2&gt;/dev/null || true</run> <!-- <run>rm -rf /var/cache/apk/* &amp;&amp; rm -rf /root/.m2 &amp;&amp; find / -name "*.log" -type f -delete 2&gt;/dev/null || true &amp;&amp; find / -name "*test*" -type f -delete 2&gt;/dev/null || true &amp;&amp; find / -name "*.md" -type f -delete 2&gt;/dev/null || true &amp;&amp; rm -rf /tmp/* /var/tmp/* &amp;&amp; rm -rf /usr/share/doc/* /usr/share/man/* /usr/share/info/* &amp;&amp; rm -rf /var/cache/yum/* /var/cache/dnf/* 2&gt;/dev/null || true &amp;&amp; rm -rf /tmp/*.tar.gz /tmp/*.zip /app/*.tar.gz 2&gt;/dev/null || true &amp;&amp; apk del &#45;&#45;purge vim curl wget tar gzip 2&gt;/dev/null || true &amp;&amp; rm -rf /root/.java /tmp/hsperfdata_* 2&gt;/dev/null || true &amp;&amp; find / -type d -empty -delete 2&gt;/dev/null || true</run>-->
</runs> <!-- </runs>-->
<resources> <resources>
<resource> <resource>
@ -583,8 +585,6 @@
</configuration> </configuration>
</plugin> </plugin>
</plugins> </plugins>
</pluginManagement> </pluginManagement>
</build> </build>