bdc3ff8434
Lowered the logging level so that these both spew all of the lowest level network logging. Useful for seeing what's going on and finding issues.
237 lines
8.7 KiB
Java
237 lines
8.7 KiB
Java
/*
|
|
* 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.Client;
|
|
import com.jme3.network.ClientStateListener;
|
|
import com.jme3.network.ErrorListener;
|
|
import com.jme3.network.Message;
|
|
import com.jme3.network.MessageListener;
|
|
import com.jme3.network.Network;
|
|
import java.awt.Component;
|
|
import java.awt.Dimension;
|
|
import java.awt.event.ActionEvent;
|
|
import java.io.IOException;
|
|
import java.util.logging.Level;
|
|
import java.util.logging.Logger;
|
|
import javax.swing.*;
|
|
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 final Client client;
|
|
private final JEditorPane chatLog;
|
|
private final StringBuilder chatMessages = new StringBuilder();
|
|
private final JTextField nameField;
|
|
private final 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.UDP_PORT);
|
|
client.addMessageListener(new ChatHandler(), ChatMessage.class);
|
|
client.addClientStateListener(new ChatClientStateListener());
|
|
client.addErrorListener(new ChatErrorListener());
|
|
client.start();
|
|
|
|
System.out.println("Started client:" + client);
|
|
}
|
|
|
|
@Override
|
|
public void dispose() {
|
|
System.out.println("Chat window closing.");
|
|
super.dispose();
|
|
if( client.isConnected() ) {
|
|
client.close();
|
|
}
|
|
}
|
|
|
|
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 {
|
|
|
|
// Increate the logging level for networking...
|
|
System.out.println("Setting logging to max");
|
|
Logger networkLog = Logger.getLogger("com.jme3.network");
|
|
networkLog.setLevel(Level.FINEST);
|
|
|
|
// And we have to tell JUL's handler also
|
|
// turn up logging in a very convoluted way
|
|
Logger rootLog = Logger.getLogger("");
|
|
if( rootLog.getHandlers().length > 0 ) {
|
|
rootLog.getHandlers()[0].setLevel(Level.FINEST);
|
|
}
|
|
|
|
// Note: in JME 3.1 this is generally unnecessary as the server will
|
|
// send a message with all server-registered classes.
|
|
// TestChatServer.initializeClasses();
|
|
// Leaving the call commented out to be illustrative regarding the
|
|
// common old pattern.
|
|
|
|
// 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;
|
|
}
|
|
|
|
// Register a shutdown hook to get a message on the console when the
|
|
// app actually finishes
|
|
Runtime.getRuntime().addShutdownHook(new Thread() {
|
|
@Override
|
|
public void run() {
|
|
System.out.println("Chat client is terminating.");
|
|
}
|
|
});
|
|
|
|
|
|
TestChatClient test = new TestChatClient(s);
|
|
test.setVisible(true);
|
|
}
|
|
|
|
private class ChatHandler implements MessageListener<Client> {
|
|
|
|
@Override
|
|
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 ChatClientStateListener implements ClientStateListener {
|
|
|
|
@Override
|
|
public void clientConnected(Client c) {
|
|
System.out.println("clientConnected(" + c + ")");
|
|
}
|
|
|
|
@Override
|
|
public void clientDisconnected(Client c, DisconnectInfo info) {
|
|
System.out.println("clientDisconnected(" + c + "):" + info);
|
|
if( info != null ) {
|
|
// The connection was closed by the server
|
|
JOptionPane.showMessageDialog(rootPane,
|
|
info.reason,
|
|
"Connection Closed",
|
|
JOptionPane.INFORMATION_MESSAGE);
|
|
dispose();
|
|
}
|
|
}
|
|
}
|
|
|
|
private class ChatErrorListener implements ErrorListener<Client> {
|
|
|
|
@Override
|
|
public void handleError( Client source, Throwable t ) {
|
|
System.out.println("handleError(" + source + ", " + t + ")");
|
|
JOptionPane.showMessageDialog(rootPane,
|
|
String.valueOf(t),
|
|
"Connection Error",
|
|
JOptionPane.ERROR_MESSAGE);
|
|
}
|
|
|
|
}
|
|
|
|
private class SendAction extends AbstractAction {
|
|
|
|
private final boolean reliable;
|
|
|
|
public SendAction(boolean reliable) {
|
|
super(reliable ? "TCP" : "UDP");
|
|
this.reliable = reliable;
|
|
}
|
|
|
|
@Override
|
|
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);
|
|
}
|
|
}
|
|
}
|