Difference between revisions of "Sirit Example Client"
From RifidiWiki
(One intermediate revision by one other user not shown) | |
(No difference)
|
Latest revision as of 19:43, 26 November 2010
This class shows how to create a program to talk to the Sirit INfinity 510 reader.
/* * SimpleSiritClient.java * * Created: 27.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 * Author: Stefan Fahrnbauer - stefan@pramari.com */ package sandbox; import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.Socket; import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; /** * @author Stefan Fahrnbauer - stefan@pramari.com * */ public class SimpleSiritClient { String ipAddress = "192.168.11.130"; Socket sock; int port = 50007; BufferedReader reader; PrintWriter writer; Future<String> future; /** * @param args */ public static void main(String[] args) { SimpleSiritClient client = new SimpleSiritClient(); client.go(); } /** * executes the application */ public void go() { setUpNetworking(); String command = ""; // Login to reader command = "reader.login(login=admin,pwd=readeradmin)"; processCommand(command); // let the reader scan for tags for 3 seconds command = "tag.db.scan_tags(3000)"; processCommand(command); tearDown(); } /** * initializes the connection */ public void setUpNetworking() { try { // connection for submitting commands sock = new Socket(this.ipAddress, this.port); reader = new BufferedReader(new InputStreamReader(sock .getInputStream())); writer = new PrintWriter(sock.getOutputStream()); } catch (IOException ex) { ex.printStackTrace(); } } /** * closes the connection */ public void tearDown() { try { sock.close(); } catch (IOException ex) { ex.printStackTrace(); } } /** * process command, get response and write to log */ public void processCommand(String command) { // create callable to read response ExecutorService pool = Executors.newFixedThreadPool(2); // Callable for Commandchannel Callable<String> callable = new IncomingCallable(); future = pool.submit(callable); // send command to reader sendCommand(command); // write to log window System.out.println(">>" + command + "\r\n"); // receive and write response System.out.println(getLastResponse()); } /** * sends command to reader */ public void sendCommand(String command) { // send command to reader writer.print(command + "\r\n"); writer.flush(); } /** * waits for and returns the reader's response */ public String getLastResponse() { String response = ""; try { response = future.get(); } catch (Exception e) { e.printStackTrace(); } return response; } public class IncomingCallable implements Callable<String> { PrintWriter writer; String command; public String call() { // get response String message = ""; String lastResponse = ""; try { while (lastResponse.indexOf("\r\n\r\n") == -1) { message = reader.readLine(); message = message.replace("\r", "").replace("\n", "") + "\r\n"; lastResponse = lastResponse.concat(message); } } catch (Exception ex) { ex.printStackTrace(); } return lastResponse; } } }