Philadelphia 开源项目教程

2024-09-18 03:38:31作者：尤辰城Agatha

项目介绍

Philadelphia 是一个高性能的金融市场交易协议库，专为金融行业设计。它支持多种金融交易协议，包括 FIX (Financial Information eXchange) 协议。Philadelphia 项目的目标是提供一个高效、可靠且易于使用的库，帮助开发者在金融市场中实现快速的交易处理。

项目快速启动

环境准备

在开始之前，请确保您的开发环境已经安装了以下工具：

Java 8 或更高版本
Maven 3.x

下载项目

首先，从 GitHub 仓库中克隆 Philadelphia 项目：

git clone https://github.com/paritytrading/philadelphia.git
cd philadelphia

构建项目

使用 Maven 构建项目：

mvn clean install

运行示例

Philadelphia 项目包含多个示例，您可以通过以下命令运行其中一个示例：

mvn exec:java -Dexec.mainClass="com.paritytrading.philadelphia.examples.Initiator"

示例代码

以下是一个简单的示例代码，展示了如何使用 Philadelphia 库创建一个基本的 FIX 连接：

import com.paritytrading.philadelphia.FIXConnection;
import com.paritytrading.philadelphia.FIXConnectionStatusListener;
import com.paritytrading.philadelphia.FIXMessage;
import com.paritytrading.philadelphia.FIXMessageListener;
import com.paritytrading.philadelphia.FIXMessageParser;
import com.paritytrading.philadelphia.FIXMessageType;
import com.paritytrading.philadelphia.FIXVersion;

public class SimpleFIXClient {

    public static void main(String[] args) {
        // 创建 FIX 连接
        FIXConnection connection = new FIXConnection(FIXVersion.FIX_4_4);

        // 设置连接状态监听器
        connection.setStatusListener(new FIXConnectionStatusListener() {
            @Override
            public void onConnected(FIXConnection connection) {
                System.out.println("Connected to server.");
            }

            @Override
            public void onDisconnected(FIXConnection connection, Throwable cause) {
                System.out.println("Disconnected from server.");
            }
        });

        // 设置消息监听器
        connection.setMessageListener(new FIXMessageListener() {
            @Override
            public void onMessage(FIXConnection connection, FIXMessage message) {
                System.out.println("Received message: " + message);
            }
        });

        // 连接到服务器
        connection.connect("localhost", 9876);

        // 发送一条消息
        FIXMessage message = new FIXMessage(FIXMessageType.LOGON);
        connection.send(message);
    }
}