Sirit Example Client - Revision history

Matt: Reverted edits by Amesycyxa (Talk); changed back to last version by Stefan

2010-11-26T19:43:03Z

Reverted edits by Amesycyxa (Talk); changed back to last version by Stefan

Amesycyxa at 23:17, 23 November 2010

2010-11-23T23:17:33Z

Stefan at 14:01, 27 May 2009

2009-05-27T14:01:55Z

Stefan at 13:59, 27 May 2009

2009-05-27T13:59:41Z

Show changes

Stefan at 12:26, 27 May 2009

2009-05-27T12:26:39Z

Stefan at 12:21, 27 May 2009

2009-05-27T12:21:21Z

Stefan at 12:20, 27 May 2009

2009-05-27T12:20:07Z

Stefan: New page: You can see a list of possible alien commands by sending the 'help' command to the alien reader. However, not all of these commands are implemented in rifidi. See this [[Sirit_INfinity510#...

2009-05-27T12:15:48Z

New page: You can see a list of possible alien commands by sending the 'help' command to the alien reader. However, not all of these commands are implemented in rifidi. See this [[Sirit_INfinity510#...

New page

You can see a list of possible alien commands by sending the 'help' command to the alien reader. However, not all of these commands are implemented in rifidi. See this [[Sirit_INfinity510#Supported Commands | List of supported commands]].

<pre>
/*
* SiritClientRAPID.java
*
* Created: 07.05.2009
* Project: RiFidi SiritClient
* http://www.rifidi.org
* http://rifidi.sourceforge.net
* Copyright: Pramari LLC and the Rifidi Project
* License: Lesser GNU Public License (LGPL)
* http://www.opensource.org/licenses/lgpl-license.html
*/
package sandbox;

/**
* @author Stefan Fahrnbauer - stefan@pramari.com
*
*/

import com.sirit.data.DataManager;
import com.sirit.driver.IEventListener;
import com.sirit.mapping.EventInfo;
import com.sirit.mapping.InfoManager;
import com.sirit.mapping.ReaderManager;
import com.sirit.mapping.SetupManager;
import com.sirit.mapping.TagManager;
import com.sirit.mapping.TagResponse;
import com.sirit.mapping.TagResponseList;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

public class SiritClientRAPID implements IEventListener {

/*
* IP Address of the reader
*/
private String ipAddress = "192.168.11.130";

/**
* Constructor
*/
public SiritClientRAPID() {
}

/**
* Constructor - with IP Address
*
* @param ipAddr
* IP Address for the reader
*/
public SiritClientRAPID(String ipAddress) {
super();
this.ipAddress = ipAddress;
}

/**
* Executes the application
*/
public void run() {
try {
long startTime = System.currentTimeMillis();

// Open a connection to the reader
DataManager dataManager = new DataManager(
DataManager.ConnectionTypes.SOCKET, ipAddress, 0);
dataManager.open();
System.out.println("Connection Opened");

// Get the reader's name
InfoManager infoManager = new InfoManager(dataManager);
String v = infoManager.getName();
System.out.println("Name: " + v);
infoManager = null;

// Login as administrator
ReaderManager readerManager = new ReaderManager(dataManager);
if (!readerManager.login("admin", "readeradmin"))
throw new Exception("Login attempt failed: "
+ readerManager.getLastErrorMessage());
v = readerManager.whoAmI();
System.out.println("Login: " + v);

// Open an event channel and get it's ID
String id = dataManager.getEventChannel(this);
System.out.println("Event Channel ID: " + id);

// Register for event.tag.report
if (!readerManager.eventsRegister(id, "event.tag.report"))
throw new Exception("Failure to register for event: "
+ readerManager.getLastErrorMessage());
System.out.println("Registered for event.tag.report");

// Set operating mode to active
SetupManager setupManager = new SetupManager(dataManager);
setupManager
.setOperatingMode(SetupManager.OPERATING_MODE_TYPES.ACTIVE);
System.out.println("Operating Mode: Active for 5 seconds");

// Sleep while handling tag events
Thread.sleep(5000);

// Unregister for event.tag.report
if (!readerManager.eventsUnregister(id, "event.tag.report"))
throw new Exception("Failure to unregister for event: "
+ readerManager.getLastErrorMessage());
System.out.println("Unregistered for event.tag.report");

// Set operating mode to standby
setupManager
.setOperatingMode(SetupManager.OPERATING_MODE_TYPES.STANDBY);
System.out.println("Operating Mode: Standby");

// List the TagDB
System.out.println("Detected Tags:");
TagManager tagManager = new TagManager(dataManager);
TagResponseList tagList = tagManager.dbGet("", "");

TagResponse tagResponse;
for (int tagResponseID = 0; tagResponseID < tagList.getCount(); tagResponseID++) {
tagResponse = tagList.getTagResponse(tagResponseID);
System.out.println("TagID: " + tagResponse.getTagId());
System.out.println("\tAntenna: " + tagResponse.getAntenna());
System.out.println("\tCount: " + tagResponse.getRepeat());
System.out.println("\t1st Time: " + tagResponse.getFirst());
System.out.println("\tLast Time: " + tagResponse.getLast());

}

// Close the connection
setupManager = null;
readerManager = null;
dataManager.close();
System.out.println("Connection Closed");

// Output the time to execute application
long endTime = System.currentTimeMillis();
long t = endTime - startTime - 500;
System.out.println("Estimated Time: " + t + "(ms)");
} catch (Exception e) {
System.out.println("Error: " + e.getMessage());
}
}

/**
* Main method for this demo application
*
* @param args
* Command line arguments first argument -IP Address of the
* reader (optional)
*/
public static void main(String[] args) {
// Create SiritClient object
SiritClientRAPID scApp;
if (args.length > 0)
scApp = new SiritClientRAPID(args[0]);
else
scApp = new SiritClientRAPID();

// Execute the application
scApp.run();
System.out.println("Exiting");
System.exit(0);

}

/**
* Event Handler
*/
public void EventFound(Object sender, EventInfo eventInfo) {
String tagID = eventInfo
.getParameter(EventInfo.EVENT_TAG_ARRIVE_PARAMS.TAG_ID);
System.out.println("Tag ID: " + tagID);
}

}
</pre>

@@ Line 1: / Line 1: @@
 This class shows how to create a program to talk to the Sirit INfinity 510 reader.
-&lt;pre&gt;
+<pre>
 /*
   *  SimpleSiritClient.java
@@ Line 33: / Line 32: @@
 public class SimpleSiritClient {
-	String ipAddress = &quot;192.168.11.130&quot;;
+	String ipAddress = "192.168.11.130";
 	Socket sock;
 	int port = 50007;
@@ Line 39: / Line 38: @@
 	PrintWriter writer;
-	Future&lt;String&gt; future;
+	Future<String> future;
 	/**
@@ Line 56: / Line 55: @@
 		setUpNetworking();
-		String command = &quot;&quot;;
+		String command = "";
 		// Login to reader
-		command = &quot;reader.login(login=admin,pwd=readeradmin)&quot;;
+		command = "reader.login(login=admin,pwd=readeradmin)";
 		processCommand(command);
 		// let the reader scan for tags for 3 seconds
-		command = &quot;tag.db.scan_tags(3000)&quot;;
+		command = "tag.db.scan_tags(3000)";
 		processCommand(command);
@@ Line 103: / Line 102: @@
 		ExecutorService pool = Executors.newFixedThreadPool(2);
 		// Callable for Commandchannel
-		Callable&lt;String&gt; callable = new IncomingCallable();
+		Callable<String> callable = new IncomingCallable();
 		future = pool.submit(callable);
@@ Line 110: / Line 109: @@
 		// write to log window
-		System.out.println(&quot;&gt;&gt;&quot; + command + &quot;\r\n&quot;);
+		System.out.println(">>" + command + "\r\n");
 		// receive and write response
@@ Line 121: / Line 120: @@
 	public void sendCommand(String command) {
 		// send command to reader
-		writer.print(command + &quot;\r\n&quot;);
+		writer.print(command + "\r\n");
 		writer.flush();
+	}
@@ Line 129: / Line 128: @@
 	 */
 	public String getLastResponse() {
-		String response = &quot;&quot;;
+		String response = "";
 		try {
 			response = future.get();
@@ Line 138: / Line 137: @@
+	}
-	public class IncomingCallable implements Callable&lt;String&gt; {
+	public class IncomingCallable implements Callable<String> {
 		PrintWriter writer;
 		String command;
@@ Line 144: / Line 143: @@
 		public String call() {
 			// get response
-			String message = &quot;&quot;;
+			String message = "";
-			String lastResponse = &quot;&quot;;
+			String lastResponse = "";
 			try {
-				while (lastResponse.indexOf(&quot;\r\n\r\n&quot;) == -1) {
+				while (lastResponse.indexOf("\r\n\r\n") == -1) {
 					message = reader.readLine();
-					message = message.replace(&quot;\r&quot;, &quot;&quot;).replace(&quot;\n&quot;, &quot;&quot;)
+					message = message.replace("\r", "").replace("\n", "")
-							+ &quot;\r\n&quot;;
+							+ "\r\n";
 					lastResponse = lastResponse.concat(message);
+				}
@@ Line 161: / Line 160: @@
+}
-&lt;/pre&gt;
+</pre>

@@ Line 1: / Line 1: @@
 This class shows how to create a program to talk to the Sirit INfinity 510 reader.
-<pre>
+&lt;pre&gt;
 /*
   *  SimpleSiritClient.java
@@ Line 32: / Line 33: @@
 public class SimpleSiritClient {
-	String ipAddress = "192.168.11.130";
+	String ipAddress = &quot;192.168.11.130&quot;;
 	Socket sock;
 	int port = 50007;
@@ Line 38: / Line 39: @@
 	PrintWriter writer;
-	Future<String> future;
+	Future&lt;String&gt; future;
 	/**
@@ Line 55: / Line 56: @@
 		setUpNetworking();
-		String command = "";
+		String command = &quot;&quot;;
 		// Login to reader
-		command = "reader.login(login=admin,pwd=readeradmin)";
+		command = &quot;reader.login(login=admin,pwd=readeradmin)&quot;;
 		processCommand(command);
 		// let the reader scan for tags for 3 seconds
-		command = "tag.db.scan_tags(3000)";
+		command = &quot;tag.db.scan_tags(3000)&quot;;
 		processCommand(command);
@@ Line 102: / Line 103: @@
 		ExecutorService pool = Executors.newFixedThreadPool(2);
 		// Callable for Commandchannel
-		Callable<String> callable = new IncomingCallable();
+		Callable&lt;String&gt; callable = new IncomingCallable();
 		future = pool.submit(callable);
@@ Line 109: / Line 110: @@
 		// write to log window
-		System.out.println(">>" + command + "\r\n");
+		System.out.println(&quot;&gt;&gt;&quot; + command + &quot;\r\n&quot;);
 		// receive and write response
@@ Line 120: / Line 121: @@
 	public void sendCommand(String command) {
 		// send command to reader
-		writer.print(command + "\r\n");
+		writer.print(command + &quot;\r\n&quot;);
 		writer.flush();
+	}
@@ Line 128: / Line 129: @@
 	 */
 	public String getLastResponse() {
-		String response = "";
+		String response = &quot;&quot;;
 		try {
 			response = future.get();
@@ Line 137: / Line 138: @@
+	}
-	public class IncomingCallable implements Callable<String> {
+	public class IncomingCallable implements Callable&lt;String&gt; {
 		PrintWriter writer;
 		String command;
@@ Line 143: / Line 144: @@
 		public String call() {
 			// get response
-			String message = "";
+			String message = &quot;&quot;;
-			String lastResponse = "";
+			String lastResponse = &quot;&quot;;
 			try {
-				while (lastResponse.indexOf("\r\n\r\n") == -1) {
+				while (lastResponse.indexOf(&quot;\r\n\r\n&quot;) == -1) {
 					message = reader.readLine();
-					message = message.replace("\r", "").replace("\n", "")
+					message = message.replace(&quot;\r&quot;, &quot;&quot;).replace(&quot;\n&quot;, &quot;&quot;)
-							+ "\r\n";
+							+ &quot;\r\n&quot;;
 					lastResponse = lastResponse.concat(message);
+				}
@@ Line 160: / Line 161: @@
+}
-</pre>
+&lt;/pre&gt;

@@ Line 3: / Line 3: @@
 <pre>
 /*
-  *  SimpleSiritClientNoGUI.java
+  *  SimpleSiritClient.java
+  *
   *  Created:	27.05.2009
@@ Line 30: / Line 30: @@
+  *
   */
-public class SimpleSiritClientNoGUI {
+public class SimpleSiritClient {
 	String ipAddress = "192.168.11.130";
@@ Line 44: / Line 44: @@
 	 */
 	public static void main(String[] args) {
-		SimpleSiritClientNoGUI client = new SimpleSiritClientNoGUI();
+		SimpleSiritClient client = new SimpleSiritClient();
 		client.go();
+	}
@@ Line 125: / Line 125: @@
 	/**
-	 * waits for the reader's response
+	 * waits for and returns the reader's response
 	 */
 	public String getLastResponse() {

← Older revision		Revision as of 12:26, 27 May 2009
Line 1:		Line 1:
−	~~You can see~~ a ~~list of possible alien commands by sending the 'help' command~~ to the ~~alien~~ reader~~. However, not all~~ of ~~these commands are implemented in rifidi. See this [[Sirit_INfinity510#Supported Commands \| List of supported commands]]~~.	+	This class shows how to create a program to talk to the Sirit INfinity 510 reader with the use of Sirit's RAPID API.

	<pre>		<pre>

@@ Line 17: / Line 17: @@
 /**
   * @author Stefan Fahrnbauer - stefan@pramari.com
+  *

@@ Line 12: / Line 12: @@
   *  License:	Lesser GNU Public License (LGPL)
   *  				http://www.opensource.org/licenses/lgpl-license.html
   */
 package sandbox;