| /* |
| * This file is part of the QuickServer library |
| * Copyright (C) QuickServer.org |
| * |
| * Use, modification, copying and distribution of this software is subject to |
| * the terms and conditions of the GNU Lesser General Public License. |
| * You should have received a copy of the GNU LGP License along with this |
| * library; if not, you can download a copy from <http://www.quickserver.org/>. |
| * |
| * For questions, suggestions, bug-reports, enhancement-requests etc. |
| * visit http://www.quickserver.org |
| * |
| */ |
| package org.quickserver.net.server; |
| |
| import org.quickserver.net.client.BlockingUDPClient; |
| import org.quickserver.util.xmlreader.Property; |
| |
| |
| |
| /** |
| * |
| * @author mukundan |
| */ |
| public class BlockingUDPClientTest { |
| |
| private static BlockingUDPClient udpClient = new BlockingUDPClient(); |
| private static String data = "hello from client"; |
| private static String host = "localhost"; |
| private static Property property = new Property("name", "value"); |
| private static int port = 8855; |
| private static String charset = "ISO-8859-1"; |
| |
| private static byte [] resp; |
| private static String response; |
| |
| public static void main (String [] args) throws Exception{ |
| UDPEchoServer.setPort(port); |
| test_send_receive_binary(); |
| test_send_receive_bytes(); |
| test_send_receive_line(); |
| test_send_receive_object(); |
| resp = udpClient.sendAndReceiveBinary(host, port, data.getBytes()); |
| System.out.println("sendAndReceiveBinary:"+new String(resp)); |
| response = udpClient.sendAndReceiveBytes(host, port, data); |
| System.out.println("sendAndReceiveBytes:"+response); |
| udpClient = new BlockingUDPClient(); |
| response = udpClient.sendAndReceiveLine(host, port, data+"\r\n"+"second line"); |
| System.out.println("sendAndReceiveLine1:"+response); |
| response = udpClient.readLine(); |
| System.out.println("sendAndReceiveLine2:"+response); |
| property = (Property)udpClient.sendAndReceiveObject(host, port, property); |
| System.out.println("sendAndReceiveObject:"+property.getName()+":"+property.getValue()); |
| UDPEchoServer.stopServer(); |
| } |
| |
| public static void test_send_receive_binary() throws Exception{ |
| udpClient.connect(host, port); |
| udpClient.sendBytes(data.getBytes()); |
| resp = udpClient.readBytes(); |
| System.out.println("C:gotBinary="+new String(resp)); |
| } |
| |
| public static void test_send_receive_bytes() throws Exception{ |
| udpClient.connect(host, port); |
| udpClient.sendBytes(data, charset); |
| response = udpClient.readBytes(charset); |
| System.out.println("C:gotBytes="+response); |
| } |
| |
| public static void test_send_receive_line() throws Exception{ |
| udpClient.connect(host, port); |
| udpClient.sendLine(data+"\r\n"+"second hello from client",charset); |
| response = udpClient.readLine(); |
| System.out.println("C:gotLine1="+response); |
| response = udpClient.readLine(); |
| System.out.println("C:gotLine2="+response); |
| } |
| |
| public static void test_send_receive_object() throws Exception{ |
| udpClient.connect(host, port); |
| property = new Property(); |
| property.setValue("value"); |
| udpClient.sendObject(property); |
| property = (Property)udpClient.readObject(); |
| System.out.println("C:gotObject:"+property.getValue()); |
| } |
| } |