Rust之Substrate框架中Core详解

// 定义一个区块结构体
#[derive(Clone)]
pub struct Block {
    header: Header,
    extrinsics: Vec<Extrinsic>,
}

// 定义一个区块头结构体
#[derive(Clone)]
pub struct Header {
    parent_hash: Hash,
    number: BlockNumber,
    state_root: Hash,
    extrinsics_root: Hash,
    digest: Digest,
}

// 配置P2P网络
let mut network_config = NetworkConfiguration::new(
    "my-node",
    "my-node",
    Default::default(),
    None,
);
network_config.boot_nodes = config.network.bootnodes;
network_config.net_config_path = Some(config_dir.join("network"));

// 配置Aura共识算法
let aura = sc_finality_grandpa::GrandpaBlockImport::new(
    client.clone(),
    &(client.clone() as Arc<_>),
    select_chain,
    telemetry.as_ref().map(|x| x.handle()),
);

let import_queue = sc_consensus_aura::import_queue::<_, _, _, AuraPair, _, _>(
    sc_consensus_aura::slot_duration(&*client)?,
    aura,
    None,
    Some(Box::new(justification_import)),
    client,
    InherentDataProviders::new(),
    spawner,
    telemetry.as_ref

// 实现区块同步功能
fn sync_blocks(&self) {
    // 获取本地区块高度
    let local_height = self.backend.blockchain().info().best_number;
    // 获取网络区块高度
    let network_height = self.network.best_seen_block().unwrap_or(Zero::zero());
    // 判断是否需要同步
    if network_height > local_height {
        // 执行区块同步操作
        // ...
    }
}

// 实现交易池管理功能
fn manage_transaction_pool(&self) {
    // 获取交易池中的所有交易
    let transactions = self.transaction_pool.ready();
    // 按照手续费排序
    let sorted_transactions = transactions.sorted_by(|a, b| b.fee.cmp(&a.fee));
    // 选择前N个交易
    let selected_transactions = sorted_transactions.take(N);
    // ...
}
复制代码

curl https://sh.rustup.rs -sSf | sh

carGo install substrate --git Https://GitHub.com/paritytech/substrate.git --tag <version>

// 定义一个运行时模块
decl_module! {
    pub struct Module<T: Trait> for enum Call where origin: T::Origin {
    // 定义一个调用函数 
    #[weight = 0] 
    pub fn my_call(origin, value: u64) -> DispatchResult {
    let sender = ensure_signed(origin)?;
    // 更新存储项
    MyValue::<T>::insert(&sender, value); Ok(()) 
      } 
     } 
    }

# 启动节点
./target/release/substrate --chain my-chain.JSON

// 定义一个运行时模块
decl_module! {
    pub struct Module<T: Trait> for enum Call where origin: T::Origin {
        // 定义一个调用函数
        #[weight = 0]
        pub fn transfer(origin, to: T::AccountId, value: BalanceOf<T>) -> DispatchResult {
            let sender = ensure_signed(origin)?;
            // 执行转账操作
            T::Currency::transfer(&sender, &to, value, ExistenceRequirement::AllowDeath)?;
            Ok(())
        }
    }
}

// 定义一个运行时模块
decl_module! {
    pub struct Module<T: Trait> for enum Call where origin: T::Origin {
        // 定义一个调用函数
        #[weight = 0]
        pub fn issue_loan(origin, to: T::AccountId, value: BalanceOf<T>) -> DispatchResult {
            let sender = ensure_signed(origin)?;
            // 检查发放贷款的权限 
            ensure!(sender == T::LoanIssuer::get(), Error::<T>::NotAuthorized); 
            // 发放贷款 
            T::Currency::deposit_creating(&to, value);
            Ok(()) 
                } 
              } 
            }

// 定义一个运行时模块
decl_module! {
    pub struct Module<T: Trait> for enum Call where origin: T::Origin {
        // 定义一个调用函数
        #[weight = 0]
        pub fn issue_asset(origin, to: T::AccountId, value: BalanceOf<T>) -> DispatchResult {
            let sender = ensure_signed(origin)?;
            // 检查发行资产的权限
            ensure!(sender == T::AssetIssuer::get(), Error::<T>::NotAuthorized);
            // 发行资产
            T::Currency::deposit_creating(&to, value);
            Ok(())
        }
    }
}