赛题介绍

题目:

开发语言:JAVA

相关知识点: JAVA编程, 多线程, IO

测评环境:

8核机器 16G内存

JVM内存2.6G -Xms2560M -Xmx2560M

磁盘速度:50MB/s

以正确性, 运行效率为排名标准

评测网站:

网址 http://39.104.188.36/lanmao/index

要求每个人注册自己的账号，昵称设置为: 第X组_真实姓名(如：第3组_帅培)

赛题背景

见ppt

时间表

即日-5.18 准备阶段

5.18-6.5 正式比赛

6.7日晚上10：00 截止排名

6.8、6.15 最后两次课要求每个小组汇报本组方案

阶段任务

5.24日22：00前 熟悉git和码云网站，阅读demo代码，至少有一次提交记录(成功失败都算)，否则会被扣分。成功提交有加分，并要求在下一次课分享自己的方案。鼓励大家5.24前仔细阅读一遍demo，看不懂的地方在下次课上跟助教讨论。

5.31日22：00前 至少有一次成功提交的记录，否则会被扣分。成功提交要求在下一次课上分享自己的方案。鼓励大家努力思考优化方案，有思路可以在下一次课上跟助教讨论。

6.7日22：00前 比赛截止

评分标准:

要求每个组员都有成绩

小组排名按组内最好成绩计算

每个阶段必须执行完对应任务，否则会有相应扣分

最终得分标准=个人得分+小组最好成绩+PPT汇报+阶段任务加分扣分

代码提交方式

通过git提交, 我们在https://gitee.com/托管代码

代码框架:https://gitee.com/chaowwwww/javamq

你需要:

1 注册一个账号, fork这个项目, 作为你的git地址

2 在管理界面-项目成员管理-添加项目成员, 添加一个开发者:chaowwwww

3 在管理界面, 将项目设置为非公开的

然后在评测网站上设置git地址(注意设置的为SSH地址)

然后点"提交评测"来提交

补充资料(git精简教程https://www.liaoxuefeng.com/wiki/0013739516305929606dd18361248578c67b8067c8c017b000 )

编程目标

你的coding目标是实现以下接口:

Producer的createBytesMessageToTopic(topic, body) 创建一个消息, 指定Topic

Producer的send(message) 发送消息

Producer的flush(), 发送结束时会调用一次

Consumer的attachQueue(queue, topics) 为Queue绑定Topics

Consumer的poll() 拉消息

评测逻辑:

1 git clone下载代码

2 push阶段: 四个线程同时push消息

3 kill程序,清理页面缓存

4 pull阶段: 四个线程同时pull消息

5 以push和pull的总时间作为排名依据

push和pull都有时间限制

代码结构

pku包下面是你要用到的的类:

核心包括: Producer Consume KeyValue ByteMessage MessageHeader

我们的评测程序只需要这5个类就能工作

DefaultKeyValue和DefaultMessage是默认的key-value和message实现, 你完全可以自己自己的版本

pku.demo下面是一个内存实现的消息队列

为了方便大家理解题目, 为大家实现了一个内存存储的消息队列

DemoConsumer: 继承Consumer

DemoProducer: 继承Producer

DemoMessageStore: 消息队列的内存存储实现

DemoTester: 一个测评程序, 里面会开启多个线程进行push与pull, 通过这个类你可以了解到测评程序的运行逻辑