Demo kode CLMM

Halaman ini diterjemahkan secara otomatis oleh AI. Versi bahasa Inggris adalah acuan resmi.Lihat versi bahasa Inggris →

Banner versi. Semua demo menargetkan @raydium-io/raydium-sdk-v2@0.2.42-alpha terhadap Solana mainnet-beta, diverifikasi 2026-04. ID program berasal dari reference/program-addresses melalui SDK.

Setup

npm install @raydium-io/raydium-sdk-v2 @solana/web3.js @solana/spl-token bn.js decimal.js

Setiap demo di halaman ini mencerminkan file dalam raydium-sdk-V2-demo/src/clmm; tautan GitHub berada di samping setiap bagian. Bootstrap mengikuti config.ts.template repo demo (sumber) — disableFeatureCheck: true adalah pengaturan yang direkomendasikan untuk integrasi apa pun yang tidak trivial:

import { Connection, Keypair, clusterApiUrl } from "@solana/web3.js";
import { Raydium, TxVersion } from "@raydium-io/raydium-sdk-v2";
import fs from "node:fs";

const connection = new Connection(process.env.RPC_URL ?? clusterApiUrl("mainnet-beta"));
const owner = Keypair.fromSecretKey(
  new Uint8Array(JSON.parse(fs.readFileSync(process.env.KEYPAIR!, "utf8"))),
);
const raydium = await Raydium.load({
  owner,
  connection,
  cluster: "mainnet",
  disableFeatureCheck: true,
  blockhashCommitment: "finalized",
});
export const txVersion = TxVersion.V0;

Buat pool CLMM

Sumber: src/clmm/createPool.ts

import { PublicKey } from "@solana/web3.js";
import { CLMM_PROGRAM_ID } from "@raydium-io/raydium-sdk-v2";
import BN from "bn.js";
import Decimal from "decimal.js";

const mintA = await raydium.token.getTokenInfo(
  new PublicKey("So11111111111111111111111111111111111111112"));   // wSOL
const mintB = await raydium.token.getTokenInfo(
  new PublicKey("EPjFWdd5AufqSSqeM2qN1xzybapC8G4wEGGkZwyTDt1v"));   // USDC

const ammConfigs = await raydium.api.getClmmConfigs();
const ammConfig  = ammConfigs.find((c) => c.index === 1)!;        // 0.05% tier

const initialPrice = new Decimal(160);        // 160 USDC per SOL
const { execute, extInfo } = await raydium.clmm.createPool({
  programId: CLMM_PROGRAM_ID,
  mint1:     mintA,
  mint2:     mintB,
  ammConfig,
  initialPrice,
  startTime: new BN(0),
  txVersion: TxVersion.V0,
});

const { txId } = await execute({ sendAndConfirm: true });
console.log("Pool:", extInfo.address.id.toBase58(), "tx:", txId);

SDK:

Mengurutkan mint1/mint2 berdasarkan urutan byte sebelum derivasi.
Menghitung sqrt_price_x64 = floor(sqrt(initialPrice × 10^(dB−dA)) × 2^64).
Membuat akun observation dan tick_array_bitmap_extension.
Membayar biaya pembuatan pool yang ditentukan oleh ammConfig.

Buka posisi dalam rentang pilihan

Sumber: src/clmm/createPosition.ts

import { PoolUtils, TickUtils } from "@raydium-io/raydium-sdk-v2";

const poolId = new PublicKey("<POOL_ID>");
const { poolInfo, poolKeys, rpcData } = await raydium.clmm.getPoolInfoFromRpc(poolId);

// Pilih rentang harga. Di sini: ±10% dari harga saat ini.
const currentPrice = new Decimal(poolInfo.price);
const lowerPrice   = currentPrice.mul(0.9);
const upperPrice   = currentPrice.mul(1.1);

// Snap ke tick yang valid untuk tick_spacing pool ini.
const { tick: tickLower } = TickUtils.getPriceAndTick({
  poolInfo, price: lowerPrice, baseIn: true,
});
const { tick: tickUpper } = TickUtils.getPriceAndTick({
  poolInfo, price: upperPrice, baseIn: true,
});

// Berapa banyak setiap token yang akan disimpan.
const inputAmount = new BN(10_000_000);  // 0.01 SOL
const inputMint   = poolInfo.mintA.address;

const res = PoolUtils.getLiquidityAmountOutFromAmountIn({
  poolInfo,
  slippage: 0.01,
  inputA: true,
  tickUpper,
  tickLower,
  amount: inputAmount,
  add: true,
  amountHasFee: true,
  epochInfo: await raydium.fetchEpochInfo(),
});

const { execute } = await raydium.clmm.openPositionFromBase({
  poolInfo,
  poolKeys,
  tickUpper,
  tickLower,
  base: "MintA",
  ownerInfo: { useSOLBalance: true },
  baseAmount: inputAmount,
  otherAmountMax: res.amountSlippageB.amount,
  txVersion: TxVersion.V0,
});

const { txId } = await execute({ sendAndConfirm: true });
console.log("Position opened, tx:", txId);

SDK secara otomatis menghitung tick array mana yang disentuh rentang dan membundel instruksi InitTickArray jika ada yang belum diinisialisasi.

Tingkatkan likuiditas pada posisi yang ada

Sumber: src/clmm/increaseLiquidity.ts

const positionNftMint = new PublicKey("<POSITION_NFT_MINT>");

const positionAccount = await raydium.clmm.getPositionInfo({
  nftMint: positionNftMint,
});

const { execute } = await raydium.clmm.increasePositionFromBase({
  poolInfo,
  poolKeys,
  ownerPosition: positionAccount,
  base: "MintA",
  baseAmount: new BN(5_000_000),
  otherAmountMax: new BN(1_000_000_000),
  txVersion: TxVersion.V0,
});

await execute({ sendAndConfirm: true });

Kurangi likuiditas (dan kumpulkan biaya pada saat yang sama)

Sumber: src/clmm/decreaseLiquidity.ts dan src/clmm/closePosition.ts

const { execute } = await raydium.clmm.decreaseLiquidity({
  poolInfo,
  poolKeys,
  ownerPosition: positionAccount,
  liquidity: positionAccount.liquidity.divn(2),   // halve
  amountMinA: new BN(0),
  amountMinB: new BN(0),
  closePosition: false,
  txVersion: TxVersion.V0,
});

await execute({ sendAndConfirm: true });

Untuk mengumpulkan biaya saja, panggil decreaseLiquidity dengan liquidity = new BN(0). Efek samping instruksi adalah menyelesaikan tokens_fees_owed_{0,1} dan mentransfernya keluar. Untuk menutup posisi sepenuhnya setelah menolkan likuiditas dan biaya, teruskan closePosition: true pada panggilan decreaseLiquidity terakhir. SDK menambahkan ClosePosition dan membakar NFT.

Posisi penerbit terbatas memerlukan pembangun penutup yang kompatibel. Posisi ini memiliki akun token NFT yang beku. ClosePosition harus menambahkan ID pool posisi sebagai akun sisa pertama sehingga CLMM dapat mencairkan akun sebelum membakarnya. Cabang sumber program tidak menyertakan perubahan SDK. Konfirmasi bahwa rilis SDK Anda secara eksplisit mendukung jalur penutupan beku sebelum mengaktifkan pembuatan posisi penerbit terbatas.

Untuk klien Anchor langsung, pertahankan akun yang dideklarasikan tidak berubah dan tambahkan pool:

// Program CLMM: lihat reference/program-addresses; sumber ecb1577;
// Solana mainnet-beta; terakhir diverifikasi 2026-08-13.
await program.methods
  .closePosition()
  .accounts({
    nftOwner,
    positionNftMint,
    positionNftAccount,
    personalPosition,
    systemProgram: SystemProgram.programId,
    tokenProgram: positionNftTokenProgram,
  })
  .remainingAccounts([
    { pubkey: poolId, isWritable: false, isSigner: false },
  ])
  .rpc();

Anda dapat melewatkan poolId pada setiap penutupan. CLMM membacanya hanya ketika positionNftAccount beku, yang membuat satu jalur klien kompatibel dengan posisi lama dan baru.

Kumpulkan reward

Sumber: src/clmm/harvestAllRewards.ts

const { execute } = await raydium.clmm.harvestAllRewards({
  ownerInfo: { useSOLBalance: true },
  allPoolInfo: { [poolInfo.id]: poolInfo },
  allPositions: { [poolInfo.id]: [positionAccount] },
  txVersion: TxVersion.V0,
});

await execute({ sendAndConfirm: true });

harvestAllRewards berjalan melalui setiap posisi di setiap pool yang dilewatkan, membuat batch instruksi CollectReward (dan UpdateRewardInfos apa pun), dan membaginya ke beberapa transaksi jika diperlukan.

Swap

Sumber: src/clmm/swap.ts

import { PoolUtils } from "@raydium-io/raydium-sdk-v2";

const amountIn = new BN(10_000_000);
const baseIn   = true;               // swap A (SOL) → B (USDC)
const slippage = 0.005;

const { minAmountOut, remainingAccounts, priceImpact } =
  PoolUtils.computeAmountOutFormat({
    poolInfo,
    tickArrayCache: await raydium.clmm.fetchTickArrays({ poolInfo }),
    amountIn,
    tokenOut: poolInfo.mintB,
    slippage,
    epochInfo: await raydium.fetchEpochInfo(),
  });

const { execute } = await raydium.clmm.swap({
  poolInfo,
  poolKeys,
  inputMint: new PublicKey(poolInfo.mintA.address),
  amountIn,
  amountOutMin: minAmountOut.amount,
  observationId: poolKeys.observationId,
  remainingAccounts,
  txVersion: TxVersion.V0,
});

await execute({ sendAndConfirm: true });

computeAmountOutFormat berjalan melalui peta tick secara offline menggunakan logika yang sama dengan program on-chain dan mengembalikan:

jumlah yang diharapkan keluar,
jumlah minimum keluar setelah slippage,
daftar akun tick-array yang akan disentuh swap sebenarnya (remainingAccounts).

Selalu teruskan remainingAccounts yang dikembalikan oleh simulasi: jika Anda melewatkan terlalu sedikit, swap akan kembali di tengah-jalan dengan TickArrayNotFound; jika Anda melewatkan yang sudah usang, komputasi terbuang.

Buat pool CLMM yang dapat disesuaikan

createCustomizablePool adalah titik masuk baru yang mengekspos toggle biaya dinamis dan biaya satu sisi pada waktu pembuatan pool. Ini mengambil bentuk yang sama dengan createPool ditambah tiga penambahan:

import { CLMM_PROGRAM_ID, CollectFeeOn } from "@raydium-io/raydium-sdk-v2";

const dynamicFeeConfigs = await raydium.api.getClmmDynamicConfigs();    // GET /main/clmm-dynamic-config
const dynamicFeeConfig  = dynamicFeeConfigs.find((c) => c.index === 0); // pilih tingkat kalibrasi

const { execute, extInfo } = await raydium.clmm.createCustomizablePool({
  programId: CLMM_PROGRAM_ID,
  mint1:     mintA,
  mint2:     mintB,
  ammConfig,
  initialPrice,
  startTime: new BN(0),
  // Bidang baru:
  collectFeeOn:        CollectFeeOn.Token1Only,   // 0 = FromInput, 1 = Token0Only, 2 = Token1Only
  enableDynamicFee:    true,
  dynamicFeeConfigId:  dynamicFeeConfig?.id,      // omit when enableDynamicFee is false
  txVersion: TxVersion.V0,
});

await execute({ sendAndConfirm: true });
console.log("Customizable pool:", extInfo.address.id.toBase58());

createPool terus bekerja untuk jalur biaya default, tanpa limit order, tanpa biaya dinamis. Gunakan createCustomizablePool kapan pun Anda memerlukan salah satu dari tiga tombol baru. Lihat products/clmm/instructions untuk daftar akun on-chain.

Limit order

Limit order memarkir input pengguna pada satu tick dan diisi FIFO ketika swap melintasi tick tersebut. Output didorong ke ATA pemilik pada waktu penyelesaian; pemilik tidak perlu online untuk diisi.

Buka limit order

import { TickUtils } from "@raydium-io/raydium-sdk-v2";

const limitConfigs = await raydium.api.getClmmLimitOrderConfigs(); // GET /main/clmm-limit-order-config
const limitConfig  = limitConfigs.find((c) => c.poolId === poolInfo.id);

// Harga limit HARUS dikuantisasi ke tick_spacing.
const targetPrice = new Decimal(180);                              // jual SOL pada 180 USDC
const { tick: limitTick } = TickUtils.getPriceAndTick({
  poolInfo, price: targetPrice, baseIn: true,
});

const { execute } = await raydium.clmm.openLimitOrder({
  poolInfo,
  poolKeys,
  limitOrderConfig: limitConfig,
  inputMint: poolInfo.mintA.address,         // menjual SOL
  inputAmount: new BN(50_000_000),           // 0.05 SOL
  tick: limitTick,
  txVersion: TxVersion.V0,
});

const { txId } = await execute({ sendAndConfirm: true });
console.log("Limit order opened, tx:", txId);

SDK menurunkan PDA LimitOrderState dari (pool, owner, tick, nonce), meningkatkan LimitOrderNonce per-(pool, owner), dan menyisipkan pesanan ke dalam kohort FIFO pada tick tersebut.

Tingkatkan / kurangi pesanan terbuka

await raydium.clmm.increaseLimitOrder({
  poolInfo,
  poolKeys,
  limitOrderId: <LIMIT_ORDER_PUBKEY>,
  addAmount: new BN(20_000_000),
  txVersion: TxVersion.V0,
}).then((b) => b.execute({ sendAndConfirm: true }));

await raydium.clmm.decreaseLimitOrder({
  poolInfo,
  poolKeys,
  limitOrderId: <LIMIT_ORDER_PUBKEY>,
  removeAmount: new BN(10_000_000),
  txVersion: TxVersion.V0,
}).then((b) => b.execute({ sendAndConfirm: true }));

decreaseLimitOrder hanya dapat menghapus dari bagian yang belum diisi dari pesanan; bagian yang diisi dikunci sampai penyelesaian. Kedua instruksi kembali dengan InvalidOrderPhase jika pesanan sudah sepenuhnya diisi.

Selesaikan pesanan yang diisi

await raydium.clmm.settleLimitOrder({
  poolInfo,
  poolKeys,
  limitOrderId: <LIMIT_ORDER_PUBKEY>,
  txVersion: TxVersion.V0,
}).then((b) => b.execute({ sendAndConfirm: true }));

settleLimitOrder membaca unfilled_ratio_x64 pesanan terhadap pelacak kohort, menghitung output yang diisi, dan mentransfernya ke ATA pemilik. Pemilik dapat memanggil ini sendiri; limit_order_admin (pemelihara operasional off-chain) juga dapat memanggilnya atas nama pemilik — output masih pergi ke pemilik. Untuk menutup pesanan yang sepenuhnya diselesaikan untuk memulihkan sewa, gunakan closeLimitOrder (tunggal) atau closeAllLimitOrder (batch). Untuk menyelesaikan banyak sekaligus, settleAllLimitOrder mengemas sebanyak mungkin panggilan SettleLimitOrder yang sesuai dalam transaksi v0.

Daftar pesanan yang diparkir dompet (off-chain)

// Pembantu API. Lihat api-reference/temp-api-v1.
const active = await fetch(
  `https://temp-api-v1.raydium.io/limit-order/order/list?wallet=<your-wallet-pubkey>`,
).then((r) => r.json());

Titik akhir pesanan aktif mengembalikan pesanan yang belum diisi dan sebagian diisi dalam satu payload (totalAmount / filledAmount / pendingSettle membedakan fase). Untuk riwayat pesanan tertutup gunakan /limit-order/history/order/list-by-user?wallet=… (per-dompet, dipaginasi oleh nextPageId); untuk log acara lengkap pesanan tertentu gunakan /limit-order/history/event/list-by-pda?pda=….

Kerangka CPI Rust

use anchor_lang::prelude::*;
use raydium_amm_v3::cpi;
use raydium_amm_v3::program::AmmV3;
use raydium_amm_v3::cpi::accounts::SwapV2;

#[derive(Accounts)]
pub struct ProxyClmmSwap<'info> {
    #[account(mut)]
    pub payer: Signer<'info>,
    /// CHECK:
    pub amm_config: UncheckedAccount<'info>,
    #[account(mut)]
    /// CHECK:
    pub pool_state: UncheckedAccount<'info>,
    #[account(mut)]
    /// CHECK:
    pub input_token_account: UncheckedAccount<'info>,
    #[account(mut)]
    /// CHECK:
    pub output_token_account: UncheckedAccount<'info>,
    #[account(mut)]
    /// CHECK:
    pub input_vault: UncheckedAccount<'info>,
    #[account(mut)]
    /// CHECK:
    pub output_vault: UncheckedAccount<'info>,
    #[account(mut)]
    /// CHECK:
    pub observation_state: UncheckedAccount<'info>,
    /// CHECK:
    pub token_program: UncheckedAccount<'info>,
    /// CHECK:
    pub token_program_2022: UncheckedAccount<'info>,
    /// CHECK:
    pub memo_program: UncheckedAccount<'info>,
    /// CHECK:
    pub input_vault_mint: UncheckedAccount<'info>,
    /// CHECK:
    pub output_vault_mint: UncheckedAccount<'info>,
    pub clmm_program: Program<'info, AmmV3>,
    // `remaining_accounts` carries the tick_array and bitmap_extension accounts.
}

pub fn proxy_swap(
    ctx: Context<ProxyClmmSwap>,
    amount: u64,
    other_amount_threshold: u64,
    sqrt_price_limit_x64: u128,
    is_base_input: bool,
) -> Result<()> {
    let cpi_accounts = SwapV2 {
        payer:                 ctx.accounts.payer.to_account_info(),
        amm_config:            ctx.accounts.amm_config.to_account_info(),
        pool_state:            ctx.accounts.pool_state.to_account_info(),
        input_token_account:   ctx.accounts.input_token_account.to_account_info(),
        output_token_account:  ctx.accounts.output_token_account.to_account_info(),
        input_vault:           ctx.accounts.input_vault.to_account_info(),
        output_vault:          ctx.accounts.output_vault.to_account_info(),
        observation_state:     ctx.accounts.observation_state.to_account_info(),
        token_program:         ctx.accounts.token_program.to_account_info(),
        token_program_2022:    ctx.accounts.token_program_2022.to_account_info(),
        memo_program:          ctx.accounts.memo_program.to_account_info(),
        input_vault_mint:      ctx.accounts.input_vault_mint.to_account_info(),
        output_vault_mint:     ctx.accounts.output_vault_mint.to_account_info(),
    };
    let cpi_ctx = CpiContext::new(ctx.accounts.clmm_program.to_account_info(), cpi_accounts)
        .with_remaining_accounts(ctx.remaining_accounts.to_vec());
    cpi::swap_v2(cpi_ctx, amount, other_amount_threshold, sqrt_price_limit_x64, is_base_input)
}

Urutan akun sisa untuk SwapV2:

[tick_array_bitmap_extension?, tick_array_0, tick_array_1, …]

Jika swap tidak pernah memerlukan ekstensi, omit; jika tidak, itu adalah akun sisa pertama.

Jebakan umum

Titik akhir tick off-spacing → InvalidTickIndex. Selalu snap melalui TickUtils.getPriceAndTick.
Tidak cukup tick array yang disediakan dalam SwapV2 → TickArrayNotFound. Gunakan computeAmountOutFormat untuk mendapatkan daftar lengkap.
Posisi jangkauan penuh tanpa ekstensi bitmap → PDA ekstensi harus dapat ditulis; SDK menangani ini secara otomatis.
Mengacaukan sqrt_price_x64 dengan price → kebingungan faktor-2 di sini sangat menyakitkan. Jika ragu, biarkan SDK menghitungnya dari harga yang dapat dibaca manusia.
Mengumpulkan reward terlalu cepat → setiap pengumpulan memerlukan satu transaksi. Batch melalui harvestAllRewards di banyak posisi.
Menutup akun NFT sendiri → ClosePosition membakar NFT dan menutup ATA-nya. Ini juga menutup mint NFT Token-2022; mint SPL Token klasik tetap pada pasokan nol karena program itu tidak dapat menutup mint. Jangan tutup akun yang didukung secara terpisah atau instruksi akan kembali.
Membuka limit order pada tick yang tidak berspasi → InvalidTickIndex. Selalu kuantisasi melalui TickUtils.getPriceAndTick.
Memanggil decreaseLimitOrder pada pesanan yang sepenuhnya diisi → InvalidOrderPhase. Gunakan settleLimitOrder kemudian closeLimitOrder sebagai gantinya.
Lupa dynamicFeeConfigId sambil melewatkan enableDynamicFee: true → pengembalian CreateCustomizablePool adalah InvalidDynamicFeeConfigParams. Baik matikan biaya dinamis, atau pilih konfigurasi dari /main/clmm-dynamic-config.

Ke mana selanjutnya

sdk-api/typescript-sdk — permukaan SDK lengkap.
sdk-api/rest-api — titik akhir kutipan dan metadata pool.
user-flows/create-clmm-pool — panduan tanpa kode.
integration-guides/aggregator — perutean CLMM sebagai bagian dari jalur.

Sumber:

Products

Algorithms

Setup

Buat pool CLMM

Buka posisi dalam rentang pilihan

Tingkatkan likuiditas pada posisi yang ada

Kurangi likuiditas (dan kumpulkan biaya pada saat yang sama)

Kumpulkan reward

Swap

Buat pool CLMM yang dapat disesuaikan

Limit order

Buka limit order

Tingkatkan / kurangi pesanan terbuka

Selesaikan pesanan yang diisi

Daftar pesanan yang diparkir dompet (off-chain)

Kerangka CPI Rust

Jebakan umum

Ke mana selanjutnya

​Setup

​Buat pool CLMM

​Buka posisi dalam rentang pilihan

​Tingkatkan likuiditas pada posisi yang ada

​Kurangi likuiditas (dan kumpulkan biaya pada saat yang sama)

​Kumpulkan reward

​Swap

​Buat pool CLMM yang dapat disesuaikan

​Limit order

​Buka limit order

​Tingkatkan / kurangi pesanan terbuka

​Selesaikan pesanan yang diisi

​Daftar pesanan yang diparkir dompet (off-chain)

​Kerangka CPI Rust

​Jebakan umum

​Ke mana selanjutnya

Setup

Buat pool CLMM

Buka posisi dalam rentang pilihan

Tingkatkan likuiditas pada posisi yang ada

Kurangi likuiditas (dan kumpulkan biaya pada saat yang sama)

Kumpulkan reward

Swap

Buat pool CLMM yang dapat disesuaikan

Limit order

Buka limit order

Tingkatkan / kurangi pesanan terbuka

Selesaikan pesanan yang diisi

Daftar pesanan yang diparkir dompet (off-chain)

Kerangka CPI Rust

Jebakan umum

Ke mana selanjutnya