root
/
Netty_Study
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Day1

This commit is contained in:
Zerroi 2024-04-20 12:33:43 +08:00
commit 578b0f553b
11 changed files with 388 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
.gitignore vendored Normal file
View File

@ -0,0 +1,2 @@
.idea
/target

45
pom.xml Normal file
View File

@ -0,0 +1,45 @@
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.zerroi</groupId>
<artifactId>netty</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>17</maven.compiler.source>
<maven.compiler.target>17</maven.compiler.target>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies>
<dependency>
<groupId>io.netty</groupId>
<artifactId>netty-all</artifactId>
<version>4.1.101.Final</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.30</version>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>2.10.1</version>
</dependency>
<dependency>
<groupId>com.google.guava</groupId>
<artifactId>guava</artifactId>
<version>19.0</version>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>1.4.11</version>
</dependency>
</dependencies>
</project>

7
src/main/java/com/zerroi/netty/charpter01/Test1.java Normal file
View File

@ -0,0 +1,7 @@
package com.zerroi.netty.charpter01;
public class Test1 {
public static void main(String[] args) {
}
}

16
src/main/resources/logback.xml Normal file
View File

@ -0,0 +1,16 @@
<?xml version="1.0" encoding="UTF-8"?>
<configuration>
<!-- 控制台输出 -->
<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
<encoder>
<pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} - %msg%n</pattern>
</encoder>
</appender>
<!-- 日志级别 -->
<root level="INFO">
<appender-ref ref="CONSOLE" />
</root>
</configuration>

183
src/test/java/com/zerroi/netty/chapter01/ByteBufferUtil.java Normal file
View File

@ -0,0 +1,183 @@
package com.zerroi.netty.chapter01;
import io.netty.util.internal.StringUtil;
import java.nio.ByteBuffer;
import static io.netty.util.internal.MathUtil.isOutOfBounds;
import static io.netty.util.internal.StringUtil.NEWLINE;
public class ByteBufferUtil {
private static final char[] BYTE2CHAR = new char[256];
private static final char[] HEXDUMP_TABLE = new char[256 * 4];
private static final String[] HEXPADDING = new String[16];
private static final String[] HEXDUMP_ROWPREFIXES = new String[65536 >>> 4];
private static final String[] BYTE2HEX = new String[256];
private static final String[] BYTEPADDING = new String[16];
static {
final char[] DIGITS = "0123456789abcdef".toCharArray();
for (int i = 0; i < 256; i++) {
HEXDUMP_TABLE[i << 1] = DIGITS[i >>> 4 & 0x0F];
HEXDUMP_TABLE[(i << 1) + 1] = DIGITS[i & 0x0F];
}
int i;
// Generate the lookup table for hex dump paddings
for (i = 0; i < HEXPADDING.length; i++) {
int padding = HEXPADDING.length - i;
StringBuilder buf = new StringBuilder(padding * 3);
for (int j = 0; j < padding; j++) {
buf.append(" ");
}
HEXPADDING[i] = buf.toString();
}
// Generate the lookup table for the start-offset header in each row (up to 64KiB).
for (i = 0; i < HEXDUMP_ROWPREFIXES.length; i++) {
StringBuilder buf = new StringBuilder(12);
buf.append(NEWLINE);
buf.append(Long.toHexString(i << 4 & 0xFFFFFFFFL | 0x100000000L));
buf.setCharAt(buf.length() - 9, '|');
buf.append('|');
HEXDUMP_ROWPREFIXES[i] = buf.toString();
}
// Generate the lookup table for byte-to-hex-dump conversion
for (i = 0; i < BYTE2HEX.length; i++) {
BYTE2HEX[i] = ' ' + StringUtil.byteToHexStringPadded(i);
}
// Generate the lookup table for byte dump paddings
for (i = 0; i < BYTEPADDING.length; i++) {
int padding = BYTEPADDING.length - i;
StringBuilder buf = new StringBuilder(padding);
for (int j = 0; j < padding; j++) {
buf.append(' ');
}
BYTEPADDING[i] = buf.toString();
}
// Generate the lookup table for byte-to-char conversion
for (i = 0; i < BYTE2CHAR.length; i++) {
if (i <= 0x1f || i >= 0x7f) {
BYTE2CHAR[i] = '.';
} else {
BYTE2CHAR[i] = (char) i;
}
}
}
/**
* 打印所有内容
* @param buffer
*/
public static void debugAll(ByteBuffer buffer) {
int oldlimit = buffer.limit();
buffer.limit(buffer.capacity());
StringBuilder origin = new StringBuilder(256);
appendPrettyHexDump(origin, buffer, 0, buffer.capacity());
System.out.println("+--------+-------------------- all ------------------------+----------------+");
System.out.printf("position: [%d], limit: [%d]\n", buffer.position(), oldlimit);
System.out.println(origin);
buffer.limit(oldlimit);
}
/**
* 打印可读取内容
* @param buffer
*/
public static void debugRead(ByteBuffer buffer) {
StringBuilder builder = new StringBuilder(256);
appendPrettyHexDump(builder, buffer, buffer.position(), buffer.limit() - buffer.position());
System.out.println("+--------+-------------------- read -----------------------+----------------+");
System.out.printf("position: [%d], limit: [%d]\n", buffer.position(), buffer.limit());
System.out.println(builder);
}
public static void main(String[] args) {
ByteBuffer buffer = ByteBuffer.allocate(10);
buffer.put(new byte[]{97, 98, 99, 100});
debugAll(buffer);
}
private static void appendPrettyHexDump(StringBuilder dump, ByteBuffer buf, int offset, int length) {
if (isOutOfBounds(offset, length, buf.capacity())) {
throw new IndexOutOfBoundsException(
"expected: " + "0 <= offset(" + offset + ") <= offset + length(" + length
+ ") <= " + "buf.capacity(" + buf.capacity() + ')');
}
if (length == 0) {
return;
}
dump.append(
" +-------------------------------------------------+" +
NEWLINE + " | 0 1 2 3 4 5 6 7 8 9 a b c d e f |" +
NEWLINE + "+--------+-------------------------------------------------+----------------+");
final int startIndex = offset;
final int fullRows = length >>> 4;
final int remainder = length & 0xF;
// Dump the rows which have 16 bytes.
for (int row = 0; row < fullRows; row++) {
int rowStartIndex = (row << 4) + startIndex;
// Per-row prefix.
appendHexDumpRowPrefix(dump, row, rowStartIndex);
// Hex dump
int rowEndIndex = rowStartIndex + 16;
for (int j = rowStartIndex; j < rowEndIndex; j++) {
dump.append(BYTE2HEX[getUnsignedByte(buf, j)]);
}
dump.append(" |");
// ASCII dump
for (int j = rowStartIndex; j < rowEndIndex; j++) {
dump.append(BYTE2CHAR[getUnsignedByte(buf, j)]);
}
dump.append('|');
}
// Dump the last row which has less than 16 bytes.
if (remainder != 0) {
int rowStartIndex = (fullRows << 4) + startIndex;
appendHexDumpRowPrefix(dump, fullRows, rowStartIndex);
// Hex dump
int rowEndIndex = rowStartIndex + remainder;
for (int j = rowStartIndex; j < rowEndIndex; j++) {
dump.append(BYTE2HEX[getUnsignedByte(buf, j)]);
}
dump.append(HEXPADDING[remainder]);
dump.append(" |");
// Ascii dump
for (int j = rowStartIndex; j < rowEndIndex; j++) {
dump.append(BYTE2CHAR[getUnsignedByte(buf, j)]);
}
dump.append(BYTEPADDING[remainder]);
dump.append('|');
}
dump.append(NEWLINE +
"+--------+-------------------------------------------------+----------------+");
}
private static void appendHexDumpRowPrefix(StringBuilder dump, int row, int rowStartIndex) {
if (row < HEXDUMP_ROWPREFIXES.length) {
dump.append(HEXDUMP_ROWPREFIXES[row]);
} else {
dump.append(NEWLINE);
dump.append(Long.toHexString(rowStartIndex & 0xFFFFFFFFL | 0x100000000L));
dump.setCharAt(dump.length() - 9, '|');
dump.append('|');
}
}
public static short getUnsignedByte(ByteBuffer buffer, int index) {
return (short) (buffer.get(index) & 0xFF);
}
}

11
src/test/java/com/zerroi/netty/chapter01/TestAllocateByteBuffer.java Normal file
View File

@ -0,0 +1,11 @@
package com.zerroi.netty.chapter01;
import java.nio.Buffer;
import java.nio.ByteBuffer;
public class TestAllocateByteBuffer {
public static void main(String[] args) {
System.out.println(ByteBuffer.allocate(10).getClass());
System.out.println(ByteBuffer.allocateDirect(10).getClass());
}
}

41
src/test/java/com/zerroi/netty/chapter01/TestBuffer.java Normal file
View File

@ -0,0 +1,41 @@
package com.zerroi.netty.chapter01;
import lombok.extern.slf4j.Slf4j;
import java.io.FileInputStream;
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;
@Slf4j
public class TestBuffer {
public static void main(String[] args) {
// FileChannel
// 输入输出流 RandomAccessFile
try (FileChannel channel = new FileInputStream("text.txt").getChannel()) {
// 缓存区
ByteBuffer buffer = ByteBuffer.allocate(10);
/* //channel读取数据，向buffer中写入
int len = channel.read(buffer);
buffer.flip();
while (buffer.hasRemaining()) {
char c = (char) buffer.get();
log.info("{}", c);
}*/
int len = 0;
while ((len = channel.read(buffer)) != -1) {
log.debug("{}", len);
buffer.flip();
while (buffer.hasRemaining()) {
char c = (char) buffer.get();
log.info("{}", c);
}
buffer.clear();
}
} catch (IOException e) {
}
}
}

25
src/test/java/com/zerroi/netty/chapter01/TestBufferReadWrite.java Normal file
View File

@ -0,0 +1,25 @@
package com.zerroi.netty.chapter01;
import java.nio.ByteBuffer;
import static com.zerroi.netty.chapter01.ByteBufferUtil.debugAll;
public class TestBufferReadWrite {
public static void main(String[] args) {
ByteBuffer buffer = ByteBuffer.allocate(10);
buffer.put((byte) 0x61);
// debugAll(buffer);
buffer.put(new byte[]{0x62, 0x63, 0x64});
// debugAll(buffer);
buffer.flip();
debugAll(buffer);
byte b = buffer.get();
debugAll(buffer);
buffer.compact();
debugAll(buffer);
buffer.put(new byte[]{0x65, 0x66, 0x67});
debugAll(buffer);
}
}

30
src/test/java/com/zerroi/netty/chapter01/TestByteBufferRead.java Normal file
View File

@ -0,0 +1,30 @@
package com.zerroi.netty.chapter01;
import java.nio.ByteBuffer;
import static com.zerroi.netty.chapter01.ByteBufferUtil.debugAll;
public class TestByteBufferRead {
public static void main(String[] args) {
ByteBuffer buffer = ByteBuffer.allocateDirect(10);
buffer.put(new byte[]{'a', 'b', 'c', 'd'});
buffer.flip();
// buffer.get(new byte[4]);
// debugAll(buffer);
// buffer.rewind();
// buffer.get();
// debugAll(buffer);
System.out.println(((char) buffer.get()));
System.out.println(((char) buffer.get()));
debugAll(buffer);
buffer.mark();
System.out.println(((char) buffer.get()));
System.out.println(((char) buffer.get()));
buffer.reset();
System.out.println(((char) buffer.get()));
System.out.println(((char) buffer.get()));
debugAll(buffer);
}
}

27
src/test/java/com/zerroi/netty/chapter01/TestByteBufferString.java Normal file
View File

@ -0,0 +1,27 @@
package com.zerroi.netty.chapter01;
import java.io.UnsupportedEncodingException;
import java.nio.ByteBuffer;
import java.nio.charset.StandardCharsets;
import static com.zerroi.netty.chapter01.ByteBufferUtil.debugAll;
public class TestByteBufferString {
public static void main(String[] args) throws UnsupportedEncodingException {
ByteBuffer buffer = ByteBuffer.allocate(16);
buffer.put("Hello".getBytes(StandardCharsets.UTF_8));
debugAll(buffer);
ByteBuffer hello = StandardCharsets.UTF_8.encode("Hello");
debugAll(hello);
ByteBuffer hello2 = ByteBuffer.wrap("Hello".getBytes());
debugAll(hello2);
String str = StandardCharsets.UTF_8.decode(hello2).toString();
// System.out.println("str = " + str);
buffer.flip();
String str1 = StandardCharsets.UTF_8.decode(buffer).toString();
System.out.println(str1);
}
}

1
text.txt Normal file
View File

@ -0,0 +1 @@
12389127636asnkjd