手把手教你搭建加密货币交易模拟器，零风险体验市场波动

·

加密货币市场波动剧烈，直接入场风险较高。通过搭建交易模拟器，你可以在无需投入真实资金的情况下，熟悉市场运作、测试交易策略并积累经验。本文将逐步指导你使用 Python 构建一个基础版的加密货币交易模拟器，涵盖数据获取、用户交互、盈亏计算等核心功能。

模拟器的核心功能与设计思路

在开始编写代码前，我们首先需要明确模拟器需要完成哪些任务，以及它们之间的逻辑关系。一个基础的模拟器通常包含以下核心模块：

为了使开发过程清晰可控，我们通常会先使用伪代码来描述整个程序的运行流程，这有助于理清思路，避免在编码过程中迷失方向。

开发前的准备：伪代码规划

伪代码并非可执行的实际代码，而是用接近自然语言的方式描述程序逻辑的思维导图。以下是本模拟器的核心步骤伪代码：

步骤1: 欢迎用户，介绍程序功能；
步骤2: 连接数据库，获取指定起始时刻的加密货币价格列表；
步骤3: 展示可投资的币种及其价格，引导用户选择币种并输入投资数量；
步骤4: 根据用户选择，在历史数据中模拟运行，寻找最佳卖出价格；
步骤5: 计算并对比初始投资与最终资产价值，向用户展示详细的盈亏报告。

开发者无需严格按顺序实现所有功能，可以从最简单的部分（如欢迎界面）开始，逐步完善，以此建立信心并巩固理解。

开始搭建：环境与数据准备

本项目的代码开发环境为 Python。首先，创建一个空的项目文件夹（例如 CryptoSimulator），这将是所有项目文件的家。

获取历史价格数据库

模拟器需要依赖历史市场数据来进行回测。你需要准备一个包含历史价格信息的数据库文件（如 SQLite 数据库），并将其放置在你的项目目录下。该数据库通常应包含时间戳、交易对、买入价（Bid）、卖出价（Ask）等关键字段。

创建主程序文件

在项目根目录下，创建一个名为 run.py 的 Python 文件，这将是模拟器的主入口文件。

编写核心功能模块

1. 创建欢迎界面

我们首先创建一个简单的欢迎函数，向用户介绍程序并设置“时光倒流”的情景。

def welcome():
    print("简易加密货币交易模拟器")
    print("嗨！你已回到过去。现在是 2018年3月7日，星期三，上午7:39。")
    print("以下是你可以投资的加密货币清单。")
    print("正在获取价格数据 ... ")

2. 获取并显示初始价格数据

模拟器需要从数据库中获取某个特定时间点的加密货币价格。这里我们使用 SQLite3 进行数据库操作。

首先，确保已安装 sqlite3 库（通常 Python 标准库已包含），然后在 run.py 文件开头导入它：

import sqlite3

接下来，编写一个函数来连接数据库，执行查询，并获取指定时间点以美元（USD）计价的各币种卖出价（Ask）。

def fetch_coins():
    connection = sqlite3.connect('./currency_monitor.db')  # 连接数据库
    cursor = connection.cursor()
    # 构建SQL查询语句，获取特定时间点的数据
    query = "SELECT first_leg, ask FROM prices WHERE timestamp='1520408341.52' AND second_leg='USD';"
    cursor.execute(query)
    coin_ask_prices = cursor.fetchall()  # 获取所有查询结果

    coins = {}  # 创建一个空字典来存储币种信息
    for coin in coin_ask_prices:
        if coin[0] in coins:  # 如果币种已存在，跳过以避免重复
            continue
        coins[coin[0]] = {"price": coin[1], "currency": coin[0]}  # 将币种和价格存入字典
        print("{} - ${} \n".format(coin[0], round(coin[1], 4)))  # 格式化输出币种和价格
    return coins  # 返回包含所有币种信息的字典

3. 处理用户输入

我们需要创建一个函数来接收用户的输入，包括他们想要购买的加密货币种类和数量。

def input_buy():
    print("请输入你想购买的加密货币代码：\n")
    currency = raw_input("").upper()  # 获取输入并转换为大写
    print("太好了！你想购买多少数量呢？\n")
    quantity = float(raw_input(""))  # 获取输入并转换为浮点数
    return currency, quantity  # 返回用户选择的币种和数量

用户输入后，程序可以从之前获得的 coins 字典中查询该币种对应的价格。

price = coins[currency]['price']

构建模拟回测引擎

现在，我们将创建模拟器的核心——回测模块。建议在一个名为 simulator.py 的新文件中创建此功能。

1. 导入库与定义模拟函数

在 simulator.py 中，导入必要的库并定义主模拟函数。

import sqlite3
import datetime

def run_simulation(bought_price, quantity, currency):
    # 计算初始投资总价值
    initial_investment_value = bought_price * quantity
    # 查询数据库中该币种在后续时间内的最佳卖出价（最高买入价）
    best_price, timestamp = fetch_best_bid_price_from_db(currency)
    # 计算最佳情况下的总资产价值
    best_value = best_price * quantity
    # 计算盈亏百分比
    profit_loss_percentage = (best_value - initial_investment_value) / float(initial_investment_value) * 100

2. 查询最佳卖出价格

run_simulation 函数依赖一个辅助函数来从数据库中查询指定币种在给定时间段内的最高买入价（Bid）。

def fetch_best_bid_price_from_db(currency):
    connection = sqlite3.connect('./currency_monitor.db')
    cursor = connection.cursor()
    # 构建SQL查询，寻找特定币种在起始时间之后的最大买入价及其时间戳
    query = "SELECT MAX(bid), timestamp FROM prices WHERE first_leg='{}' AND second_leg='USD' AND timestamp > '1520408341.52'".format(currency)
    cursor.execute(query)
    result = cursor.fetchone()  # 获取查询结果（一行数据）
    return result[0], result[1]  # 返回最佳价格和对应时间戳

3. 向用户展示模拟结果

回到 run_simulation 函数，添加结果展示逻辑，清晰地告诉用户他们的投资表现。

    # 将时间戳转换为可读格式
    readable_time = datetime.datetime.fromtimestamp(timestamp).strftime('%Y-%m-%d %H:%M:%S')
    
    print("{} 的最佳卖出价为 ${}，达成时间：{} \n".format(currency, best_price, readable_time))
    
    if profit_loss_percentage > 0:
        print("你的资产总价值最高达到 ${}，增长了 {}% \n".format(round(best_value, 4), round(profit_loss_percentage, 2)))
    else:
        print("你的资产总价值最高为 ${}，下跌了 {}% \n".format(round(best_value, 4), round(abs(profit_loss_percentage), 2)))

增强用户体验：一点戏剧化效果

为了让模拟器的输出更有趣，可以添加一个模拟逐字打印的效果。创建一个 drama.py 文件：

import time
import sys

def dramatic_typing(text):
    for character in text:
        sys.stdout.write(character)  # 逐个字符输出
        sys.stdout.flush()  # 立即刷新输出缓冲区
        time.sleep(0.10)  # 每个字符之间的延迟

然后，你可以在主程序 run.py 和 simulator.py 中导入这个函数，并用 dramatic_typing("你的文本") 替代部分 print 语句，从而创造一种沉浸式的打字机效果。

整合与运行

最后，在 run.py 的主函数中，将欢迎模块、数据获取模块、用户输入模块和模拟器模块按逻辑顺序调用并整合起来，传递必要的参数。

至此，一个基础版本的加密货币交易模拟器就完成了！👏

通过这个项目，你不仅实践了编程，更重要的是深入理解了交易回测的基本原理。👉 探索更多高级策略与实时数据工具，将你的模拟交易技能提升到新水平。

常见问题

1. 这个模拟器需要真实资金吗？
完全不需要。该模拟器使用历史数据进行回测，所有交易和盈亏均为虚拟计算，旨在为用户提供一个零风险的学习和测试环境。

2. 我是编程新手，能完成这个项目吗？
完全可以。本文提供了详细的步骤和代码示例。建议先尝试运行现有代码，观察结果，然后逐步修改和理解每一部分的功能，这是学习编程的有效方式。

3. 数据库文件从哪里获取？
本文假设你已拥有一个格式合适的 SQLite 历史价格数据库。在实际操作中，你需要自行准备或从可靠的数据源获取此类数据。

4. 这个模拟器可以连接实时市场进行真实交易吗？
本文所构建的仅为本地回测模拟器，不具备连接交易所进行实时交易的功能。若要实现自动交易，需要调用交易所提供的 API 并编写额外的逻辑，同时务必注意安全风险。

5. 如何扩展这个模拟器的功能？
你可以考虑添加更多功能，例如：支持更多技术指标、允许多种策略回测、增加可视化图表（K线图）、优化用户界面（GUI或Web应用），或者引入风险管理模块。

6. 模拟结果能保证真实交易的盈利吗？
不能。历史回测性能并不代表未来收益。市场情况瞬息万变，过去成功的策略在未来可能失效。模拟器主要用于策略验证和学习，切勿完全依赖回测结果进行真实投资决策。