Welcome to My Blog!

这里记录着我的java后端学习之路

NIO

2020-08-01

百味皆苦

网络编程

Nginx

简介

简介

Java NIO（New IO）是从Java 1.4版本开始引入的一个新的IO API，可以替代标准的Java IO API。 NIO与原来的IO有同样的作用和目的，但是使用的方式完全不同，NIO支持面向缓冲区的、基于通道的IO操作。NIO将以更加高效的方式进行文件的读写操作。

NIO与IO的区别

IO	NIO
面向流（Stream Oriented）	面向缓冲区（Buffer Oriented）
阻塞IO（Blocking IO）	非阻塞IO（Non Blocking IO）
无	选择器（Selectors）

传统的IO 流都是阻塞式的。也就是说，当一个线程调用read() 或write()时，该线程被阻塞，直到有一些数据被读取或写入，该线程在此期间不能执行其他任务。因此，在完成网络通信进行IO 操作时，由于线程会阻塞，所以服务器端必须为每个客户端都提供一个独立的线程进行处理，当服务器端需要处理大量客户端时，性能急剧下降。
Java NIO 是非阻塞模式的。当线程从某通道进行读写数据时，若没有数据可用时，该线程可以进行其他任务。线程通常将非阻塞IO 的空闲时间用于在其他通道上执行IO 操作，所以单独的线程可以管理多个输入和输出通道。因此，NIO 可以让服务器端使用一个或有限几个线程来同时处理连接到服务器端的所有客户端。

Read All

Nginx

2020-06-30

百味皆苦

Nginx

Nginx
- 简介
  - 正向代理
简介
- Nginx是一个高性能的HTTP和反向代理服务器，特点是占用内存少，并发能力强，事实上Nginx的并发能力确实在同类型的网页服务器中表现良好
- Nginx可以作为静态页面的web服务器，不支持java。java程序只能通过与tomcat配合完成。Nginx专为性能优化而开发，性能是最重要的考量，实现上非常注重效率，能经受高负载的考验，大概能支持高达50000个并发连接数。
正向代理
- Nginx 不仅可以做反向代理，实现负载均衡。还能用作正向代理来进行上网等功能。
- 正向代理：如果把局域网外的 Internet 想象成一个巨大的资源库，则局域网中的客户端要访问Internet，则需要通过代理服务器来访问，这种代理服务就称为正向代理。
Read All

（MK）socket网络编程进阶与实战

2020-04-29

百味皆苦

网络编程

网络编程
- 通讯demo

网络编程

什么是网络：
- 在计算机领域中，网络是信息传输、接收、共享的虚拟平台。
- 通过它把各个点、面、体的信息联系到一起，从而实现这些资源的共享
什么是网络编程：
- 网络编程从大的方面说就是对信息的发送到接收
- 通过操作相应的Api调度计算机硬件资源，并利用传输管道（网线）进行数据交换的过程。
- 更为具体的涉及：网络模型，套接字，数据包
七层网络模型-OSI

基础层：物理层（physical），数据链路层（datalink），网络层（network）
传输层（transport）：TCP-UDP协议层、socket
高级层：会话层（session），表示层（presentation），应用层（application）
什么是socket：简单来说就是IP地址与端口的结合协议（RFC 793），一种地址与端口的结合描述协议
socket作用与组成
- 在网络传输中用于唯一标示两个端点之间的链接
- 端点包括ip和port
- 四个要素：客户端地址，客户端端口，服务器地址，服务器端口
socket之TCP：
- TCP是面向连接的通信协议
- 通过三次握手建立连接，通讯完成时要拆除连接
- 由于TCP是面向连接的，所以只能用于端到端的通讯
socket之UDP
- UDP是面向无连接的通讯协议
- UDP数据包括目的端口号和源端口号信息
- 由于通讯不需要连接，所以可以实现广播发送，并不局限于端到端

通讯demo

客户端

public class Client{
	public static void main(String[] args) throws IOException{
		Socket socket = new Socket();
		//超时时间
		socket.setSoTimeout(3000);
		//连接本地，端口2000，超时时间3000ms
		socket.connect(new InetSocketAddress(InetSocketAddress.getLocalHost(),2000),3000);

		System.out.printf("已发起服务器连接，并进入后续流程~");
		System.out.printf("客户端信息："+socket.getLocalAddress()+"P:"+socket.getLocalPort());
		System.out.printf("服务器信息："+socket.getInetAddress()+"P:"+socket.getPort());

		try{
			todo(socket);
		}catch(Exception e){
			System.out.printf("异常关闭");
		}

		socket.close();
		System.out.printf("客户端已退出");
	}

	private static void todo(Socket client) throws IOException{
		//构建键盘输入流
		InputStream in = System.in;
		BufferedReader input = new BufferedReader(new InputStreamReader(in));

		//得到socket输出流，并转换为打印流
		OutputStream outputStream = client.getOutputStream();
		PrintStream socketPrintStream = new PrintStream(outputStream);

		//得到socket输入流，并转换为BufferedReader
		InputStream inputStream = client.getInputStream();
		BufferedReader socketBufferedReader = new BufferedReader(new InputStreamReader(inputStream));

		boolean flag = true;
		do{
			//键盘读取一行
			String str = input.readLine();
			//发送到服务器
			socketPrintStream.println(str);

			//从服务器读取一行
			String echo = socketBufferedReader.readLine();
			if ("bye".equalsIgnoreCase(echo)) {
				flag = false;
			}else{
				System.out.println(echo);
			}
		}while(flag);

		//资源释放
		socketPrintStream.close();
		socketBufferedReader.close();		
	}
}

服务端

public class Server{
	public static void main(String[] args) throws IOexception{
		ServerSocket server = new ServerSocket(2000);

		System.out.printf("服务器准备就绪~");
		System.out.printf("服务器信息:"+server.getInetAddress()+" P:"+server.getLocalPort());

		//等待客户端连接
		for (; ; ) {
			//得到客户端
			Socket client = server.accept();
			//客户端构建异步线程
			ClientHandler clientHandler = new ClientHandler(client);
			//启动线程
			clientHandler.start();
		}
		
		
	}

	//客户端消息处理
	private static class ClientHandler extends Thread{
		private Socket socket;
		private boolean flag = true;

		ClientHandler(Socket socket){
			this.socket = socket;
		}

		@Override
        public void run() {
            super.run();
            System.out.println("新客户端连接：" + socket.getInetAddress() +
                    " P:" + socket.getPort());

            try {
                // 得到打印流，用于数据输出；服务器回送数据使用
                PrintStream socketOutput = new PrintStream(socket.getOutputStream());
                // 得到输入流，用于接收数据
                BufferedReader socketInput = new BufferedReader(new InputStreamReader(
                        socket.getInputStream()));

                do {
                    // 客户端拿到一条数据
                    String str = socketInput.readLine();
                    if ("bye".equalsIgnoreCase(str)) {
                        flag = false;
                        // 回送
                        socketOutput.println("bye");
                    } else {
                        // 打印到屏幕。并回送数据长度
                        System.out.println(str);
                        socketOutput.println("回送：" + str.length());
                    }

                } while (flag);

                socketInput.close();
                socketOutput.close();

            } catch (Exception e) {
                System.out.println("连接异常断开");
            } finally {
                // 连接关闭
                try {
                    socket.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }

            System.out.println("客户端已退出：" + socket.getInetAddress() +
                    " P:" + socket.getPort());

        }
	}
}

Read All

13/58

Welcome to My Blog!

NIO

简介

Nginx

简介

正向代理

（MK）socket网络编程进阶与实战

网络编程

通讯demo