The ONE使用笔记:深入源码理解消息创建过程

可以使用The ONE的消息事件产生器MessageEventGenerator自动创建消息,本文深入源码介绍用MessageEventGenerator创建消息的过程。

1. MessageEventGenerator

1.1 设置文件

可以用The ONE的MessageEventGenerator产生消息事件,进而自动创建消息,在my_settings.txt设置如下:

# my_settings.txt
Events2.class = MessageEventGenerator
Events2.interval = 25,35
Events2.size = 5k,10k
Events2.hosts = 0, 79
Events2.tohosts = ...
Events2.prefix = M

值得注意的是,hoststohosts包括下界但不包括上界,即[0, 79)sizeinterval上下界都不包括,即(min, max)详情见MessageEventGenerator.java

1.2 加入事件队列

The ONE初始化时,会创建EventQueueHandler的一个实例,用于管理The ONE所有事件,详情可参考博文《The ONE使用笔记:宏观角度理解事件是如何组织》。MessageEventGenerator事件就是在EventQueueHandler构造函数中被加入到事件队列的。相关源代码如下:

//EventQueueHandler.java
public EventQueueHandler() {
    ...
    //消息产生器事件
    else if (s.contains(CLASS_SETTING)) {
        String className = CLASS_PACKAGE + "." + s.getSetting(CLASS_SETTING); //即input.MessageEventGenerator
        EventQueue eq = (EventQueue)s.createIntializedObject(className);
        queues.add(eq);  //加入到事件队列
    }
    ...
}

1.3 消息Message

描述一个消息Message的属性有:id,从哪里来到哪里去,创建和接收时间,TTL,大小等。Message的主要成员变量如下:

//Message.java
//identify 
private String id;
private int uniqueId;  //Unique ID of this message
private String    appID;  //Application ID of the application that created the message

//about DTNHost
private DTNHost from;
private DTNHost to;
private List<DTNHost> path;  //消息经过的路径

private int size;  //bytes
private int initTtl;
private double timeReceived;
private double timeCreated;

private int responseSize;
private Message requestMsg;

2 消息创建

消息创建分两步:首先,由MessageEventGenerator.nextEvent()产生一个消息创建事件MessageCreateEvent;而后,当轮到处理MessageCreateEvent时,才真正创建一个消息。

2.1 消息创建事件

轮到处理MessageEventGenerator事件时,调用其nextEvent创建一个消息产生事件(只是一个事件,还不是消息)。更确切的说,World.updatethis.nextEventQueue.nextEvent得到一个消息创建的外部事件。相关源代码如下:

//MessageEventGenerator.java
public ExternalEvent nextEvent() {

    /* 从某个范围(在settings文件设置)随机选择消息的source, sink, size, interval */
    from = drawHostAddress(this.hostRange);
    to = drawToAddress(hostRange, from);
    msgSize = drawMessageSize();
    interval = drawNextEventTimeDiff(); //再过interval,再产生一个新的消息

    /* 产生消息创建事件MessageCreateEvent */
    MessageCreateEvent mce = new MessageCreateEvent(from, to, this.getID(), msgSize, responseSize, this.nextEventsTime);
    return mce;
}

//MessageCreateEvent.java
public MessageCreateEvent(int from, int to, String id, int size, int responseSize, double time) {
    super(from,to, id, time);
    this.size = size;
    this.responseSize = responseSize;
}

由此可见,MessageEventGenerator实际上是产生一系列消息创建事件,正如其名。  

2.2 创建消息

首先,需要获取消息创建事件,每隔updateIntervalWorld.java中的update()会逐一处理事件。相关源代码如下:

//World.java中的update()
public void update () {
    ......
    setNextEventQueue();  //找到一个事件队列,该事件队列含有本updateInterval可以处理的事件
    while (this.nextQueueEventTime <= runUntil) {
        simClock.setTime(this.nextQueueEventTime);
        ExternalEvent ee = this.nextEventQueue.nextEvent();  //取得事件
        ee.processEvent(this);  //处理事件
        updateHosts();  //update all hosts after every event
        setNextEventQueue();
    }
    ......
}

从上述代码可见,取得一个事件队列(setNextEventQueue,可能是EventQueue类型的MessageEventGenerator),紧接着处理之processEventprocessEvent()在这里对应于MessageCreateEventprocessEvent函数,旨在创建消息。相关源代码如下:

//MessageCreateEvent.java
public void processEvent(World world) {
    DTNHost to = world.getNodeByAddress(this.toAddr);
    DTNHost from = world.getNodeByAddress(this.fromAddr);
    Message m = new Message(from, to, this.id, this.size);
    m.setResponseSize(this.responseSize);
    
    from.createNewMessage(m);   //创建消息
}

//DTNHost.java
DTNHost.createNewMessage --> MessageRouter.createNewMessage

//MessageRouter.java
public boolean createNewMessage(Message m) {
    m.setTtl(this.msgTtl);
    m.addToMessages( true);     //将消息加入到HashMap<String, Message> messages
    return true;
}

至此,一个消息创建完毕。值得注意的是,当一个新消息被创建时,会触发消息监听器MessageListenerMessageListener是一个接口,实现该接口主要是一些reports。通俗理解就是消息被创建后,通知相关reports更新统计信息(如CreatedMessagesReport, MessageStatsReport)。相关源代码如下:(详情可参考博文《The ONE使用笔记:深入源码理解消息监听器MessageListener》)

//MessageRouter.java
protected void addToMessages(Message m, boolean newMessage) {
    this.messages.put(m.getId(), m);

    if (newMessage) {
        for (MessageListener ml : this.mListeners) {   //触发消息监听器
            ml.newMessage(m);
        }
    }
}
赞赏

微信赞赏支付宝赞赏

发表评论

您的电子邮箱地址不会被公开。

21 thoughts on “The ONE使用笔记:深入源码理解消息创建过程