使用Spark连接RabbitMQ,并使用Java代码编写消费者,将接收到的数据写入MySQL数据库。