Browse Source

A crude but working chat client and server using swing
on the client (could be converted to nifty someday).
Simple but lets users test UDP or TCP messaging.


git-svn-id: https://jmonkeyengine.googlecode.com/svn/trunk@7083 75d07b2b-3a1a-0410-a2c5-0572b91ccdca

PSp..om 14 years ago
parent
commit
f6d070afe6

+ 172 - 0
engine/src/test/jme3test/network/TestChatClient.java

@@ -0,0 +1,172 @@
+/*
+ * Copyright (c) 2011 jMonkeyEngine
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are
+ * met:
+ *
+ * * Redistributions of source code must retain the above copyright
+ *   notice, this list of conditions and the following disclaimer.
+ *
+ * * Redistributions in binary form must reproduce the above copyright
+ *   notice, this list of conditions and the following disclaimer in the
+ *   documentation and/or other materials provided with the distribution.
+ *
+ * * Neither the name of 'jMonkeyEngine' nor the names of its contributors
+ *   may be used to endorse or promote products derived from this software
+ *   without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
+ * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+ * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
+ * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
+ * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
+ * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
+ * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
+ * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
+ * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+package jme3test.network;
+
+import java.awt.Dimension;
+import java.awt.event.ActionEvent;
+import java.awt.Component;
+import java.io.IOException;
+import javax.swing.*;
+
+import com.jme3.network.AbstractMessage;
+import com.jme3.network.Client;
+import com.jme3.network.HostedConnection;
+import com.jme3.network.Message;
+import com.jme3.network.MessageListener;
+import com.jme3.network.Network;
+import com.jme3.network.Server;
+import com.jme3.network.serializing.Serializable;
+import com.jme3.network.serializing.Serializer;
+
+import jme3test.network.TestChatServer.ChatMessage;
+
+
+/**
+ *  A simple test chat server.  When SM implements a set
+ *  of standard chat classes this can become a lot simpler.
+ *
+ *  @version   $Revision$
+ *  @author    Paul Speed
+ */
+public class TestChatClient extends JFrame
+{
+    private Client client;
+    private JEditorPane chatLog;
+    private StringBuilder chatMessages = new StringBuilder();
+    private JTextField nameField;
+    private JTextField messageField; 
+    
+    public TestChatClient( String host ) throws IOException
+    {
+        super( "jME3 Test Chat Client - to:" + host );
+        
+        // Build out the UI       
+        setDefaultCloseOperation( DISPOSE_ON_CLOSE );
+        setSize( 800, 600 );
+        
+        chatLog = new JEditorPane();
+        chatLog.setEditable(false);
+        chatLog.setContentType("text/html");
+        chatLog.setText( "<html><body>" );
+        
+        getContentPane().add( new JScrollPane(chatLog), "Center" );
+ 
+        // A crude form       
+        JPanel p = new JPanel();
+        p.setLayout( new BoxLayout(p, BoxLayout.X_AXIS) );
+        p.add( new JLabel( "Name:" ) );
+        nameField = new JTextField( System.getProperty( "user.name", "yourname" ) );
+        Dimension d = nameField.getPreferredSize();
+        nameField.setMaximumSize( new Dimension(120, d.height + 6) );
+        p.add( nameField );
+        p.add( new JLabel( "  Message:" ) );
+        messageField = new JTextField();
+        p.add( messageField );
+        p.add( new JButton(new SendAction(true)) );       
+        p.add( new JButton(new SendAction(false)) );       
+        
+        getContentPane().add( p, "South" );
+        
+        client = Network.connectToServer( TestChatServer.NAME, TestChatServer.VERSION,
+                                          host, TestChatServer.PORT, TestChatServer.PORT + 1 );                                          
+        client.addMessageListener( new ChatHandler(), ChatMessage.class );                                             
+        client.start();                                                                               
+    }
+ 
+    public static String getString( Component owner, String title, String message, String initialValue )
+    {
+        return (String)JOptionPane.showInputDialog( owner, message, title, JOptionPane.PLAIN_MESSAGE,
+                                                     null, null, initialValue );
+    }
+   
+    public static void main( String... args ) throws Exception
+    {
+        TestChatServer.initializeClasses();
+
+        // Grab a host string from the user
+        String s = getString( null, "Host Info", "Enter chat host:", "localhost" );
+        if( s == null ) {
+            System.out.println( "User cancelled." );
+            return;
+        }
+    
+        TestChatClient test = new TestChatClient( s );
+        test.setVisible( true );
+    }
+ 
+    private class ChatHandler implements MessageListener<Client>
+    {
+        public void messageReceived( Client source, Message m ) 
+        {
+            ChatMessage chat = (ChatMessage)m;
+ 
+            System.out.println( "Received:" + chat );
+                       
+            // One of the least efficient ways to add text to a
+            // JEditorPane
+            chatMessages.append( "<font color='#00a000'>" + (m.isReliable() ? "TCP" : "UDP") + "</font>" );
+            chatMessages.append( " -- <font color='#000080'><b>" + chat.getName() + "</b></font> : " ); 
+            chatMessages.append( chat.getMessage() );
+            chatMessages.append( "<br />" ); 
+            String s = "<html><body>" + chatMessages + "</body></html>"; 
+            chatLog.setText( s );
+            
+            // Set selection to the end so that the scroll panel will scroll
+            // down.
+            chatLog.select( s.length(), s.length() );
+        }
+    }
+    
+    private class SendAction extends AbstractAction
+    {
+        private boolean reliable;
+        
+        public SendAction( boolean reliable )
+        {
+            super( reliable ? "TCP" : "UDP" );
+            this.reliable = reliable;
+        }
+        
+        public void actionPerformed( ActionEvent evt )
+        {
+            String name = nameField.getText();
+            String message = messageField.getText();
+            
+            ChatMessage chat = new ChatMessage( name, message );
+            chat.setReliable(reliable);
+            System.out.println( "Sending:" + chat );
+            client.send( chat ); 
+        }
+    }
+}
+

+ 152 - 0
engine/src/test/jme3test/network/TestChatServer.java

@@ -0,0 +1,152 @@
+/*
+ * Copyright (c) 2011 jMonkeyEngine
+ * All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are
+ * met:
+ *
+ * * Redistributions of source code must retain the above copyright
+ *   notice, this list of conditions and the following disclaimer.
+ *
+ * * Redistributions in binary form must reproduce the above copyright
+ *   notice, this list of conditions and the following disclaimer in the
+ *   documentation and/or other materials provided with the distribution.
+ *
+ * * Neither the name of 'jMonkeyEngine' nor the names of its contributors
+ *   may be used to endorse or promote products derived from this software
+ *   without specific prior written permission.
+ *
+ * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
+ * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
+ * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR
+ * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR
+ * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
+ * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
+ * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
+ * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
+ * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
+ * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
+ * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
+ */
+
+package jme3test.network;
+
+import com.jme3.network.Message;
+import com.jme3.network.AbstractMessage;
+import com.jme3.network.HostedConnection;
+import com.jme3.network.MessageListener;
+import com.jme3.network.Network;
+import com.jme3.network.Server;
+import com.jme3.network.serializing.Serializable;
+import com.jme3.network.serializing.Serializer;
+
+
+/**
+ *  A simple test chat server.  When SM implements a set
+ *  of standard chat classes this can become a lot simpler.
+ *
+ *  @version   $Revision$
+ *  @author    Paul Speed
+ */
+public class TestChatServer
+{
+    // Normally these and the initialized method would
+    // be in shared constants or something.
+    public static final String NAME = "Test Chat Server";
+    public static final int VERSION = 1;
+
+    public static final int PORT = 5110;
+
+    public static void initializeClasses()
+    {
+        // Doing it here means that the client code only needs to
+        // call our initialize. 
+        Serializer.registerClass(ChatMessage.class);
+    }
+    
+    public static void main( String... args ) throws Exception
+    {
+        initializeClasses();
+    
+        // Use this to test the client/server name version check
+        Server server = Network.createServer( NAME, VERSION, PORT, PORT );
+        server.start();
+
+        ChatHandler handler = new ChatHandler();
+        server.addMessageListener( handler, ChatMessage.class );
+ 
+        // Keep running basically forever
+        synchronized( NAME ) {
+            NAME.wait();
+        }           
+    }
+    
+    private static class ChatHandler implements MessageListener<HostedConnection>
+    {
+        public ChatHandler() 
+        {
+        }
+    
+        public void messageReceived( HostedConnection source, Message m )
+        {
+            if( m instanceof ChatMessage ) {
+                // Keep track of the name just in case we 
+                // want to know it for some other reason later and it's
+                // a good example of session data
+                source.setAttribute( "name", ((ChatMessage)m).getName() );
+ 
+                System.out.println( "Broadcasting:" + m );
+                                   
+                // Just rebroadcast... the reliable flag will stay the
+                // same so if it came in on UDP it will go out on that too
+                source.getServer().broadcast( m ); 
+            } else {
+                System.err.println( "Received odd message:" + m );
+            }            
+        }
+    }
+
+    @Serializable
+    public static class ChatMessage extends AbstractMessage 
+    {
+        private String name;
+        private String message;
+ 
+        public ChatMessage()
+        {
+        }
+
+        public ChatMessage( String name, String message )
+        {
+            setName(name);
+            setMessage(message);
+        }
+        
+        public void setName( String name )
+        {
+            this.name = name;
+        }
+        
+        public String getName()
+        {
+            return name;
+        }
+        
+        public void setMessage( String s )
+        {
+            this.message = s;
+        }
+        
+        public String getMessage()
+        {
+            return message;
+        }
+        
+        public String toString()
+        {
+            return name + ":" + message;
+        }
+    }
+}
+