📄 agentsender.java
字号:
package examples.receivers;
import java.io.*;
import jade.core.*;
import jade.core.behaviours.*;
import jade.lang.acl.*;
public class AgentSender extends Agent {
long fileSize=-1;
byte buffer[]=null;
protected void setup() {
addBehaviour(new SimpleBehaviour(this) {
private boolean finished = false;
public void action() {
try{
System.out.println("\nEnter responder agent name (e.g. receiver@agent@JADE-LEAP): ");
//BufferedReader buff = new BufferedReader(new InputStreamReader(System.in));
//String responder = buff.readLine();
String responder="receiver@JADE-LEAP";
AID r = new AID();
r.setName(responder);
//r.setName("receiver@JADE-LEAP");
ACLMessage msg = new ACLMessage(ACLMessage.INFORM);
msg.setSender(getAID());
msg.addReceiver(r);
//..................................................
while(true) {
try
{
RandomAccessFile readFile = new RandomAccessFile("XXX.txt","r");
fileSize = readFile.length();
buffer = new byte[(int)fileSize];
readFile.readFully(buffer,0,(int)fileSize);
readFile.close();
}
catch(Exception oe)
{
System.out.println("can't find XXX.txt ");
}
String tempStr = new String(buffer, 0,(int)fileSize);
System.out.println(tempStr);
//..................................................
msg.setContent(tempStr);
msg.setLanguage("PlainText");
send(msg);
System.out.println("\nINFORM sent");
doWait(5000);
finished = true;
myAgent.doDelete();
}//end while (true)
}catch (Exception e){
e.printStackTrace(); }//end first try
}//end action
public boolean done(){
return finished;
}
}); //end addbehavior
}//end setup
}//end class
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -