Mina网络通信框架

认识 Mina

Apache Mina Server 是一个网络通信应用框架，与 Netty 出自同一作者，Netty 借鉴了部分 Mina 的设计思路。

Mina 主要是对基于 TCP/IP、UDP/IP 协议栈的通信框架，Mina 可以帮助我们快速开发高性能、高扩展性的网络通信应用，Mina 提供了事件驱动、异步操作的编程模型，Mina 的异步 IO 默认使用的是 JAVA NIO（New IO）作为底层支持，基于 Channel 的双向通道。Mina 主要有1.x 和2.x 两个分支。Mina 同时提供了网络通信的 Server 端、Client 端的封装，无论是哪端，Mina 在整个网通通信结构中提供了一系列接口 API，Mina 的 API 将真正的网络通信与我们的应用程序隔离开来。

img

Mina 的底层依赖的主要是 Java NIO 库，上层提供的是基于事件的异步接口。其整体的结构如下：

  • IoService：最底层的是 IOService，负责具体的 IO 相关工作。这一层的典型代表有 IOSocketAcceptor 和 IOSocketChannel，分别对应 TCP 协议下的服务端和客户端的 IOService。IOService 的意义在于隐藏底层 IO 的细节，对上提供统一的基于事件的异步 IO 接口。每当有数据到达时，IOService 会先调用底层 IO 接口读取数据，封装成 IoBuffer，之后以事件的形式通知上层代码，从而将 Java NIO 的同步 IO 接口转化成了异步 IO。所以从图上看，进来的 low-level IO 经过 IOService 层后变成 IO Event。具体的代码可以参考 org.apache.mina.core.polling.AbstractPollingIoProcessor 的私有内部类 Processor。
  • IoProcessor：这个接口在另一个线程上，负责检查是否有数据在通道上读写，也就是说它也拥有自己的 Selector，这是与我们使用 JAVA NIO 编码时的一个不同之处，通常在 JAVA NIO 编码中，我们都是使用一个 Selector，也就是不区分 IoService 与 IoProcessor 两个功能接口。另外，IoProcessor 负责调用注册在 IoService 上的过滤器，并在过滤器链之后调用 IoHandler。
  • IoFilter：这个接口定义一组拦截器，这些拦截器可以包括日志输出、黑名单过滤、数据的编码（write 方向）与解码（read 方向）等功能，其中数据的 encode 与decode 是最为重要的、也是你在使用 Mina 时最主要关注的地方。
  • IoHandler：这个接口负责编写业务逻辑，也就是接收、发送数据的地方。需要有开发者自己来实现这个接口。IoHandler 可以看成是 Mina 处理流程的终点，每个 IoService 都需要指定一个 IoHandler。
  • IoSession：是对底层连接（服务器与客户端的特定连接，该连接由服务器地址、端口以及客户端地址、端口来决定）的封装，一个 IoSession 对应于一个底层的 IO 连接（在 Mina 中 UDP 也被抽象成了连接）。通过 IoSession，可以获取当前连接相关的上下文信息，以及向远程 peer 发送数据。发送数据其实也是个异步的过程。发送的操作首先会逆向穿过 IoFilterChain，到达 IoService。但 IoService 上并不会直接调用底层 IO 接口来将数据发送出去，而是会将该次调用封装成一个 WriteRequest，放入 session 的 writeRequestQueue 中，最后由 IoProcessor 线程统一调度 flush 出去。所以发送操作并不会引起上层调用线程的阻塞。具体代码可以参考 org.apache.mina.core.filterchain.DefaultIoFilterChain 的内部类 HeadFilter 的 filterWrite 方法。

服务端流程：

  • 通过 SocketAcceptor 同客户端建立连接
  • 连接建立之后 I/O 的读写交给了 I/O Processor 线程，I/O Processor 是多线程的
  • 通过 I/O Processor 读取的数据经过 IoFilterChain 里所有配置的 IoFilter，IoFilter 进行消息的过滤，格式的转换，在这个层面可以制定一些自定义的协议
  • 最后 IoFilter 将数据交给 Handler 进行业务处理，完成了整个读取的过程

写入过程也是类似，只是刚好倒过来，通过 IoSession.write 写出数据，然后 Handler 进行写入的业务处理，处理完成后交给 IoFilterChain，进行消息过滤和协议的转换，最后通过 I/O Processor 将数据写出到 socket 通道。

简单的 TCPServer

第一步：编写 IoService

IoAcceptor acceptor = new NioSocketAcceptor();
acceptor.getSessionConfig().setReadBufferSize(2048);
acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);acceptor.bind(new InetSocketAddress(9124));

第二步：编写过滤器

// 编写过滤器
acceptor.getFilterChain().addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"),LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue()))
);

第三步：编写 IoHandler

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;public class TCPServerHandler extends IoHandlerAdapter {@Overridepublic void messageReceived(IoSession session, Object message) throws Exception {}@Overridepublic void sessionCreated(IoSession session) throws Exception {super.sessionCreated(session);}@Overridepublic void sessionOpened(IoSession session) throws Exception {super.sessionOpened(session);}@Overridepublic void sessionClosed(IoSession session) throws Exception {super.sessionClosed(session);}
}

把这个 IoHandler 注册到 IoService：

acceptor.setHandler(new TCPServerHandler());

当然这段代码也要在 acceptor.bind() 方法之前执行。完成的代码：

import java.io.IOException;
import java.net.InetSocketAddress;
import java.nio.charset.Charset;import org.apache.mina.core.service.IoAcceptor;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.LineDelimiter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketAcceptor;public class TCPServer {public static void main(String[] args) throws IOException {IoAcceptor acceptor = new NioSocketAcceptor();acceptor.getSessionConfig().setReadBufferSize(2048);acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);// 编写过滤器acceptor.getFilterChain().addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"),LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue())));//设置handleracceptor.setHandler(new TCPServerHandler());//绑定端口acceptor.bind(new InetSocketAddress(9124));}
}

简单的 TCPClient

第一步：编写 IoService 并注册过滤器

import java.net.InetSocketAddress;
import java.nio.charset.Charset;import org.apache.mina.core.service.IoConnector;
import org.apache.mina.filter.codec.ProtocolCodecFilter;
import org.apache.mina.filter.codec.textline.LineDelimiter;
import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
import org.apache.mina.transport.socket.nio.NioSocketConnector;public class TCPClient {public static void main(String[] args) {IoConnector connector = new NioSocketConnector();connector.setConnectTimeoutMillis(30000);connector.getFilterChain().addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory(Charset.forName("UTF-8"),LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue())));connector.setHandler(new TCPClientHandler("你好！\r\n 大家好！"));    connector.connect(new InetSocketAddress("localhost", 9124));}}

第三步：编写 IoHandler

import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IoSession;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;public class TCPClientHandler extends IoHandlerAdapter {private final String values;public TCPClientHandler(String values) {this.values = values;}@Overridepublic void sessionOpened(IoSession session) {session.write(values);}
}

注册 IoHandler：

connector.setHandler(new ClientHandler("你好！\r\n 大家好！"));

Mina网络通信框架

由于传统的 Socket 网络编程基于一个线程对应一个客户端的实现方式，大量的线程创建和销毁导致性能下降，无法应对高并发量的访问，所以基于服务器端的网络通信开发，我们常用 Mina 网络通信框架，即常说的 Java NIO ( java non-blocking IO ) 开发。

首先，我们来看看 Mina 的几个重要接口：

IoServiece ：这个接口在一个线程上负责套接字的建立，拥有自己的 Selector，监听是否有连接被建立。
IoProcessor ：这个接口在另一个线程上负责检查是否有数据在通道上读写，也就是说它也拥有自己的 Selector，
这是与我们使用 JAVA NIO 编码时的一个不同之处，通常在 JAVA NIO 编码中，我们都是使用一个 Selector，
也就是不区分 IoService与 IoProcessor 两个功能接口。
另外，IoProcessor 负责调用注册在 IoService 上的过滤器，并在过滤器链之后调用 IoHandler。  
IoAccepter ：相当于网络应用程序中的服务器端
IoConnector ：相当于客户端
IoSession ：当前客户端到服务器端的一个连接实例
IoHandler ：这个接口负责编写业务逻辑，也就是接收、发送数据的地方。这也是实际开发过程中需要用户自己编写的部分代码。
IoFilter ：过滤器用于悬接通讯层接口与业务层接口，这个接口定义一组拦截器，这些拦截器可以包括日志输
出、黑名单过滤、数据的编码（write 方向）与解码（read 方向）等功能，其中数据的 encode与 decode是
最为重要的、也是你在使用 Mina时最主要关注的地方。

接着，我们来看看 Mina 的一个重要的类 IoHandlerAdapter，此类仅仅是实现了 IoHandler 接口，但并不做任何处理。
一个 IoHandler 接口中具有如下一些方法（摘自 MINA 的 API 文档）：

void exceptionCaught(IoSession session, Throwable cause)
当接口中其他方法抛出异常未被捕获时触发此方法
void messageReceived(IoSession session, Object message)
当接收到客户端的请求信息后触发此方法
void messageSent(IoSession session, Object message)
当信息已经传送给客户端后触发此方法
void sessionClosed(IoSession session)
当连接被关闭时触发，例如客户端程序意外退出等等
void sessionCreated(IoSession session)
当一个新客户端连接后触发此方法
void sessionIdle(IoSession session, IdleStatus status)
当连接空闲时触发此方法
void sessionOpened(IoSession session)
当连接后打开时触发此方法，一般此方法与 sessionCreated 会被同时触发

下面我们来看看 Mina 服务器网络通信框架开发流程：

1、导入相关 jar 包: mina-core-2.0.13.jar、slf4j-api-1.7.14.jar

img

2、创建acceptor，绑定Handler，设置Filter，绑定端口

            NioSocketAcceptor acceptor = new NioSocketAcceptor();acceptor.setHandler(new MyServerHandler());// 获取拦截器，拦截器作用：把字节转成对象// TextLineCodecFactory 把数据进行加解码acceptor.getFilterChain().addLast("codec",new ProtocolCodecFilter(new TextLineCodecFactory()));// 5秒钟服务器和客户端没有进行读写，则进入空闲状态Idleacceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 5);//绑定9898端口acceptor.bind(new InetSocketAddress(9898));

3、创建自定义的Handler

package com.example.server;import org.apache.mina.core.service.IoHandlerAdapter;
import org.apache.mina.core.session.IdleStatus;
import org.apache.mina.core.session.IoSession;public class MyServerHandler extends IoHandlerAdapter {@Overridepublic void exceptionCaught(IoSession session, Throwable cause)throws Exception {System.out.println("exceptionCaught");}@Overridepublic void messageReceived(IoSession session, Object message)throws Exception {String s = (String) message;System.out.println("messageReceived: " + s);session.write("server replay: " + s);}@Overridepublic void messageSent(IoSession session, Object message) throws Exception {System.out.println("messageSent");}@Overridepublic void sessionClosed(IoSession session) throws Exception {System.out.println("sessionClosed");}@Overridepublic void sessionCreated(IoSession session) throws Exception {System.out.println("sessionCreated");}/*** 会话空闲状态*/@Overridepublic void sessionIdle(IoSession session, IdleStatus status)throws Exception {System.out.println("sessionIdle");}@Overridepublic void sessionOpened(IoSession session) throws Exception {System.out.println("sessionOpened");}}

4、由于默认的 Filter: TextLineCodeFactory 只能接收以换行符为结束的消息，有时为满足特定需求，需要自定义一个 Factory

package com.example.server;import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolCodecFactory;
import org.apache.mina.filter.codec.ProtocolDecoder;
import org.apache.mina.filter.codec.ProtocolEncoder;public class MyTextLineFactory implements ProtocolCodecFactory {private MyTextLineDecoder mDecoder;private MyTextLineEncoder mEncoder;private MyTextLineCumulativeDecoder mCumulativeDecoder;public MyTextLineFactory() {mDecoder = new MyTextLineDecoder();mEncoder = new MyTextLineEncoder();mCumulativeDecoder = new MyTextLineCumulativeDecoder();}// 加密@Overridepublic ProtocolDecoder getDecoder(IoSession arg0) throws Exception {// return mDecoder;// 解决没检测到\n时的数据丢失问题return mCumulativeDecoder;}// 解密@Overridepublic ProtocolEncoder getEncoder(IoSession arg0) throws Exception {return mEncoder;}}

package com.example.server;import java.nio.charset.Charset;
import java.nio.charset.CharsetEncoder;import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolEncoder;
import org.apache.mina.filter.codec.ProtocolEncoderOutput;public class MyTextLineEncoder implements ProtocolEncoder {@Overridepublic void dispose(IoSession session) throws Exception {}@Overridepublic void encode(IoSession session, Object message,ProtocolEncoderOutput output) throws Exception {String s = null;if (message instanceof String) {s = (String) message;}if (s != null) {// 系统默认的EncoderCharsetEncoder charsetEncoder = (CharsetEncoder) session.getAttribute("encoder");if (charsetEncoder == null) {charsetEncoder = Charset.defaultCharset().newEncoder();session.setAttribute("encoder", charsetEncoder);}IoBuffer ioBuffer = IoBuffer.allocate(s.length());ioBuffer.setAutoExpand(true);// 自动扩展ioBuffer.putString(s, charsetEncoder);ioBuffer.flip();output.write(ioBuffer);}}
}

package com.example.server;import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.ProtocolDecoder;
import org.apache.mina.filter.codec.ProtocolDecoderOutput;public class MyTextLineDecoder implements ProtocolDecoder {@Overridepublic void decode(IoSession session, IoBuffer ioBuffer,ProtocolDecoderOutput output) throws Exception {// 起始位置int startPosition = ioBuffer.position();// 是否还有数据while (ioBuffer.hasRemaining()) {byte b = ioBuffer.get();// 读取到\nif (b == '\n') {// 当前位置int currentPosition = ioBuffer.position();// 当前总长度,指向末尾int limit = ioBuffer.limit();// 截取行ioBuffer.position(startPosition);ioBuffer.limit(currentPosition);IoBuffer buf = ioBuffer.slice();// 把buf中的数据写入到destbyte[] dest = new byte[buf.limit()];buf.get(dest);String str = new String(dest);output.write(str);// 还原位置ioBuffer.position(currentPosition);ioBuffer.limit(limit);}}}@Overridepublic void dispose(IoSession arg0) throws Exception {}@Overridepublic void finishDecode(IoSession arg0, ProtocolDecoderOutput arg1)throws Exception {}
}

5、为了解决数据丢失问题，我们常使用 CumulativeProtocolDecoder

package com.example.server;import org.apache.mina.core.buffer.IoBuffer;
import org.apache.mina.core.session.IoSession;
import org.apache.mina.filter.codec.CumulativeProtocolDecoder;
import org.apache.mina.filter.codec.ProtocolDecoderOutput;/*** 处理数据丢失*/
public class MyTextLineCumulativeDecoder extends CumulativeProtocolDecoder {@Overrideprotected boolean doDecode(IoSession ioSession, IoBuffer ioBuffer,ProtocolDecoderOutput output) throws Exception {// 起始位置int startPosition = ioBuffer.position();// 是否还有数据while (ioBuffer.hasRemaining()) {byte b = ioBuffer.get();// 读取到\nif (b == '\n') {// 当前位置int currentPosition = ioBuffer.position();// 当前总长度,指向末尾int limit = ioBuffer.limit();// 截取行ioBuffer.position(startPosition);ioBuffer.limit(currentPosition);IoBuffer buf = ioBuffer.slice();// 把buf中的数据写入到destbyte[] dest = new byte[buf.limit()];buf.get(dest);String str = new String(dest);output.write(str);// 还原位置ioBuffer.position(currentPosition);ioBuffer.limit(limit);return true;// 读取完成}}ioBuffer.position(startPosition);return false;// 读取未完成}
}

至此，整个服务器搭建框架就完了，是否比 Socket 开发要简洁呢？下节笔者将为大家带来一个完整案例，并给出相应的 jar 包和源码。

Mina详解：https://www.cnblogs.com/duanxz/p/5143227.html

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

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

相关文章

每个tabpage中都有一个dategridview_每个女人，都有一个礼服梦

每个tabpage中都有一个dategridview_每个女人，都有一个礼服梦

●今天，我要带着大家跟随几部经典电影，来开启一场关于礼服的时空穿越。01. 《爱玛》//关键词：19世纪初英国乡村经历了巴洛克风格的洗礼，服饰的整体风格变得柔和了不少，蕾丝、细纱、蝴蝶结这些浪漫元素，是这…
阅读更多...
ssm框架sql换成MySQL_搭建ssm框架，可实现登录和数据展示以及增删改查

ssm框架sql换成MySQL_搭建ssm框架，可实现登录和数据展示以及增删改查

需求：后台使用ssm(spring-springMVC-mybatis)进行整合前台使用bootstrap框架前后台交互使用Ajax进行发送表结构：登录页面后显示所有用户信息，可对每条进行增删改查登录时也使用本表的user_name和user_pwd进行校验项目目录结构步骤一&#xff…
阅读更多...
巧妙mybatis避免Where 空条件的尴尬

巧妙mybatis避免Where 空条件的尴尬

我就废话不多说了&#xff0c;大家还是直接看代码吧~ <select id"findActiveBlogLike" resultType"Blog">SELECT * FROM BLOGWHERE<if test"state ! null">state #{state}</if> </select>如果state参数为空时&#x…
阅读更多...
numpy 矩阵与向量相乘_高能！8段代码演示Numpy数据运算的神操作

numpy 矩阵与向量相乘_高能！8段代码演示Numpy数据运算的神操作

作者&#xff5c;王天庆来源&#xff5c;大数据(ID&#xff1a;hzdashuju)导读&#xff1a;本文介绍一下在Python科学计算中非常重要的一个库——Numpy。Numpy是Numerical Python extensions 的缩写&#xff0c;字面意思是Python数值计算扩展。Numpy是Python中众多机器学习库的…
阅读更多...
Spring Boot——日志配置

Spring Boot——日志配置

日志&#xff0c;通常不会在需求阶段作为一个功能单独提出来&#xff0c;也不会在产品方案中看到它的细节。但是&#xff0c;这丝毫不影响它在任何一个系统中的重要的地位。 为了保证服务的高可用&#xff0c;发现问题一定要即使&#xff0c;解决问题一定要迅速&#xff0c;所…
阅读更多...
python2转python3代码_Python2代码转成Python3代码

python2转python3代码_Python2代码转成Python3代码

1.利用anaconda软件自带的功能: 1.找2to3.py文件 我的anaconda装在了D盘下的Anaconda文件夹下 你需要找到anaconda下的script文件夹里面的2to3-script.py文件(由于版本不同,可能名字不太一样,但是一定是2to3开头,而且是py文件)打开2to3-script.py文件后(内容肯定都是一样的):2.…
阅读更多...
hbase java api count_HBase内置过滤器java api的总结

hbase java api count_HBase内置过滤器java api的总结

1、RowFilter:筛选出匹配的所有的行(使用过)//rowkey 等于 test|id9Filter filternew RowFilter(CompareOperator.EQUAL,new BinaryComparator(Bytes.toBytes("test|id9")));2、PrefixFilter:筛选出具有特定前缀的行健的数据//rowkey 以test开头Filter filternew Pre…
阅读更多...
是否有必要使用外键？为什么不用外键？

是否有必要使用外键？为什么不用外键？

什么是外键&#xff1a; 如果一个实体的某个字段指向另一个实体的主键&#xff0c;就称为外键。被指向的实体&#xff0c;称之为主实体&#xff08;主表&#xff09;&#xff0c;也叫父实体&#xff08;父表&#xff09;。负责指向的实体&#xff0c;称之为从实体&#xff08;…
阅读更多...
haproxy keepalived_Haproxy+KeepAlived+Mycat实现高可用集群

haproxy keepalived_Haproxy+KeepAlived+Mycat实现高可用集群

1.什么是HaproxyHAProxy是一个使用C语言编写的自由及开放源代码软件[1]&#xff0c;其提供高可用性、负载均衡&#xff0c;以及基于TCP和HTTP的应用程序代理。HAProxy特别适用于那些负载特大的web站点&#xff0c;这些站点通常又需要会话保持或七层处理。HAProxy运行在当前的硬…
阅读更多...
IO与NIO

IO与NIO

1、阻塞与非阻塞 阻塞与非阻塞是描述进程在访问某个资源时&#xff0c;数据是否准备就绪的的一种处理方式。当数据没有准备就绪时&#xff1a; 阻塞&#xff1a;线程持续等待资源中数据准备完成&#xff0c;直到返回响应结果。非阻塞&#xff1a;线程直接返回结果&#xff0c…
阅读更多...
java spark wordcount_提交任务到spark（以wordcount为例）

java spark wordcount_提交任务到spark（以wordcount为例）

1、首先需要搭建好hadoopspark环境&#xff0c;并保证服务正常。本文以wordcount为例。2、创建源文件&#xff0c;即输入源。hello.txt文件&#xff0c;内容如下&#xff1a;tom jerryhenry jimsuse lusy注&#xff1a;以空格为分隔符3、然后执行如下命令&#xff1a;hadoop fs…
阅读更多...
python类百度百科_Python抓取百度百科数据

python类百度百科_Python抓取百度百科数据

抓取策略确定目标&#xff1a;确定抓取哪个网站的哪些页面的哪部分数据。本实例抓取百度百科python词条页面以及python相关词条页面的标题和简介。 分析目标&#xff1a;分析要抓取的url的格式&#xff0c;限定抓取范围。分析要抓取的数据的格式&#xff0c;本实例中就要分析标…
阅读更多...
redis的四大特性和原理

redis的四大特性和原理

一、redis的过期 A.应用场景 cookie自动过期&#xff0c;限时优惠价格&#xff0c;限制每分钟的访问次数 B.实现方式 setex(String key, int seconds, String value) expire key time #秒 pexpire key time #毫秒 expireat key time #秒 pexpireat key time #毫秒 C.实…
阅读更多...
java ssh 那一层应该捕获异常_ssh经典异常！

java ssh 那一层应该捕获异常_ssh经典异常！

我对异常抛出的情况作啦一个总结&#xff0c;下面的是我在做项目的时候&#xff0c;处理抛出来的经典异常。严重: action: nulljava.lang.ClassNotFoundException: org.springframework.web.struts.ContextLoaderPlugInat org.apache.catalina.loader.WebappClassLoader.loadCl…
阅读更多...
默认文献工具_工具分享??超好用的SCI外文文献下载工具

默认文献工具_工具分享??超好用的SCI外文文献下载工具

第一步&#xff1a;打开工具第二步&#xff1a;查找目标文献的DOI号&#xff08;知网、谷歌学术等等...&#xff09;&#xff0c;然后复制。第三步&#xff1a;粘贴到工具里面&#xff0c;然后点击「立即下载」第四步&#xff1a;点击立即下载之后&#xff0c;会自动打开默认浏…
阅读更多...
java 变量的调用方法_java类变量的调用方式

java 变量的调用方法_java类变量的调用方式

java类变量的调用方式从类的内部调用类变量&#xff0c;可以使用类名.变量&#xff0c;也可以直接使用变量进行调用&#xff1a;public class Test {static byte a 1;static short b 2;​public static void main(String[] args) {System.out.println("a"a);System…
阅读更多...
Redis之Redis的事务

Redis之Redis的事务

1.Redis的事务是什么 Redis 事务的本质是一组命令的集合,事务支持一次执行多个命令&#xff0c;一个事务中所有命令都会被序列化。(redis事务就是一次性、顺序性、排他性的执行一个队列中的一系列命令). 1.1reids事务的特点 事务同命令一样都是Redis最小的执行单位&#xff0…
阅读更多...
idea 设置内存_IDEA新特性：提前知道代码怎么走！

idea 设置内存_IDEA新特性：提前知道代码怎么走！

作者&#xff1a;简简单单OnlineZuozuo原文链接&#xff1a;https://blog.csdn.net/qq_15071263/article/details/104186309新特性IDEA - 2020.1 版本针对调试器和代码分析器的改进&#xff0c;值得期待1、对于调试器的加强&#xff1a;数据流分析辅助2、调试加强&#xff1a;属…
阅读更多...
64位ie加载java失败_java-无法在AMD 64位平台上加载IA 32位.dll

64位ie加载java失败_java-无法在AMD 64位平台上加载IA 32位.dll

java-无法在AMD 64位平台上加载IA 32位.dll我正在尝试通过此页面上的JNI包装器使用Java中的SVMLight&#xff1a;static {System.loadLibrary("lib/JNI_SVM-light-6.01/lib/svmlight");}我收到以下错误&#xff1a;... lib \ JNI_SVM-light-6.01 \ lib \ svmlight.dl…
阅读更多...
Redis的内部运作机制——Redis详解

Redis的内部运作机制——Redis详解

本文将分五个部分来分析和总结Redis的内部机制&#xff0c;分别是&#xff1a;Redis数据库、Redis客户端、Redis事件、Redis服务器的初始化步骤、Redis命令的执行过程。 首先介绍一下Redis服务器的状态结构。Redis使用一个类型为“redisServer”的数据结构来保存整个Redis服务…
阅读更多...
最新文章

Copyright @ 2022~2023