SpringBoot+WebSocket+Session共享

前言

WebSocket协议是基于TCP的一种新的网络协议。它实现了浏览器与服务器全双工(full-duplex)通信——允许服务器主动发送信息给客户端

一、为什么需要WebSocket

HTTP 是基于请求响应式的，即通信只能由客户端发起，服务端做出响应，无状态，无连接。

无状态： 每次连接只处理一个请求，请求结束后断开连接。

无连接： 对于事务处理没有记忆能力，服务器不知道客户端是什么状态。

通过HTTP实现即时通讯，只能是页面轮询向服务器发出请求，服务器返回查询结果。轮询的效率低，非常浪费资源，因为必须不停连接，或者 HTTP 连接始终打开。

WebSocket的最大特点就是，服务器可以主动向客户端推送信息，客户端也可以主动向服务器发送信息，是真正的双向平等对话。

WebSocket特点

  • （1）建立在 TCP 协议之上，服务器端的实现比较容易。

  • （2）与 HTTP 协议有着良好的兼容性。默认端口也是80和443，并且握手阶段采用 HTTP 协议，因此握手时不容易屏蔽，能通过各种
    HTTP 代理服务器。

  • （3）数据格式比较轻量，性能开销小，通信高效。

  • （4）可以发送文本，也可以发送二进制数据。

  • （5）没有同源限制，客户端可以与任意服务器通信。

  • （6）协议标识符是ws（如果加密，则为wss），服务器网址就是 URL。

二、SpringBoot整合WebSocket

1.maven依赖

		<dependency>  <groupId>org.springframework.boot</groupId>  <artifactId>spring-boot-starter-websocket</artifactId>  </dependency>

2.WebSocketConfig

启用WebSocket的支持

@Configuration
public class WebSocketConfig {/*** 自动注册使用@ServerEndpoint注解声明的websocket endpoint* 2022/2/14* @return*/@Beanpublic ServerEndpointExporter serverEndpointExporter() {return new ServerEndpointExporter();}
}

3.WebSocketServer

因为WebSocket是类似客户端服务端的形式(采用ws协议)，那么这里的WebSocketServer其实就相当于一个ws协议的Controller

直接@ServerEndpoint(“/websocket/{userId}”) 、@Component启用即可，然后在里面实现@OnOpen开启连接，@onClose关闭连接，@onMessage接收消息等方法。

集群版（多个ws节点）还需要借助mysql或者redis等进行处理，改造对应的sendMessage方法即可。

import java.io.IOException;
import java.util.concurrent.ConcurrentHashMap;
import javax.websocket.OnClose;
import javax.websocket.OnError;
import javax.websocket.OnMessage;
import javax.websocket.OnOpen;
import javax.websocket.Session;
import javax.websocket.server.PathParam;
import javax.websocket.server.ServerEndpoint;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import org.apache.commons.lang.StringUtils;
import org.springframework.stereotype.Component;
import cn.hutool.log.Log;
import cn.hutool.log.LogFactory;@ServerEndpoint("/imserver/{userId}")
@Component
public class WebSocketServer {static Log log=LogFactory.get(WebSocketServer.class);/**静态变量，用来记录当前在线连接数。应该把它设计成线程安全的。*/private static int onlineCount = 0;/**concurrent包的线程安全Set，用来存放每个客户端对应的MyWebSocket对象。*/private static ConcurrentHashMap<String,WebSocketServer> webSocketMap = new ConcurrentHashMap<>();/**与某个客户端的连接会话，需要通过它来给客户端发送数据*/private Session session;/**接收userId*/private String userId="";/*** 连接建立成功调用的方法*/@OnOpenpublic void onOpen(Session session,@PathParam("userId") String userId) {this.session = session;this.userId=userId;if(webSocketMap.containsKey(userId)){webSocketMap.remove(userId);webSocketMap.put(userId,this);//加入set中}else{webSocketMap.put(userId,this);//加入set中addOnlineCount();//在线数加1}log.info("用户连接:"+userId+",当前在线人数为:" + getOnlineCount());try {sendMessage("连接成功");} catch (IOException e) {log.error("用户:"+userId+",网络异常!!!!!!");}}/*** 连接关闭调用的方法*/@OnClosepublic void onClose() {if(webSocketMap.containsKey(userId)){webSocketMap.remove(userId);//从set中删除subOnlineCount();}log.info("用户退出:"+userId+",当前在线人数为:" + getOnlineCount());}/*** 收到客户端消息后调用的方法** @param message 客户端发送过来的消息*/@OnMessagepublic void onMessage(String message, Session session) {log.info("用户消息:"+userId+",报文:"+message);//可以群发消息//消息保存到数据库、redisif(StringUtils.isNotBlank(message)){try {//解析发送的报文JSONObject jsonObject = JSON.parseObject(message);//追加发送人(防止串改)jsonObject.put("fromUserId",this.userId);String toUserId=jsonObject.getString("toUserId");//传送给对应toUserId用户的websocketif(StringUtils.isNotBlank(toUserId)&&webSocketMap.containsKey(toUserId)){webSocketMap.get(toUserId).sendMessage(jsonObject.toJSONString());}else{log.error("请求的userId:"+toUserId+"不在该服务器上");//否则不在这个服务器上，发送到mysql或者redis}}catch (Exception e){e.printStackTrace();}}}/**** @param session* @param error*/@OnErrorpublic void onError(Session session, Throwable error) {log.error("用户错误:"+this.userId+",原因:"+error.getMessage());error.printStackTrace();}/*** 实现服务器主动推送*/public void sendMessage(String message) throws IOException {this.session.getBasicRemote().sendText(message);}/*** 发送自定义消息* */public static void sendInfo(String message,@PathParam("userId") String userId) throws IOException {log.info("发送消息到:"+userId+"，报文:"+message);if(StringUtils.isNotBlank(userId)&&webSocketMap.containsKey(userId)){webSocketMap.get(userId).sendMessage(message);}else{log.error("用户"+userId+",不在线！");}}public static synchronized int getOnlineCount() {return onlineCount;}public static synchronized void addOnlineCount() {WebSocketServer.onlineCount++;}public static synchronized void subOnlineCount() {WebSocketServer.onlineCount--;}
}

4.集群版

在使用websocket的时候会面对session共享的问题

在这里我们通过Redis的监听订阅模式来实现session共享，当有连接加入时，将连接发送到队列中然后向订阅该队列的服务下发，由存储该连接的服务进行逻辑处理

session共享的业务逻辑如下图所示
在这里插入图片描述

4.1 Redis发布订阅模式实现

前言

Redis可以通过发布订阅模式、轮询机制实现消息队列。

由于没有消息持久化与 ACK 的保证，所以，Redis 的发布订阅功能并不可靠。这也就导致了它的应用场景很有限，建议用于实时与可靠性要求不高的场景。

一、Redis发布订阅

​​​​​​1. Redis发布订阅模式实现原理

服务器中维护着一个pubsub_channels字典，所有的频道和订阅关系都存储在这里。字典的键为频道的名称，而值为订阅频道的客户端链表。

1> 当有新的客户端订阅某个频道时，会发生两种情况中的一种：

（1）如果频道已经存在，则新的客户端会添加到pubsub_channels对应频道的链表末尾

（2）如果频道原本不存在，则会为频道创建一个键，该客户端成为链表的第一个元素

2> 当一个客户端退订一个频道的时候：

pubsub_channels对应键的链表会删除该客户端

3> 发送信息

服务器会遍历pubsub_channels中对应键的链表，向每一个客户端发送信息

服务器还维护着一个pubsub_patterns链表，链表的pattern属性记录了被订阅的模式，而client属性记录了订阅模式的客户端

  1. 当有新的客户端订阅某个模式的时，会进行如下步骤：

（1）创建一个链表节点，pattern属性记录订阅的模式，client记录订阅模式的客户端

（2）将这个链表节点添加到pubsub_patterns链表中

  1. 当一个客户端退订某一个模式的时候：

服务器遍历pubsob_patterns找到对应的pattern同时也是对应该client客户端的节点，将改节点删除

  1. 发送信息

服务器遍历pubsub_channels，查找与channels频道相匹配的模式麻将消息发送给订阅了这些模式的客户端。

2.引入依赖
        <dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId></dependency>
3.redis配置
public class RedisConfig {//Key的过期时间private Duration timeToLive = Duration.ofDays(1);/*** redis模板，存储关键字是字符串，值jackson2JsonRedisSerializer是序列化后的值** @param* @return org.springframework.data.redis.core.RedisTemplate*/@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory connectionFactory) {RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();redisTemplate.setConnectionFactory(connectionFactory);//使用Jackson2JsonRedisSerializer来序列化和反序列化redis的value值（默认使用JDK的序列化方式）Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);ObjectMapper objectMapper = new ObjectMapper();objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);jackson2JsonRedisSerializer.setObjectMapper(objectMapper);//使用StringRedisSerializer来序列化和反序列化redis的key值RedisSerializer redisSerializer = new StringRedisSerializer();//keyredisTemplate.setKeySerializer(redisSerializer);redisTemplate.setHashKeySerializer(redisSerializer);//valueredisTemplate.setValueSerializer(jackson2JsonRedisSerializer);redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);redisTemplate.afterPropertiesSet();return redisTemplate;}@Beanpublic RedisCacheConfiguration redisCacheConfiguration() {return RedisCacheConfiguration.defaultCacheConfig().entryTtl(this.timeToLive).			//Key过期时间 1天serializeKeysWith(RedisSerializationContext.SerializationPair.fromSerializer(new StringRedisSerializer())).serializeValuesWith(RedisSerializationContext.SerializationPair.fromSerializer(new GenericJackson2JsonRedisSerializer()));}
}
4.redis监听
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.listener.PatternTopic;
import org.springframework.data.redis.listener.RedisMessageListenerContainer;
import org.springframework.data.redis.listener.adapter.MessageListenerAdapter;import java.util.concurrent.CountDownLatch;@Configuration
public class RedisMessageListener {/*** 创建连接工厂** @param connectionFactory* @param listenerAdapter* @return*/@Beanpublic RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,MessageListenerAdapter listenerAdapter,MessageListenerAdapter listenerAdapterWang,MessageListenerAdapter listenerAdapterTest2) {RedisMessageListenerContainer container = new RedisMessageListenerContainer();container.setConnectionFactory(connectionFactory);//（不同的监听器可以收到同一个频道的信息）接受消息的频道container.addMessageListener(listenerAdapter, new PatternTopic("phone"));container.addMessageListener(listenerAdapterWang, new PatternTopic("phone"));container.addMessageListener(listenerAdapterTest2, new PatternTopic("phoneTest2"));return container;}/*** 绑定消息监听者和接收监听的方法** @param receiver* @return*/@Beanpublic MessageListenerAdapter listenerAdapter(ReceiverRedisMessage receiver) {return new MessageListenerAdapter(receiver, "receiveMessage");}@Beanpublic MessageListenerAdapter listenerAdapterWang(ReceiverRedisMessage receiver) {return new MessageListenerAdapter(receiver, "receiveMessageWang");}/*** 绑定消息监听者和接收监听的方法** @param receiver* @return*/@Beanpublic MessageListenerAdapter listenerAdapterTest2(ReceiverRedisMessage receiver) {return new MessageListenerAdapter(receiver, "receiveMessage2");}/*** 注册订阅者** @param latch* @return*/@BeanReceiverRedisMessage receiver(CountDownLatch latch) {return new ReceiverRedisMessage(latch);}/*** 计数器，用来控制线程** @return*/@Beanpublic CountDownLatch latch() {return new CountDownLatch(1);//指定了计数的次数 1}
}
5.redis消息接收类
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;import java.util.concurrent.CountDownLatch;public class ReceiverRedisMessage {private CountDownLatch latch;@Autowiredpublic ReceiverRedisMessage(CountDownLatch latch) {this.latch = latch;}/*** 队列消息接收方法** @param jsonMsg*/public void receiveMessage(String jsonMsg) {log.info("[开始消费REDIS消息队列phone数据...]");try {System.out.println(jsonMsg);log.info("[消费REDIS消息队列phone数据成功.]");} catch (Exception e) {log.error("[消费REDIS消息队列phone数据失败，失败信息:{}]", e.getMessage());}latch.countDown();}public void receiveMessageWang(String jsonMsg) {log.info("[开始消费REDIS消息队列phone数据...]");try {System.out.println(jsonMsg);log.info("[消费REDIS消息队列phone数据成功.]");} catch (Exception e) {log.error("[消费REDIS消息队列phone数据失败，失败信息:{}]", e.getMessage());}latch.countDown();}/*** 队列消息接收方法** @param jsonMsg*/public void receiveMessage2(String jsonMsg) {log.info("[开始消费REDIS消息队列phoneTest2数据...]");try {System.out.println(jsonMsg);/***  此处执行自己代码逻辑 操作数据库等*/log.info("[消费REDIS消息队列phoneTest2数据成功.]");} catch (Exception e) {log.error("[消费REDIS消息队列phoneTest2数据失败，失败信息:{}]", e.getMessage());}latch.countDown();}}
6.代码测试
  public void redisTest() {//这个是测试同一个频道，不同的订阅者收到相同的信息，“phone”也就是topic也可以理解为频道redisTemplate.convertAndSend("phone", "223333");//这个phoneTest2是另外的一个频道//  redisTemplate.convertAndSend("phoneTest2", "34555665");}

二、Redis轮询机制

1.原理

Redis的列表类型键可以用来实现队列，并且支持阻塞式读取，可以实现一个高性能的优先队列, 在Redis中，List类型是按照插入顺序排序的字符串链表。和数据结构中的普通链表一样，我们可以在其头部(left)和尾部(right)添加新的元素。在插入时，如果该键并不存在，Redis将为该键创建一个新的链表。与此相反，如果链表中所有的元素均被移除，那么该键也将会被从数据库中删除。List中可以包含的最大元素数量是4294967295。从元素插入和删除的效率视角来看，如果我们是在链表的两头插入或删除元素，这将会是非常高效的操作，即使链表中已经存储了百万条记录，该操作也可以在常量时间内完成。

2.生产者
  public R saveUserTicket(String phoneNum) {redisTemplate.opsForList().leftPush("ticket:Data", phoneNum);return R.ok();}
3.消费者
 @Scheduled(fixedRate = 1)public synchronized void consumer() {String message = redisTemplate.opsForList().rightPop("ticket:Data", 5, TimeUnit.SECONDS);if (!StringUtils.isEmpty(message)){//数据库操作}}
4.优化

如上述代码，如果此时队列为空，消费者依然会频繁拉取数据，造成CPU空转，不仅占用CPU资源还对Redis造成压力。因此当队列为空时我们可以休眠一段时间，再进行拉取。

实现如下

     @Scheduled(fixedRate = 1)public synchronized void consumer() throws InterruptedException {long a = redisTemplate.opsForList().size("ticket:Data");if (a == 0) {TimeUnit.SECONDS.sleep(1);//等待时间}String message = redisTemplate.opsForList().rightPop("ticket:Data", 5, TimeUnit.SECONDS);if (!StringUtils.isEmpty(message)){//数据库操作}

Redis发布订阅模式实现原理

前言

发布订阅系统在我们日常的工作中经常会使用到，这种场景大部分情况我们都是使用消息队列，常用的消息队列有 Kafka，RocketMQ，RabbitMQ，每一种消息队列都有其特性，很多时候我们可能不需要独立部署相应的消息队列，只是简单的使用，而且数据量也不会太大，这种情况下，我们就可以使用 Redis 的 Pub/Sub 模型。

一、Redis发布订阅

Redis 的发布订阅功能主要由 PUBLISH，SUBSCRIBE，PSUBSCRIBE 命令组成，一个或者多个客户端订阅某个或者多个频道，当其他客户端向该频道发送消息的时候，订阅了该频道的客户端都会收到对应的消息。

二、发布订阅模式的基本命令

Psubscribe 命令订阅一个或多个符合给定模式的频道。每个模式以 * 作为匹配符，比如 it* 匹配所有以 it 开头的频道( it.news 、 it.blog 、 it.tweets )

Psubscribe 命令基本语法如下：

PSUBSCRIBE pattern [pattern …]

Redis Pubsub 命令用于查看订阅与发布系统状态，它由数个不同格式的子命令组成。

PUBSUB [argument [argument …]]

Publish 命令用于将信息发送到指定的频道。

Publish 命令基本语法如下：

PUBLISH channel message

Punsubscribe 命令用于退订所有给定模式的频道。

Punsubscribe 命令基本语法如下：

PUNSUBSCRIBE [pattern [pattern …]]

Subscribe 命令用于订阅给定的一个或多个频道的信息。

Subscribe 命令基本语法如下：

SUBSCRIBE channel [channel …]

Unsubscribe 命令用于退订给定的一个或多个频道的信息。

Unsubscribe 命令基本语法如下：

UNSUBSCRIBE channel [channel …]

三、发布订阅模式的实现原理

Redis通过PUBLISH、SUBSCRIBE和PSUBSCRIBE等命令实现了发布和订阅功能。

  • 通过SUBSCRIBE命令订阅某个频道后，redis-server里面维护了一个字典，字典的键就是一个个channel，而字典的值则是一个链表，链表中保存了所有订阅这个channel的客户端。SUBSCRIBE命令的关键，就是将客户端添加到指定channel的订阅链表中。
  • 通过PUBLISH命令向订阅者发送信息，redis-server会使用给定的频道作为键，在他所维护的channel字典中查找记录订阅该频道的所有客户端的链表，通过遍历这个链表，来将信息发布给所有的订阅者
Pub/Sub 底层存储结构

订阅 Channel

在 Redis 的底层结构中，客户端和频道的订阅关系是通过一个字典加链表的结构保存的，形式如下：

在这里插入图片描述

在 Redis 的底层结构中，Redis 服务器结构体中定义了一个 pubsub_channels 字典

struct redisServer {//用于保存所有频道的订阅关系dict *pubsub_channels}

在这个字典中，key 代表的是频道名称，value 是一个链表，这个链表里面存放的是所有订阅这个频道的客户端。

所以当有客户端执行订阅频道的动作的时候，服务器就会将客户端与被订阅的频道在 pubsub_channels 字典中进行关联。

这个时候有两种情况：

  • 该渠道是首次被订阅：首次被订阅说明在字典中并不存在该渠道的信息，那么程序首先要创建一个对应的 key，并且要赋值一个空链表，然后将对应的客户端加入到链表中。此时链表只有一个元素。

  • 该渠道已经被其他客户端订阅过：这个时候就直接将对应的客户端信息添加到链表的末尾就好了。

比如，如果有一个新的客户端 Client 08 要订阅 run 渠道，那么上图就会变成
在这里插入图片描述

如果 Client 08 要订阅一个新的渠道 new_sport ，那么就会变成

在这里插入图片描述

取消订阅

上面介绍的是单个 Channel 的订阅，相反的如果一个客户端要取消订阅相关 Channel，则无非是找到对应的 Channel 的链表，从中删除对应的客户端，如果该客户端已经是最后一个了，则将对应 Channel 也删除。

模式订阅结构

模式渠道的订阅与单个渠道的订阅类似，不过服务器是将所有模式的订阅关系都保存在服务器状态的pubsub_patterns 属性里面。


struct redisServer{//保存所有模式订阅关系list *pubsub_patterns;}

与订阅单个 Channel 不同的是，pubsub_patterns 属性是一个链表，不是字典。节点的结构如下：


struct pubsubPattern{//订阅模式的客户端redisClient *client;//被订阅的模式robj *pattern;} pubsubPattern;

其实 client 属性是用来存放对应客户端信息，pattern 是用来存放客户端对应的匹配模式。

所以对应上面的 Client-06 模式匹配的结构存储如下
在这里插入图片描述

在pubsub_patterns链表中有一个节点，对应的客户端是 Client-06，对应的匹配模式是run*。

订阅模式

当某个客户端通过命令psubscribe 订阅对应模式的 Channel 时候，服务器会创建一个节点，并将 Client 属性设置为对应的客户端，pattern 属性设置成对应的模式规则，然后添加到链表尾部。

创建新节点；

给节点的属性赋值；

将节点添加到链表的尾部；

退订模式

退订模式的命令是punsubscribe，客户端使用这个命令来退订一个或者多个模式 Channel。服务器接收到该命令后，会遍历pubsub_patterns链表，将匹配到的 client 和 pattern 属性的节点给删掉。这里需要判断 client 属性和 pattern 属性都合法的时候再进行删除。

遍历所有的节点，当匹配到相同 client 属性和 pattern 属性的时候就进行节点删除。

发布消息

当一个客户端执行了publish channelName message 命令的时候，服务器会从pubsub_channels和pubsub_patterns 两个结构中找到符合channelName 的所有 Channel，进行消息的发送。在 pubsub_channels 中只要找到对应的 Channel 的 key 然后向对应的 value 链表中的客户端发送消息。

4.2 队列消息推送

    @OnMessagepublic void onMessage(Session session, String message) throws IOException, ParseException {//业务逻辑处理//向所有用户广播redisUtil.convertSend("topic", message);}

4.3 队列消息接收

/*** 队列消息接收方法* 2022/2/21*/public void receiveMessage(String message) {log.info("[开始消费REDIS消息队列topic数据...]");try {//业务逻辑处理webSocketServer.sendMessageForProject(message);log.info("[消费REDIS消息队列topic数据成功.]");} catch (Exception e) {log.error("[消费REDIS消息队列topic数据失败，失败信息:{}]", e.getMessage());}latch.countDown();}

参考来源：「人苼若只茹初見」
原文链接： https://blog.csdn.net/printf88/article/details/123685995

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/9245.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

kafka入门，节点服役和退役（新增节点和删除节点）(十二)

kafka入门，节点服役和退役（新增节点和删除节点）(十二)

1、节点服役 1、克隆准备其中一台节点 2、如果新节点的kafka有被log和datas文件夹要删除 3、修改/etc/hosts 配置新节点映射 1.1 执行负载均衡操作 vim topics-to-move.json{"topic": "主题名称"} {"topics": [{"topic": "fi…
阅读更多...
web测试需要注意几个非常重要的测试点

web测试需要注意几个非常重要的测试点

微软语言标准&#xff1a; 全角字符和半角字符都要使用一个空格分开 英文和数字直接要有空页面分辨率&#xff1a; 通常是计算机的默认分辨率&#xff0c;但是还是会有一些老式电脑存在1024*768的情况 浏览器的兼容性&#xff1a; 目前市场上的主流浏览器&#xff1a;IE8.0-…
阅读更多...
如何在Mac终端上，用十六进制查看某个硬盘（使用dd和hexdump，所以其他系统也可以使用这个方法）

如何在Mac终端上，用十六进制查看某个硬盘（使用dd和hexdump，所以其他系统也可以使用这个方法）

首先需要强调&#xff1a;这种方法不能保证所有的硬盘都可以查看&#xff0c;有些硬盘由于一些原因会显示“Resource busy”&#xff0c;比如说时间机器的硬盘&#xff0c;内置硬盘等。 准备&#xff1a; 当然是一台 Mac&#xff1b;hexdump程序dd程序 方法如下&#xff1a;…
阅读更多...
QT或VS2015报错：Error: C2661: QColor::ct::ct: 没有重载函数接受 5 个参数解决方案

QT或VS2015报错：Error: C2661: QColor::ct::ct: 没有重载函数接受 5 个参数解决方案

安装了QT5.14.2 MSCV2015配置并同时在QT或VS2015测试并运行都提示没有重载函数接受 5 个参数。 同时还会出现C2134错误&#xff1a;QMetaObject::SuperData::operator const QMetaObject *: 调用不会生成常数表达式的错误 搜索了网络上的结果都让换其它版本&#xff0c;没有…
阅读更多...
【Telephony】SIM单卡到双卡的变化

【Telephony】SIM单卡到双卡的变化

1、注册观察者 --> PhoneFactory.makeDefaultPhones() --> TelephonyComponentFactory.makeSubscriptionInfoUpdater() --> new SubscriptionInfoUpdater() --> PhoneConfigurationManager.registerForMultiSimConfigChange(this, EVENT_MULTI_SIM_CONFIG_CHAN…
阅读更多...
06、Nginx反向代理与负载均衡

06、Nginx反向代理与负载均衡

反向代理&#xff1a; 这种代理方式叫做&#xff0c;隧道代理。有性能瓶颈&#xff0c;因为所有的数据都经过Nginx&#xff0c;所以Nginx服务器的性能至关重要 负载均衡&#xff1a; 把请求&#xff0c;按照一定算法规则&#xff0c;分配给多台业务服务器&#xff08;即使其中…
阅读更多...
【STM32】F103 时钟树

【STM32】F103 时钟树

STM32F103是一款基于ARM Cortex-M3内核的32位微控制器&#xff0c;它具有丰富的外设资源和灵活的时钟配置。本文将从以下几个方面介绍STM32F103的时钟树&#xff1a; 时钟树的概念和作用时钟树的组成和分类时钟树的配置方法和步骤时钟树的应用实例 一、时钟树的概念和作用二、时…
阅读更多...
elementui实现表格自定义排序

elementui实现表格自定义排序

需求说明&#xff1a; 1、第一行不参与排序 2、实现带%排序 3、实现null值排序 4、实现值相等不排序 5、实现含有占位符‘–‘排序放到最后 效果图如下&#xff1a; <template> <div><template><el-table border :data"previewTableData" style…
阅读更多...
vue三种方式导出报表至excel

vue三种方式导出报表至excel

1、序言 1.1、源码 源码在下方&#xff0c;复制运行&#xff0c;安装相应的插件即可 1.2、坑 方式一、方式二安装相同插件&#xff1a; npm install xlsx xlsx-style file-saver 导入 xlsx-style 会报如下的错误 解决办法&#xff1a; &#xff08;1&#xff09;去node_modules…
阅读更多...
个人对于SAR的粗浅理解

个人对于SAR的粗浅理解

个人对于SAR的粗浅理解 有同学问我是做成像的&#xff0c;让我解释一下SAR成像&#xff0c;我思索了一下&#xff0c;决定这样简单回答&#xff1a; 首先SAR的全称为Synthetic Aperture Radar&#xff0c;即合成孔径雷达&#xff0c;本质还是一种Radar 合成孔径&#xff0c;其…
阅读更多...
二叉树刷题总结

二叉树刷题总结

题单&#xff1a; 一&#xff0c;相同的树 题目&#xff1a; 给你两棵二叉树的根节点 p 和 q &#xff0c;编写一个函数来检验这两棵树是否相同。 如果两个树在结构上相同&#xff0c;并且节点具有相同的值&#xff0c;则认为它们是相同的。 题目接口&#xff1a; /*** Defin…
阅读更多...
STM32实战项目—密码锁

STM32实战项目—密码锁

该项目的完整工程可以在博主的资源里找到&#xff0c;仅供参考。 文章目录 一、任务要求二、实现方法2.1 输入密码判断2.2 管理员模式2.3 修改密码 三、程序设计3.1 输入密码判断3.2 进入管理员模式3.3 修改密码 四、问题总结4.1 输入内容一直提示Error4.2 密码判断一直错误 五…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023