SpringBoot项目整合WebSocket几种方式_springboot 集成websocket的几种方式-程序员宅基地

技术标签: websocket  # SpringBoot  

一、WebSocket相关介绍

在线测试websocket网站:http://www.easyswoole.com/wstool.html

1、WebSocket基本概念

1.1 基本概念

基本概念原理这里就不细讲了,一查一大把,推荐大佬的这篇博客(偏代码实践一些)以及知乎的这篇高赞回答(偏寓教于乐一些)。需要重点说明的几点

  • Websocket作为标准的通信协议在Web C/S使用时,需要浏览器和Web服务容器的支持
  • Websocket依靠Http来完成握手,握手完成后才是完全走Websocket协议
  • 资源描述符的前缀为ws,加密通道传输则为wss,例如ws://example.com:80/some/path
  • Websocket没有规定发送内容的格式,支持文本、二进制

1.2 Http握手

为什么要使用Http来进行握手而不是完全独立采用自有协议,主要原因有:

  • Websocket主要还是作为Http的一种补充,与Http紧密结合是合情合理的,并且能够较好地融入Http生态
  • 提供了良好的兼容性处理,可以通过Http来获取兼容性支持反馈以及使用Http来在不支持websocket的客户端上模拟兼容Websocket

1.3 SockJS

SockJS是一个JavaScript库,主要用于应对浏览器缺失websocket支持的情况。它提供了连贯的、跨浏览器的JavaScript API,它首先尝试使用原生Websocket,在失败时能够使用各种浏览器特定的传输协议来模拟Websocket的行为

1.4 Java规范

Java发布提供了Websocket的标准API接口JSR-356,作为Java EE7标准的一部分。大部分标准的Java web容器都已经实现了对Websocket的支持,同时也是兼容这个标准接口的,例如Tomcat 7.0.47+, Jetty 9.1+, GlassFish 4.1+, WebLogic 12.1.3+, Undertow 1.0+ (WildFly 8.0+)等。

1.5 Websocket使用场景

这里主要参考Spring文档中的叙述:Websocket虽然可以使网页变得动态以及更加有交互性,但是在很多情况下Ajax结合Http Streaming或者长轮询可以提供简单高效的解决方案。例如新闻、邮件、社交订阅等需要动态更新,但是在这些情景下每隔几分钟更新一次是完全没有问题的。而另一方面,协作、游戏以及金融应用则需要更加接近实时更新。注意延迟本身并不是决定性因素,如果信息量相对较少(例如监控网络故障),Http Streaming或轮询同样也可以高效地解决。低延迟、高频率以及高信息量的组合情况下,Websocket才是最佳选择。

2、STOMP协议

2.1 概念介绍

STOMP是一个简单的互操作协议,它被设计为常用消息传递模式的最小子集,定义了一种基于文本的简单异步消息协议,它最初是为脚本语言(如 Ruby、 Python 和 Perl)创建的,用于连接企业消息代理。STOMP已经广泛使用了好几年,并且得到了很多客户端(如stomp.js、Gozirra、stomp.py、stompngo等)、消息代理端(如ActiveMQ、RabbitMQ等)工具库的支持,目前最新的协议版本为1.2。

STOMP是一种基于’Frame’的协议,Frame基于Http建模,每个Frame由一个命令(Command)、一组头部(Headers)和可选的正文(Body)组成,如下是一个STOMP frame的基本结构示例:

COMMAND
header1:value1
header2:value2

Body^@

可以看到STOMP本身的结构是非常简单明了的。

2.2 STOMP相关命令

STOMP同样有客户端和服务端的概念,服务端被认为是可以接收和发送消息的一组目的地;而客户端则是用户代理,可以进行两种操作:发送消息(SEND)、发送订阅(SUBSCRIBE),为此,STOMP的命令有如下几种。

客户端命令:

  • CONNECT:用于初始化信息流或TCP连接,是客户端第一个需要发送的命令
  • SEND:表示向目的地发送消息,必须要包含一个名为destination的头部
  • SUBSCRIBE:用于注册监听一个目的地,必须包含一个名为destination的头部
  • BEGIN:用于启动事务,必须包含一个名为transaction的头部
  • COMMIT:用于提交事务,必须包含一个名为transaction的头部
  • ABORT:用于回滚事务,必须包含一个名为transaction的头部
  • DISCONNECT:告知服务端关闭连接

服务端命令:

  • CONNECTED:服务器响应客户的段的CONNECT请求,表示连接成功
  • MESSAGE:用于将订阅的消息发送给客户端,头部destination的值应与SEND frame中的相同,且必须包含一个名为message-id的头部用于唯一标识这个消息
  • RECIPT:收据,表示服务器成功处理了一个客户端要求返回收据的消息,必须包含头部message-id表明是哪个消息的收据
  • ERROR:出现异常时,服务端可能会发送该命令,通常在发送ERROR后将关闭连接

可以说STOMP主要就是提供了发送消息、订阅消息的语义,同时还能够支持事务的处理。

二、WebSocket的应用

官网关于websocket的介绍:https://docs.spring.io/spring-framework/docs/current/reference/html/web.html#websocket

1、WebSocket原生注解

原生websocket入门实践:https://blog.csdn.net/lemon_TT/article/details/113263443

pom.xml

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

配置类WebSocketConfig,这里开启了配置之后springboot才会去扫描对应的注解

@Configuration
@EnableWebSocket
public class WebSocketConfig {
    
//如果使用了springboot启动项目,则需要bean注入,而如果使用了外置tomcat容器,则并不要bean注入,否侧会报错
  @Bean
  public ServerEndpointExporter serverEndpoint() {
    
    return new ServerEndpointExporter();
  }
}

处理消息类WsServerEndpoint

@ServerEndpoint("/myWs")
@Component
public class WsServerEndpoint {
    
    /**
     * 连接成功
     * @param session
     */
    @OnOpen
    public void onOpen(Session session) {
    
        System.out.println("连接成功");
    }

    /**
     * 连接关闭
     * @param session
     */
    @OnClose
    public void onClose(Session session) {
    
        System.out.println("连接关闭");
    }

    /**
     * 接收到消息
     * @param text
     */
    @OnMessage
    public String onMsg(String text) throws IOException {
    
        return "servet 发送:" + text;
    }
}

这些注解都是属于jdk自带的,并不是spring提供的,具体位置是在javax.websocket下,需要注意的是接收参数中的session,这是我们需要保存的,后面如果要对客户端发送消息的话使用session.getBasicRemote().sendText(XXX)

@ServerEndpoint

  • 通过这个 spring boot 就可以知道你暴露出去的 ws 应用的路径,有点类似我们经常用的@RequestMapping。比如你的启动端口是8080,而这个注解的值是ws,那我们就可以通过 ws://127.0.0.1:8080/ws 来连接你的应用。

@OnOpen

  • 当 websocket 建立连接成功后会触发这个注解修饰的方法。

@OnClose

  • 当 websocket 建立的连接断开后会触发这个注解修饰的方法。

@OnMessage

  • 当客户端发送消息到服务端时,会触发这个注解修改的方法,它有一个 String 入参表明客户端传入的值。

@OnError

  • 当 websocket 建立连接时出现异常会触发这个注解修饰的方法。

2、Spring封装的WebSocket

spring同样也为我们提供了WebSocket的封装,这种方式可以自己配置拦截器,在tcp握手之前对请求进行一次处理,可以避免一些恶意的连接

2.1 pom.xml

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

2.2 WsSessionManager

这里简单通过 ConcurrentHashMap来实现了一个 session 池,用来保存已经登录的WebSocket 的 session。服务端发送消息给客户端必须要通过这个 session。

@Slf4j
public class WsSessionManager {
    
    /**
     * 保存连接 session 的地方
     */
    private static ConcurrentHashMap<String, WebSocketSession> SESSION_POOL = new ConcurrentHashMap<>();

    /**
     * 添加 session
     * @param key
     */
    public static void add(String key, WebSocketSession session) {
    
        // 添加 session
        SESSION_POOL.put(key, session);
    }

    /**
     * 删除 session,会返回删除的 session
     * @param key
     * @return
     */
    public static WebSocketSession remove(String key) {
    
        // 删除 session
        return SESSION_POOL.remove(key);
    }

    /**
     * 删除并同步关闭连接
     * @param key
     */
    public static void removeAndClose(String key) {
    
        WebSocketSession session = remove(key);
        if (session != null) {
    
            try {
    
                // 关闭连接
                session.close();
            } catch (IOException e) {
    
                // todo: 关闭出现异常处理
                e.printStackTrace();
            }
        }
    }
    /**
     * 获得 session
     * @param key
     * @return
     */
    public static WebSocketSession get(String key) {
    
        // 获得 session
        return SESSION_POOL.get(key);
    }
}

2.3 HttpAuthHandler

HttpAuthHandler用于处理ws的消息,通过继承 TextWebSocketHandler 类并覆盖相应方法,可以对 websocket 的事件进行处理,这里可以同原生注解的那几个注解连起来看(可以创建多个session池管理不同的websocket)

  • afterConnectionEstablished 方法是在 socket 连接成功后被触发,同原生注解里的 @OnOpen 功能
  • afterConnectionClosed方法是在 socket 连接关闭后被触发,同原生注解里的 @OnClose 功能
  • handleTextMessage方法是在客户端发送信息时触发,同原生注解里的 @OnMessage 功能
@Component
public class HttpAuthHandler extends TextWebSocketHandler {
    
    /**
     * socket 建立成功事件
     * @param session
     * @throws Exception
     */
    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
    
        //这里的值在拦截器中的域属性中复制,后面会自动添加进去
        Object token = session.getAttributes().get("token");
        if (token != null) {
    
            // 用户连接成功,放入在线用户缓存
            WsSessionManager.add(token.toString(), session);
        } else {
    
            throw new RuntimeException("用户登录已经失效!");
        }
    }
    /**
     * 接收消息事件
     * @param session
     * @param message
     * @throws Exception
     */
    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
    
        // 获得客户端传来的消息
        String payload = message.getPayload();
        Object token = session.getAttributes().get("token");
        System.out.println("server 接收到 " + token + " 发送的 " + payload);
        session.sendMessage(new TextMessage("server 发送给 " + token + " 消息 " + payload + " " +    LocalDateTime.now().toString()));
    }

    /**
     * socket 断开连接时
     * @param session
     * @param status
     * @throws Exception
     */
    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
    
        Object token = session.getAttributes().get("token");
        if (token != null) {
    
            // 用户退出,移除缓存
            WsSessionManager.remove(token.toString());
        }
    }
}

2.4 Interceptor拦截器

MyInterceptor用来拦截ws请求,通过实现 HandshakeInterceptor 接口来定义握手拦截器,注意这里与上面 Handler 的事件是不同的,这里是建立握手时的事件,分为握手前与握手后,而 Handler 的事件是在握手成功后的基础上建立 socket 的连接。所以在如果把认证放在这个步骤相对来说最节省服务器资源。它主要有两个方法 beforeHandshakeafterHandshake,顾名思义一个在握手前触发,一个在握手后触发。

@Component
public class MyInterceptor implements HandshakeInterceptor {
    
    /**
     * 握手前
     * @param request
     * @param response
     * @param wsHandler
     * @param attributes
     * @return
     * @throws Exception
     */
    @Override
    public boolean beforeHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Map<String, Object> attributes) throws Exception {
    
        System.out.println("握手开始");
        // 获得请求参数,这里用了hutools工具箱
        HashMap<String, String> paramMap = (HashMap<String, String>) HttpUtil.decodeParamMap(request.getURI().getQuery(), Charset.defaultCharset());
        String uid = paramMap.get("token");
        if (StrUtil.isNotBlank(uid)) {
    
            // 放入属性域,可以在HttpAuthHandler的session的attributes中获取
            attributes.put("token", uid);
            System.out.println("用户 token " + uid + " 握手成功!");
            return true;
        }
        System.out.println("用户登录已失效");
        return false;
    }
    /**
     * 握手后
     * @param request
     * @param response
     * @param wsHandler
     * @param exception
     */
    @Override
    public void afterHandshake(ServerHttpRequest request, ServerHttpResponse response, WebSocketHandler wsHandler, Exception exception) {
    
        System.out.println("握手完成");
    }
}

2.5 PrincipalHandshakeHandler配置(可不设置)

用户登录系统后,才可以登录websocket,并重写MyPrincipal,MyPrincipalHandshakeHandlerDefaultHandshakeHandler的子类,处理websocket请求,这里我们只重写determineUser方法,生成我们自己的Principal ,这里我们使用loginName标记登录用户,而不是默认值

MyPrincipal 定义自己的Principal

import java.security.Principal;

public class MyPrincipal implements Principal {
    
    private String loginName;

    public MyPrincipal(String loginName){
    
        this.loginName = loginName;
    }

    @Override
    public String getName() {
    
        return loginName;
    }
}

生成MyPrincipalHandshakeHandler类

@Component
public class MyPrincipalHandshakeHandler extends DefaultHandshakeHandler {
    
    private static final Logger log = LoggerFactory.getLogger(MyPrincipalHandshakeHandler.class);

    protected Principal determineUser(ServerHttpRequest request, WebSocketHandler wsHandler, Map<String, Object> attributes) {
    

        HttpSession httpSession = getSession(request);
        String user = (String)httpSession.getAttribute("loginName");

        if(StrUtil.isEmpty(user)){
    
            log.error("未登录系统,禁止登录websocket!");
            return null;
        }
        log.info(" MyDefaultHandshakeHandler login = " + user);
        return new MyPrincipal(user);
    }

    private HttpSession getSession(ServerHttpRequest request) {
    
        if (request instanceof ServletServerHttpRequest) {
    
            ServletServerHttpRequest serverRequest = (ServletServerHttpRequest) request;
            //如果之前登录了必定有session,如果没有登录就返回null
            return serverRequest.getServletRequest().getSession(false);
        }
        return null;
    }
}

2.6 配置类WebSocketConfig

通过实现 WebSocketConfigurer 类并覆盖相应的方法进行 websocket 的配置。我们主要覆盖 registerWebSocketHandlers 这个方法。通过向 WebSocketHandlerRegistry 设置不同参数来进行配置。其中 addHandler方法添加我们的 ws 的 handler 处理类,第二个参数是你暴露出的 ws 路径。addInterceptors添加我们写的拦截器。setAllowedOrigins这个是关闭跨域校验。

@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
    

    @Autowired
    private HttpAuthHandler httpAuthHandler;
    @Autowired
    private MyInterceptor myInterceptor;
    @Autowired
    private MyPrincipalHandshakeHandler myPrincipalHandshakeHandler;

    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
    
        registry
                //自定义的websocket服务,这里都可以定义多个
                .addHandler(httpAuthHandler, "ws")
                //设置拦截器
                .addInterceptors(myInterceptor)
                //设置登录用户检查
                //.setHandshakeHandler(myPrincipalHandshakeHandler)
                //关闭跨域校验
                .setAllowedOrigins("*");
    }
}

最后访问链接ws://localhost:8085/parentServer?token=shawn

3、STOMP

3.1 介绍

stomp是WebSocket的一个子协议,SpringBoot官方也有整合stomp的例子,这也是我现在所用到的整合方式,这种方式功能更加强大,可以使用消息代理,对于发送的消息可以使用类似springMvc的处理方式,同时消息的发送变成了订阅的模式,可以很方便的进行群发。

3.2 pom.xml

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

3.3 WebSocketConfig配置类

@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements WebSocketMessageBrokerConfigurer {
    

    @Bean
    public WebSocketInterceptor getWebSocketInterceptor() {
    
        return new WebSocketInterceptor();
    }

    @Override
    public void registerStompEndpoints(StompEndpointRegistry registry) {
    
        // 配置客户端尝试连接地址
        registry.
                addEndpoint("/ws").     // 设置连接节点,前端请求的建立连接的地址就是 http://ip:端口/ws
                //addInterceptors(getWebSocketInterceptor()).     // 设置握手拦截器
                setAllowedOrigins("*").     // 配置跨域
                withSockJS();       // 开启sockJS支持,这里可以对不支持stomp的浏览器进行兼容。
    }

    @Override
    public void configureMessageBroker(MessageBrokerRegistry registry) {
    
        // 消息代理,这里配置自带的消息代理,也可以配置其它的消息代理
        // 一定要注意这里的参数,可以理解为开启通道,后面如果使用了"/XXX"来作为前缀,这里就要配置,同时这里的"/topic"是默认群发消息的前缀,前端在订阅群发地址的时候需要加上"/topic"
        registry.enableSimpleBroker("/user","/topic");  
        // 客户端向服务端发送消息需有的前缀,需要什么样的前缀在这里配置,但是不建议使用,这里跟下面首次订阅返回会有点冲突,如果不需要首次订阅返回消息,也可以加上消息前缀
        // registry.setApplicationDestinationPrefixes("/");
        // 配置单发消息的前缀 /user,前端订阅一对一通信的地址需要加上"/user"前缀
        registry.setUserDestinationPrefix("/user");
    }
}

3.4 SpringMVC控制器

WSController是ws的控制器,@SubscribeMapping注解可以在客户端首次订阅了对应的地址后直接返回一条消息,订阅地址支持路径参数,接收路径参数需要在参数前加上@DestinationVariable,下面有三种常用的订阅方式,这里一定要注意地址格式,通用群发消息/topic/hello,指定一部分人可以收到的群发消息/topic/state/{classId},一对一消息/user/{name}/hello,我这里的ResultWrapper.success就是一个封装类,跟springMVC中封装的返回对象完全一致,stomp会把对象解析为json字符串返回给前端。

@MessageMapping是用来接收客户端对某个地址发送的消息,需要注意的是客户端发送的地址,如果在之前的配置类中配置了发送前缀,则必须携带前缀才能发送消息到客户端,如:/app/hello,但是服务器仍然只需要这样写@MessageMapping("/hello")

@SendTo是用来向客户端发送消息的注解,这里填写的参数就是订阅地址的全名/topic/hello不能省略/topic,返回消息只需要return消息对象即可。

除了注解的方式发送消息,还有一种灵活的方式使用消息模板来发送,simpMessagingTemplate.convertAndSendToUser(一对一)和simpMessagingTemplate.convertAndSend(群发),注意我参数中填写的方式,这种方式比较推荐使用,可以在任意地方对客户端发送消息,但是这个地方似乎有个坑,发送消息之后会阻塞在这里,不过可以开一个线程去发送消息。

@RestController
public class WSController {
    
    @Autowired
    private SimpMessagingTemplate simpMessagingTemplate;

    @SubscribeMapping({
    "/topic/hello"})
    public Result subscribeTime() {
    
        return ResultWrapper.success("hello!");
    }
    
    @SubscribeMapping({
    "/topic/info/{classId}"})
    public Result subscribeState(@DestinationVariable String classId) {
    
        return ResultWrapper.success("班级消息推送订阅成功!");
    }

    @SubscribeMapping({
    "/user/{name}/hello"})
    public Result subscribeParam(@DestinationVariable String name) {
    
        return ResultWrapper.success("你好!"+name);
    }
    
    @MessageMapping("/hello")
    @SendTo("/topic/hello")
    public Result hello(RequestMessage requestMessage) {
    
        System.out.println("接收消息:" + requestMessage);
        return ResultWrapper.success("服务端接收到你发的:"+requestMessage);
    }

    @GetMapping("/sendMsgToUser")
    public String sendMsgByUser(String name, String msg) {
    
        // /user/{name}/hello
        simpMessagingTemplate.convertAndSendToUser(name, "/hello", msg);
        return "success";
    }

    @GetMapping("/sendMsgToAll")
    public String sendMsgByAll(int classId, String msg) {
    
        // /topic/info/{classId}
        simpMessagingTemplate.convertAndSend("/topic/info/"+classId, msg);
        return "success";
    }
}

3.5 前端的订阅

一部分代码举例

function connect() {
    
        var socket = new SockJS('http://localhost:8092/simple');
        stompClient = Stomp.over(socket);
        stompClient.connect({
    }, function (frame) {
    
            setConnected(true);
            console.log('Connected:' + frame);
            stompClient.subscribe('/topic/say', function (response) {
    
                showResponse(JSON.parse(response.body).responseMessage);
            });
            // 另外再注册一下定时任务接受
            stompClient.subscribe('/topic/callback', function (response) {
    
                showCallback(response.body);
            });
        });
    }

    function disconnect() {
    
        if (stompClient != null) {
    
            stompClient.disconnect();
        }
        setConnected(false);
        console.log('Disconnected');
    }

三、常见问题

1、Session共享问题

上面反复提到一个问题就是,服务端如果要主动发送消息给客户端一定要用到 session。而大家都知道的是 session 这个东西是不跨 jvm 的。如果有多台服务器,在 http 请求的情况下,我们可以通过把 session 放入缓存中间件中来共享解决这个问题,通过 spring session 几条配置就解决了。但是 web socket 不可以。他的 session 是不能序列化的,当然这样设计的目的不是为了为难你,而是出于对 http 与 web socket 请求的差异导致的。

目前网上找到的最简单方案就是通过 redis 订阅广播的形式,主要代码跟第二种方式差不多,你要在本地放个 map 保存请求的 session。也就是说每台服务器都会保存与他连接的 session 于本地。然后发消息的地方要修改,并不是现在这样直接发送,而通过 redis 的订阅机制。服务器要发消息的时候,你通过 redis 广播这条消息,所有订阅的服务端都会收到这个消息,然后本地尝试发送。最后肯定只有有这个对应用户 session 的那台才能发送出去。


参考文章

【websocket】spring boot 集成 websocket 的四种方式

STMOP集成WebSocket实时通信

Spring WebSocket简析

SpringBoot项目整合WebSocket

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/lemon_TT/article/details/124172948

智能推荐

apache php html页面不显示内容,apache服务器下.htaccess控制文件列表、目录显示,不显示的方法...-程序员宅基地

文章浏览阅读348次。.htaccess文件不仅能控制伪静态、防盗链等等,它还具备控制项目文件在index.html或者index.php文件缺失时是否线上其他一些目录文件。我们经常能看到"forbidden You don't have permission to access / on this server" 这样的报错提示,那是因为我们关闭了服务器的目录索引。如果我们不关闭目录索引,那么基本上就把我们项目目录结..._阿帕奇已经把文件放在html文件夹里了但是就是看不到

线性回归原理----简单线性回归、多元线性回归_多元线性回归原理-程序员宅基地

文章浏览阅读6.5k次,点赞3次,收藏38次。回归分析是用来评估变量之间关系的统计过程。用来解释自变量X与因变量Y的关系。即当自变量X发生改变时,因变量Y会如何发生改变。线性回归是回归分析的一种,评估的自变量X与因变量Y之间是一种线性关系,当只有一个自变量时,成为简单线性回归,当具有多个变量时,称为多元线性回归。线性关系的理解:>画出来的图像是直的(简单线性回归是直线,多元线性回归是超平面)>每个自变量的最高次项为1拟合是指构建一种算法,使得该算法能够符合真实的数据。从机器学习角度讲,线性回归就是要构建一个线性函_多元线性回归原理

linux查看历史挂载饿磁盘,Linux 查看、挂载磁盘-程序员宅基地

文章浏览阅读636次。参考链接:https://www.cnblogs.com/youbiyoufang/p/7607174.htmldf -T 查看已挂载的分区和文件类型df 命令用于显示磁盘分区上的可使用的磁盘空间,-T 表示显示文件类型fdisk -l 可以显示出所有挂载和未挂载的分区,但不显示文件系统类型移动硬盘一般是/dev/sdX1的形式,比如/dev/sdc1。这里需要了解sdX1的含义,sd表示可移..._linux查看历史硬盘

php 老版本 下载地址,常用官方php版本下载链接-程序员宅基地

文章浏览阅读264次。【如何快速的开发一个完整的iOS直播app】&lpar;美颜篇&rpar;原文转自:袁峥Seemygo 感谢分享.自我学习 前言 在看这篇之前,如果您还不了解直播原理,请查看这篇文章如何快速的开发一个完整的iOS直播app(原理篇) 开发一款直播app,美颜功能是很重 ...cordova插件iOS平台实战开发注意点cordova插件是其设计理念的精髓部分,创建并使用自定义插..._php旧版本官方下载地址

【Java】HashMap 和 HashTable 的区别到底是什么?_java中hashmap和hashtable的区别-程序员宅基地

文章浏览阅读2.7w次,点赞21次,收藏48次。第一、继承不同第一个不同主要是历史原因。Hashtable是基于陈旧的Dictionary类的,HashMap是Java 1.2引进的Map接口的一个实现。public class HashMap extends AbstractMap implements Cloneable, Serializable {...}public class Hashtable_java中hashmap和hashtable的区别

Openwrt下jshn.sh用法解析_json_get_vars-程序员宅基地

文章浏览阅读4.8k次,点赞3次,收藏11次。一、示例用到的json数据{ "up": true, "uptime": 18804, "l3_device": "eth0.2", "proto": "dhcp", "device": "eth0.2", "ipv4-address": [ { "address": "192.168.5.102", _json_get_vars

随便推点

Tips展开关闭问答代码_js tips 取消-程序员宅基地

文章浏览阅读351次。http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">http://www.w3.org/1999/xhtml">无标题文档function show(c_Str,imgg){if(document.all(c_Str).style.display=='none'){document.all(c_Str)._js tips 取消

[Linux]grep指令加参数_grep 结果作为参数-程序员宅基地

文章浏览阅读2.2k次。1.grep指令的用途grep是我们常用的一个指令,经常与管道符“|”搭配,对上一操作的结果进行筛选通常我们是直接grep 内容例如:检查opt目录在不在 ll | grep opt查看tty相关进程ps -ef|grep tty检查22端口netstat -tunlp|grep 222.使用参数筛选在上面的操作中,可以看到查看进程和端口时,结果中多出了一些无关的东西在gr..._grep 结果作为参数

使用mycat搭建实现mysql数据库集群管理_mycat mysql集群-程序员宅基地

文章浏览阅读4.6k次,点赞4次,收藏18次。今天来使用mycat管理mysql集群, 随着数据量的提升, 我们如果把所有数据存储在一个数据库中, 对数据的各种操作就会变得非常的困难. 自然我们又想到了数据库也进行集群部署, 将一个数据库的数据分散到不同的数据库中存储, 进而提升数据操作的性能.本文的定义是简洁快速的使用mycat, 让读者可以快速的入门mycat, 因此本文聚焦于mycat的安装, 使用, 简易配置, 常用配置文件和标签的..._mycat mysql集群

python turtle画房子代码里面的窗子,如何用python画房子_用python画一个小房子-程序员宅基地

文章浏览阅读2.7k次。如何用python画一个小房子?效果图如下:代码如下:import turtle# 前置p = turtle.Pen()# 作者要说的话for i in range(6):print('请把画板最大化,否则会影响画面效果!')# 设置笔的速度p.speed(10)# 开始画画p.pencolor("#F4A460")p.penup()p.goto((-240), (-200))p.pendown(..._turtle 房子

linux 硬盘品牌,CentOS如何查看硬盘品牌型号等具体信息-程序员宅基地

文章浏览阅读3.5k次。首先使用smartctl --all /dev/sda指令来检查硬盘信息,该指令CentOS自带,得到的结果可能如下:smartctl 5.43 2012-06-30 r3573 [x86_64-linux-2.6.32-358.el6.x86_64] (local build)Copyright (C) 2002-12 by Bruce Allen, http://smartmontools...._centos查看物理机磁盘型号

腾讯计费平台部PHP,企业级正规php第三方api第四方支付平台程序源码完整开源全套 - A保站...-程序员宅基地

文章浏览阅读388次。程序名称:企业级PHP第三方支付平台(云计费聚合支付)程序语言:PHP+mysql程序大小:约180MB程序已集成支付宝PC、支付宝WAP、微信扫码、微信WAP、财付通PC、财付通WAP、QQ钱包扫码、QQ钱包WAP、银联在线、京东支付、环迅支付、易宝支付等等20多个接口。此套程序开发成本3万多,全站兼容手机HTML5页面,仅售2000元全套源码+数据库(包安装,,需要安装的联系卖家洽谈)官网演示..._api收费平台源码

推荐文章

热门文章

相关标签