159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta/* 259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * Copyright (c) 2011 jMonkeyEngine 359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * All rights reserved. 459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * 559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * Redistribution and use in source and binary forms, with or without 659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * modification, are permitted provided that the following conditions are 759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * met: 859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * 959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * * Redistributions of source code must retain the above copyright 1059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * notice, this list of conditions and the following disclaimer. 1159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * 1259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * * Redistributions in binary form must reproduce the above copyright 1359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * notice, this list of conditions and the following disclaimer in the 1459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * documentation and/or other materials provided with the distribution. 1559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * 1659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * * Neither the name of 'jMonkeyEngine' nor the names of its contributors 1759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * may be used to endorse or promote products derived from this software 1859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * without specific prior written permission. 1959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * 2059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS 2159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED 2259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 2359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR 2459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 2559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 2659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR 2759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF 2859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING 2959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS 3059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 3159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta */ 3259b2e6871c65f58fdad78cd7229c292f6a177578Scott Bartapackage jme3test.network; 3359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 3459b2e6871c65f58fdad78cd7229c292f6a177578Scott Bartaimport com.jme3.network.*; 3559b2e6871c65f58fdad78cd7229c292f6a177578Scott Bartaimport com.jme3.network.serializing.Serializable; 3659b2e6871c65f58fdad78cd7229c292f6a177578Scott Bartaimport com.jme3.network.serializing.Serializer; 3759b2e6871c65f58fdad78cd7229c292f6a177578Scott Bartaimport java.io.IOException; 3859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 3959b2e6871c65f58fdad78cd7229c292f6a177578Scott Bartapublic class TestThroughput implements MessageListener<MessageConnection> { //extends MessageAdapter { 4059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 4159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta private static long lastTime = -1; 4259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta private static long counter = 0; 4359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta private static long total = 0; 4459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta // Change this flag to test UDP instead of TCP 4559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta private static boolean testReliable = false; 4659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta private boolean isOnServer; 4759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 4859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta public TestThroughput(boolean isOnServer) { 4959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta this.isOnServer = isOnServer; 5059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 5159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 5259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta @Serializable 5359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta public static class TestMessage extends AbstractMessage { 5459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 5559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta public TestMessage() { 5659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta setReliable(testReliable); 5759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 5859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 5959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 6059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta @Override 6159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta public void messageReceived(MessageConnection source, Message msg) { 6259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 6359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta if (!isOnServer) { 6459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta // It's local to the client so we got it back 6559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta counter++; 6659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta total++; 6759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta long time = System.currentTimeMillis(); 6859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta//System.out.println( "total:" + total + " counter:" + counter + " lastTime:" + lastTime + " time:" + time ); 6959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta if (lastTime < 0) { 7059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta lastTime = time; 7159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } else if (time - lastTime > 1000) { 7259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta long delta = time - lastTime; 7359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta double scale = delta / 1000.0; 7459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta double pps = counter / scale; 7559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta System.out.println("messages per second:" + pps + " total messages:" + total); 7659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta counter = 0; 7759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta lastTime = time; 7859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 7959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } else { 8059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta if (source == null) { 8159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta System.out.println("Received a message from a not fully connected source, msg:" + msg); 8259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } else { 8359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta//System.out.println( "sending:" + msg + " back to client:" + source ); 8459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta // The 'reliable' flag is transient and the server doesn't 8559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta // (yet) reset this value for us. 8659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta ((com.jme3.network.Message) msg).setReliable(testReliable); 8759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta source.send(msg); 8859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 8959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 9059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 9159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 9259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta public static void main(String[] args) throws IOException, InterruptedException { 9359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 9459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta Serializer.registerClass(TestMessage.class); 9559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 9659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta // Use this to test the client/server name version check 9759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta //Server server = Network.createServer( "bad name", 42, 5110, 5110 ); 9859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta Server server = Network.createServer(5110, 5110); 9959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta server.start(); 10059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 10159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta Client client = Network.connectToServer("localhost", 5110); 10259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta client.start(); 10359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 10459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta client.addMessageListener(new TestThroughput(false), TestMessage.class); 10559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta server.addMessageListener(new TestThroughput(true), TestMessage.class); 10659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 10759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta Thread.sleep(1); 10859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 10959b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta TestMessage test = new TestMessage(); 11059b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta// for( int i = 0; i < 10; i++ ) { 11159b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta while (true) { 11259b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta//System.out.println( "sending." ); 11359b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta client.send(test); 11459b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 11559b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta 11659b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta //Thread.sleep(5000); 11759b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta } 11859b2e6871c65f58fdad78cd7229c292f6a177578Scott Barta} 119