3.设计Flink程序模拟流式数据源。要求每1秒钟随机生成一条订单信息，包含： 订单ID、用户ID、订单金额、时间戳。其中，订单ID为UUID格式，用户ID为user01-user09， 订单金额200-1200，时间戳为当前系统时间。

以下是一个使用Java和Apache Flink的代码示例，可以模拟流式数据源，每秒钟随机生成一条订单信息：

import org.apache.flink.api.common.functions.MapFunction;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.api.functions.source.SourceFunction;

import java.util.Random;
import java.util.UUID;

public class OrderGenerator {
    public static void main(String[] args) throws Exception {
        // 创建Flink执行环境
        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        // 自定义一个数据源，每1秒钟生成一条订单数据
        DataStream<Order> orderStream = env.addSource(new SourceFunction<Order>() {
            private volatile boolean isRunning = true;
            private Random rand = new Random();

            @Override
            public void run(SourceContext<Order> ctx) throws Exception {
                while (isRunning) {
                    // 随机生成订单ID、用户ID、订单金额和时间戳
                    String orderId = UUID.randomUUID().toString();
                    String userId = "user0" + (rand.nextInt(9) + 1);
                    double amount = rand.nextInt(1001) + 200;
                    long timestamp = System.currentTimeMillis();

                    // 发送订单数据到Flink数据流
                    ctx.collect(new Order(orderId, userId, amount, timestamp));

                    // 等待1秒钟
                    Thread.sleep(1000);
                }
            }

            @Override
            public void cancel() {
                isRunning = false;
            }
        });

        // 将订单数据打印到控制台
        orderStream.map(new MapFunction<Order, String>() {
            @Override
            public String map(Order value) throws Exception {
                return value.toString();
            }
        }).print();

        // 启动Flink程序
        env.execute("OrderGenerator");
    }

    // 订单数据类
    public static class Order {
        public String orderId;
        public String userId;
        public double amount;
        public long timestamp;

        public Order() {}

        public Order(String orderId, String userId, double amount, long timestamp) {
            this.orderId = orderId;
            this.userId = userId;
            this.amount = amount;
            this.timestamp = timestamp;
        }

        @Override
        public String toString() {
            return "Order{" +
                    "orderId='" + orderId + '\'' +
                    ", userId='" + userId + '\'' +
                    ", amount=" + amount +
                    ", timestamp=" + timestamp +
                    '}';
        }
    }
}

该程序使用`SourceFunction`自定义了一个数据源，每秒钟随机生成一条订单数据，并通过`collect()`方法将数据发送到Flink数据流中。然后，将数据打印到控制台。最后，启动Flink程序并执行。