前言

这段时间一直在学习Netty相关知识，因为涉及知识点比较多，也走了不少弯路。目前网上关于Netty学习资料琳琅满目，不知如何下手，其实大家都是一样的，学习方法和技巧都是总结出来的，我们在没有找到很好的方法之前不如按部就班先从基础开始，一般从总分总的渐进方式，既观森林，又见草木。

Netty是一款提供异步的、事件驱动的网络应用程序框架和工具，是基于NIO客户端、服务器端的编程框架。所以这里我们先以NIO和依赖相关的基础铺垫来进行剖析讲解，从而作为Netty学习之旅的一个开端。

RPC概述

RPC(Remote Procedure Call)即远程过程调用，允许一台计算机调用另一台计算机上的程序得到结果，而代码中不需要做额外的编程，就像在本地调用一样。

现在互联网应用的量级越来越大，单台计算机的能力有限，需要借助可扩展的计算机集群来完成，分布式的应用可以借助RPC来完成机器之间的调用。

RPC框架原理

在RPC框架中主要有三个角色：Provider、Consumer和Registry。如下图所示：

节点角色说明：

• Server: 暴露服务的服务提供方。

• Client: 调用远程服务的服务消费方。

• Registry: 服务注册与发现的注册中心。

RPC调用流程

RPC基本流程图：

一次完整的RPC调用流程（同步调用，异步另说）如下：

1）服务消费方（client）调用以本地调用方式调用服务；

2）client stub接收到调用后负责将方法、参数等组装成能够进行网络传输的消息体；

3）client stub找到服务地址，并将消息发送到服务端；

4）server stub收到消息后进行解码；

5）server stub根据解码结果调用本地的服务；

6）本地服务执行并将结果返回给server stub；

7）server stub将返回结果打包成消息并发送至消费方；

8）client stub接收到消息，并进行解码；

9）服务消费方得到最终结果。

RPC框架的目标就是要2~8这些步骤都封装起来，让用户对这些细节透明。

服务注册&发现

服务提供者启动后主动向注册中心注册机器ip、port以及提供的服务列表；

服务消费者启动时向注册中心获取服务提供方地址列表，可实现软负载均衡和Failover；

使用到的技术

1、动态代理

生成 client stub和server stub需要用到 Java 动态代理技术 ，我们可以使用JDK原生的动态代理机制，可以使用一些开源字节码工具框架 如：CgLib、Javassist等。

2、序列化

为了能在网络上传输和接收 Java对象，我们需要对它进行 序列化和反序列化操作。

• 序列化：将Java对象转换成byte[]的过程，也就是编码的过程；

• 反序列化：将byte[]转换成Java对象的过程；

可以使用Java原生的序列化机制，但是效率非常低，推荐使用一些开源的、成熟的序列化技术，例如：protobuf、Thrift、hessian、Kryo、Msgpack

关于序列化工具性能比较可以参考：jvm-serializers

3、NIO

当前很多RPC框架都直接基于netty这一IO通信框架，比如阿里巴巴的HSF、dubbo，Hadoop Avro，推荐使用Netty 作为底层通信框架。

4、服务注册中心

可选技术：

• Redis

• Zookeeper

• Consul

• Etcd

编程实践：手写实现千万级流量架构必备的RPC框架

视频内容

1、为什么千万级流量分布式、微服务架构都有RPC？
2、什么是RPC？
3、辨析RPC和HTTP
4、实现RPC框架我们需要解决哪些问题？
5、具体问题具体分析，各个解决和实现！
6、应付千万级流量，这样够了吗？反思我们的实现。
7、Dubbo和SpringCloud哪个更好？

Spring全套教学资料

Spring是Java程序员的《葵花宝典》，其中提供的各种大招，能简化我们的开发，大大提升开发效率！目前99%的公司使用了Spring，大家可以去各大招聘网站看一下，Spring算是必备技能，所以一定要掌握。

资料领取方式：点击这里前往蓝色传送门

目录：

部分内容：

Spring源码

• 第一部分 Spring 概述
• 第二部分 核心思想
• 第三部分 手写实现 IoC 和 AOP（自定义Spring框架）
• 第四部分 Spring IOC 高级应用
  基础特性
  高级特性
• 第五部分 Spring IOC源码深度剖析
  设计优雅
  设计模式
  注意：原则、方法和技巧
• 第六部分 Spring AOP 应用
  声明事务控制
• 第七部分 Spring AOP源码深度剖析
  必要的笔记、必要的图、通俗易懂的语言化解知识难点

脚手框架：SpringBoot技术

它的目标是简化Spring应用和服务的创建、开发与部署，简化了配置文件，使用嵌入式web服务器，含有诸多开箱即用的微服务功能，可以和spring cloud联合部署。

Spring Boot的核心思想是约定大于配置，应用只需要很少的配置即可，简化了应用开发模式。

• SpringBoot入门
• 配置文件
• 日志
• Web开发
• Docker
• SpringBoot与数据访问
• 启动配置原理
• 自定义starter

微服务架构：Spring Cloud Alibaba

同 Spring Cloud 一样，Spring Cloud Alibaba 也是一套微服务解决方案，包含开发分布式应用微服务的必需组件，方便开发者通过 Spring Cloud 编程模型轻松使用这些组件来开发分布式应用服务。

• 微服务架构介绍
• Spring Cloud Alibaba介绍
• 微服务环境搭建
• 服务治理
• 服务容错
• 服务网关
• 链路追踪
• ZipKin集成及数据持久化
• 消息驱动
• 短信服务
• Nacos Confifig—服务配置
• Seata—分布式事务
• Dubbo—rpc通信

Spring MVC

目录：

部分内容：

m-1621576255570)]

[外链图片转存中…(img-2cNCHspY-1621576255571)]

[外链图片转存中…(img-AvZ4y84K-1621576255572)]

部分内容：

[外链图片转存中…(img-5D6wTpGe-1621576255572)]

[外链图片转存中…(img-zCzZ1dpH-1621576255573)]

项目场景：

java实现简单的银行存款取款系统

本次代码适合初学者小白，连数据库都没有运用。一次性程序哈哈。

备学内容：

你得先了解java中以下基本内容。
1、 数组
2、 方法
3、 类
4、 Scanner扫描器

学习产果：

：
在写这段代码的过程中，我学到了以下几个知识点：
1、 类和方法的灵活应用。
2、类既然可以数组来使用！！！
3、 数据的相互传递：

系统描述：

当我学完java中的基本知识点之后想实现一个银行存取款系统，就简单实现：
登录，注册，退出，存款，取款转账，查询个人信息等功能。

首先写一个main方法

import java.util.Scanner;     //扫描器
public class bank{
     public static void main(String[] args){
     	Scanner sc = new Scanner(System.in);
     }
 }

main方法创建好之后再 创建一个geren1类，就是保存用户各类信息。

class geren1{
    private String zhanghao;
    private String mima;
    private int zijin=0;
    private String name;
    private int xuhao;
    private String phone;
    //构造方法
    public geren1(String zhanghao,String mima,String name,String phone,int xuhao){
        this.zhanghao = zhanghao;
        this.mima = mima;
        this.name = name;
        this.phone = phone;
        this.xuhao = xuhao;
    }
    //遍历个人信息
    public void print(){
        System.out.println("姓名："+this.getName()+
                "\t\t\t账号："+this.getZhanghao()+
                " \n密码："+this.getMima()+
                "\t\t\t账户资金："+this.getZijin()+
                "\n练习电话："+this.getPhone());
    }

    public String getPhone(){
        return phone;
    }
    public void setPhone(String phone){
        this.phone = phone;
    }
    public int getXuhao(){
        return xuhao;
    }
    public void setXuhao(int xuhao){
        this.xuhao = xuhao;
    }
    public String getName(){
        return name;
    }
    public void setName(String name){
        this.name = name;
    }
    public String getZhanghao(){
        return zhanghao;
    }
    public void setZhanghao(String zhanghao){
        this.zhanghao = zhanghao;
    }
    public String getMima(){
        return mima;
    }
    public void setMima(String mima){
        this.mima = mima;
    }
    public int getZijin(){
        return zijin;
    }
    public void setZijin(int zijin){
        this.zijin = zijin;
    }
}

类创建好了之后在main方法里创建一个geren1类型数组。

我之前还不知道类还能当数组用。意思就是在geren1数组中就放geren1类。
刚开始我用String创建数组，发现“类”不能放在String数组类中。然后我就用Object创建数组，然后把类放进去没有报错。但发现放进去之后拿不出来了，强制类型转换也不行。
最后直接用类类型创建数组，最多也就能放10个，如果想多方几个就把10改成100或者更多就OK了。

 public static void main(String[] args){
 	Scanner sc = new Scanner(System.in);
 	geren1[] user = new geren1[10];
 }

然后就输出一个登录页面，不用认真，简单输出就好！我在main方法外面创建一个xtjiemian()方法，顾名思义就是专门用来显示登录界面的。

public static void xtjiemian(Scanner sc,geren1[] user){
        while (true)
        {
            System.out.println("===银行存取款系统===");
            System.out.println();
            System.out.println("1,登录\t\t2,注册\t\t3,退出");
            int xuanze = sc.nextInt();
            if (xuanze == 1)
            {
                //print(user);
                denglu1(sc,user);
            }else if(xuanze == 2){
                zhuce(sc,user);
                //print(user);
            }else if(xuanze == 3){
                break;
            }
            else{System.out.println("输入有误！");}
        }
    }

然后分别再写两个登录和注册判断的两个方法

	public static void denglu1(Scanner sc,geren1[] user){
        System.out.println("==== 登  录 =====");
        System.out.println("请输入账号：");
        String zh = sc.next();
        System.out.println("请输入密码：");
        String mm = sc.next();

        for (int i = 0;i<user.length;i++){
            System.out.println(user[i]);
            if (user[i] != null){
                geren1 gr = user[i];
                System.out.println(gr.getZijin());
                if (zh.equals(gr.getZhanghao()) && mm.equals(gr.getMima()))
                {
                    System.out.println("登录成功！");
                    grjiemian(sc,user,gr);
                    return;
                }
            }
        }
        System.out.println("无此账号或密码错误！");
    }
    public static void zhuce(Scanner sc, geren1[] user){
        System.out.println("==== 注  册 ====");
        for (int i=0;i<user.length;i++)
        {
            if (user[i] == null)
            {

                System.out.println("请输入注册账号：");
                //user[i][0] = sc.next();
                String zhanghao = sc.next();
                System.out.println("请输入注册密码：");
                //user[i][1] = sc.next();
                String mima = sc.next();
                System.out.println("请输入您的真实姓名：");
                String name = sc.next();
                System.out.println("请输入银行卡号：（手机号即可）");
                //zijin[i][2] = sc.nextInt();
                String phone = sc.next();
                geren1 gr = new geren1(zhanghao,mima,name,phone,i);
                user[i] = gr;
                System.out.println("注册成功");
                return;
            }
        }
    }

最后就是登录后的个人界面

public static void grjiemian(Scanner sc,geren1[] user,geren1 gr){
        while(true){
            System.out.println("==== 个人页面 =====");
            System.out.println("请选择您要办理的业务：");
            System.out.println("1,存款\t\t\t2,取款");
            System.out.println("3,查询余额\t\t4,转账");
            System.out.println("5,查询个人信息\t6,退出登录");
            int xuanze = sc.nextInt();
            if (xuanze == 1){
                System.out.println("请输入存款金额：");
                gr.setZijin(gr.getZijin()+sc.nextInt());
                System.out.println("存款成功，当前余额："+gr.getZijin()+"元");
            }else if (xuanze == 2){
                System.out.println("请输入取款金额：");
                int qk = sc.nextInt();
                if(qk>gr.getZijin()){
                    System.out.println("余额不足。。。");
                }else{
                    gr.setZijin(gr.getZijin()-qk);
                    System.out.println("取款成功，当前余额："+gr.getZijin()+"元");
                }
            }else if(xuanze == 3){
                System.out.println("当前余额："+gr.getZijin()+"元");
            }
            else if(xuanze == 4){
                System.out.println("请输入转账账号：");
                String zh = sc.next();
                System.out.println("请输入转账金额：");
                int jine = sc.nextInt();
                for (int zhao = 0;zhao<user.length;zhao++){
                    if (user[zhao] !=null){
                        geren1 gr1 = user[zhao];
                        if (zh.equals(gr1.getZhanghao())){
                            gr1.setZijin(gr1.getZijin()+jine);
                            gr.setZijin(gr.getZijin() - jine);
                        }
                    }
                }
            }
            else if(xuanze == 5){
                gr.print();
            }
            else if(xuanze == 6){
                return;
            }
        }
    }

把xtjiemian()方法写在main()方法中，大功告成，以下是最后的成品代码。

import java.util.Scanner;

public class denglu2 {
   public static void main(String[] args){
       Scanner sc = new Scanner(System.in);
       geren1[] user = new geren1[10];
       //System.out.println(user[1]);
       xtjiemian(sc,user);
   }
   public static void xtjiemian(Scanner sc,geren1[] user){
       while (true)
       {
           System.out.println("===优就业银行系统===");
           System.out.println();
           System.out.println("1,登录\t\t2,注册\t\t3,退出");
           int xuanze = sc.nextInt();
           if (xuanze == 1)
           {
               //print(user);
               denglu1(sc,user);
           }else if(xuanze == 2){
               zhuce(sc,user);
               //print(user);
           }else if(xuanze == 3){
               break;
           }
           else{System.out.println("输入有误！");}
       }
   }
   public static void zhuce(Scanner sc, geren1[] user){
       System.out.println("==== 注  册 ====");
       for (int i=0;i<user.length;i++)
       {
           if (user[i] == null)
           {

               System.out.println("请输入注册账号：");
               //user[i][0] = sc.next();
               String zhanghao = sc.next();
               System.out.println("请输入注册密码：");
               //user[i][1] = sc.next();
               String mima = sc.next();
               System.out.println("请输入您的真实姓名：");
               String name = sc.next();
               System.out.println("请输入手机号：");
               //zijin[i][2] = sc.nextInt();
               String phone = sc.next();
               geren1 gr = new geren1(zhanghao,mima,name,phone,i);
               user[i] = gr;
               System.out.println("注册成功");
               return;
           }
       }
   }
   public static void denglu1(Scanner sc,geren1[] user){
       System.out.println("==== 登  录 =====");
       System.out.println("请输入账号：");
       String zh = sc.next();
       System.out.println("请输入密码：");
       String mm = sc.next();

       for (int i = 0;i<user.length;i++){
           //System.out.println(user[i]);
           if (user[i] != null){
               geren1 gr = user[i];
               //System.out.println(gr.getZijin());
               if (zh.equals(gr.getZhanghao()) && mm.equals(gr.getMima()))
               {
                   System.out.println("登录成功！");
                   grjiemian(sc,user,gr);
                   return;
               }
           }
       }
       System.out.println("无此账号或密码错误！");
   }
   public static void grjiemian(Scanner sc,geren1[] user,geren1 gr){

       while(true){
           System.out.println("==== 个人页面 =====");
           System.out.println("请选择您要办理的业务：");
           System.out.println("1,存款\t\t\t2,取款");
           System.out.println("3,查询余额\t\t4,转账");
           System.out.println("5,查询个人信息\t6,退出登录");
           int xuanze = sc.nextInt();
           if (xuanze == 1){
               System.out.println("请输入存款金额：");
               gr.setZijin(gr.getZijin()+sc.nextInt());
               System.out.println("存款成功，当前余额："+gr.getZijin()+"元");
           }else if (xuanze == 2){
               System.out.println("请输入取款金额：");
               int qk = sc.nextInt();
               if(qk>gr.getZijin()){
                   System.out.println("余额不足。。。");
               }else{
                   gr.setZijin(gr.getZijin()-qk);
                   System.out.println("取款成功，当前余额："+gr.getZijin()+"元");
               }
           }else if(xuanze == 3){
               System.out.println("当前余额："+gr.getZijin()+"元");
           }
           else if(xuanze == 4){
               System.out.println("请输入转账账号：");
               String zh = sc.next();
               System.out.println("请输入转账金额：");
               int jine = sc.nextInt();
               for (int zhao = 0;zhao<user.length;zhao++){
                   if (user[zhao] !=null){
                       geren1 gr1 = user[zhao];
                       if (zh.equals(gr1.getZhanghao())){
                           gr1.setZijin(gr1.getZijin()+jine);
                           gr.setZijin(gr.getZijin() - jine);
                       }
                   }
               }
           }
           else if(xuanze == 5){
               gr.print();
           }
           else if(xuanze == 6){
               return;
           }
       }
   }
}

代码其实可以再优化以下，有一些代码可以合并。

效果图：

package com.coding.study09;

import java.util.Scanner;

public class Demo01 {
	public static void main(String[] args) {
		Scanner scanner = new Scanner(System.in);
		while (true) {
			System.out.println("------欢迎使用自助存取款系统------");
			System.out.println("请输入账户密码（首次使用请按#注册）：");
			String account = scanner.nextLine();
			if (account.equals("#")) {
				System.out.println("请输入新的账户：");
				String account1 = scanner.nextLine();
				System.out.println("请输入密码：");
				String passwd1 = scanner.nextLine();
				System.out.println("请输入用户姓名：");
				String name1 = scanner.nextLine();
				BankOperate.regist(account1, passwd1, name1);
				continue;
			}
			System.out.println("请输入密码：");
			String passwd2 = scanner.nextLine();
			// BankOperate.logine(account, passwd2);
			boolean result = BankOperate.logine(account, passwd2);
			if (result) {
				System.out.println("登录成功，欢迎" + BankTool.account[BankTool.index].getName() + "光临");
				operate();
			} else {
				System.out.println("输入错误，请重新输入。");
			}
		}
	}

	public static void operate() {
		Scanner scanner1 = new Scanner(System.in);
		while (true) {
			System.out.println("请选择服务项目：");
			System.out.println("1.存款");
			System.out.println("2.取款");
			System.out.println("3.查询");
			System.out.println("4.退出");
			int n = scanner1.nextInt();
			switch (n) {

			case 1:
				System.out.println("请输入存款金额：");
				double money = scanner1.nextDouble();
				BankOperate.save(money);

				break;
			case 2:
				System.out.println("请输入取款金额：");
				double money1 = scanner1.nextDouble();
				BankOperate.take(money1);
				break;
			case 3:
				BankOperate.check();
				break;
			case 4:

				return;

			default:
				System.out.println("输入错误，请重新输入。");
				break;
			}
		}
	}
}
package com.coding.study09;

public class Account {
	String account;
	String passwd;
	String name;
	double money;

	public Account(String account, String passwd, String name) {
		this.account = account;
		this.passwd = passwd;
		this.name = name;
	}

	public String getAccount() {
		return account;
	}

	public void setAccount(String account) {
		this.account = account;
	}

	public String getPasswd() {
		return passwd;
	}

	public void setPasswd(String passwd) {
		this.passwd = passwd;
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public double getMoney() {
		return money;
	}

	public void setMoney(double money) {
		this.money = money;
	}

}
package com.coding.study09;

public class BankOperate {
	public static void regist(String account, String passwd, String name) {
		Account account1 = new Account(account, passwd, name);
		for (int i = 0; i < BankTool.account.length; i++) {
			if (BankTool.account[i] == null) {
				BankTool.account[i] = account1;
				System.out.println("注册成功");
				break;
			}
		}
	}

	public static boolean logine(String account, String passwd) {
		for (int i = 0; i < BankTool.account.length; i++) {
			if (BankTool.account[i] != null) {
				if (account.equals(BankTool.account[i].getAccount())
						&& passwd.equals(BankTool.account[i].getPasswd())) {
					BankTool.index = i;
					return true;
				}
			}
		}
		return false;
	}

	public static void save(double money) {
		BankTool.account[BankTool.index].setMoney(BankTool.account[BankTool.index].getMoney() + money);
		System.out.println("存钱成功");
	}

	public static void take(double money) {
		BankTool.account[BankTool.index].setMoney(BankTool.account[BankTool.index].getMoney() - money);
		System.out.println("取钱成功");
	}

	public static void check() {
		System.out.println("当前账户余额为："+BankTool.account[BankTool.index].getMoney());
	}
}
package com.coding.study09;

public class BankTool {
	public static Account[] account=new Account[100];
	public static int index=0;
}

Demo用来进行测试，Account用来创建账户的set和get方法，BankOperate用来存放注册/登录/存钱/取钱/查询的操作，BankTool定义工具类。