(Небольшое) Java-приложение на стороне сервера не может получить DatagramPackets
У меня есть Linux Microsoft Azure VM, которая работает под управлением Java JDK 7 "Сервер" (с использованием SSH для подключения)
Мой компьютер (Mac OSX) работает под управлением Java JDK 8 "Сервер"
Клиент сообщений компилируется и запускается на моем компьютере, а сервер запускается и компилируется на моем виртуальном компьютере. Я настроил порты xxx2 и xxx3 для UDP.
Код сервера:
public class server {
public static void main(String args[]) throws Exception {
int OutPort = xxx2;
int InPort = xxx3;
byte data[] = new byte[2048];
System.out.println("LOCALHOST:" + InetAddress.getLocalHost());
InetAddress users[] = new InetAddress[1000];
DatagramSocket dataIn = new DatagramSocket(OutPort);
DatagramSocket dataOut = new DatagramSocket(InPort);
DatagramPacket dataIncoming = new DatagramPacket(data, 2048);
int userNum = 0;
while (true) {
try {
dataIn.receive(dataIncoming);
} catch (IOException e) {
System.out.println(e);
}
String message = dataIncoming.getData().toString();
if (message.startsWith("login")) {
users[userNum] = dataIncoming.getAddress();
System.out.println("NEW USER:" + dataIncoming.getAddress().toString() + ", ADDED AS:" + users[userNum]);
userNum++;
}
for (int i = 0; i <= userNum; i++) {
dataOut.send(new DatagramPacket(message.getBytes(), 2048, users[i], InPort));
}
}
}
}
Код клиента:
public class message {
public String username;
public int OutPort = xxx2;
public int InPort = xxx3;
// xxx2 out, xxx3 in (default for testing the opposite).
final InetAddress address;
message() throws UnknownHostException {
// Create the variables.
InetAddress addresses[] = null;
address = InetAddress.getByName("xxxxx.cloudapp.net");
addresses = InetAddress.getAllByName("xxxxx.cloudapp.net");
// Create the colors.
Color background = new Color(141,234,184);
// Create the window.
JFrame window = new JFrame("Java Message");
window.setSize(600,400);
window.setLayout(new BorderLayout());
window.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
window.setVisible(true);
// Create the title.
JLabel title = new JLabel("Xxxxx's Java Messaging System");
title.setFont(new Font("Arial", Font.PLAIN, 24));
title.setOpaque(true);
title.setBackground(background);
title.setHorizontalAlignment(SwingConstants.CENTER);
window.add(title, BorderLayout.NORTH);
// Create the text output.
JTextArea content = new JTextArea();
content.setFont(new Font("Arial", Font.PLAIN, 14));
content.setEditable(false);
window.add(content, BorderLayout.CENTER);
JScrollPane scroll = new JScrollPane(content);
window.add(scroll, BorderLayout.CENTER);
// Create the info panel.
JTextArea info = new JTextArea();
info.setFont(new Font("Menlo", Font.PLAIN, 14));
startup(info, address, addresses);
window.add(info, BorderLayout.EAST);
// Create username dialog.
JDialog usernameWindow = new JDialog();
usernameWindow.setTitle("Username setup");
usernameWindow.setSize(300,200);
usernameWindow.setDefaultCloseOperation(JDialog.DO_NOTHING_ON_CLOSE);
usernameWindow.setVisible(true);
// Create username title.
JLabel loginTitle = new JLabel("Enter a username:");
loginTitle.setFont(new Font("Arial", Font.PLAIN, 16));
usernameWindow.add(loginTitle, BorderLayout.CENTER);
// Create username input.
JTextField usernameInput = new JTextField();
usernameInput.setFont(new Font("Arial", Font.PLAIN, 16));
usernameWindow.add(usernameInput, BorderLayout.SOUTH);
usernameInput.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent ae) {
if (usernameInput.getText().length() >= 8) {
errorDialog("Username too long, must be 8 characters or less!");
} else {
username = usernameInput.getText().toString().toUpperCase();
content.append(":Logged in as:" + username + "\n");
sendMessage("login", username, address);
usernameWindow.dispose();
}
}
});
// Create the text input.
JTextField messageInput = new JTextField();
window.add(messageInput, BorderLayout.SOUTH);
reciveMessages(content);
messageInput.addActionListener(new ActionListener() {
public void actionPerformed(ActionEvent ae) {
sendMessage(username, messageInput.getText(), address);
messageInput.setText("");
}
});
}
public static void main(String args[]) {
SwingUtilities.invokeLater(new Runnable() {
public void run() {
try {
new message();
} catch (Exception e) {
System.out.println("ERROR:" + e);
}
}
});
}
public void startup(JTextArea content, InetAddress ip, InetAddress ips[]) {
InetAddress local = null;
try {
local = InetAddress.getLocalHost();
} catch(Exception e) {
System.out.println(e);
}
content.append("SERVER IP(s):\n");
for (int i = 0; i < ips.length; i++) content.append(ips[i].getHostAddress() + "\n");
content.append("USING:\n" + ip.getHostAddress() + "\n\n");
content.append("LOCALHOST:\n" + local.getHostAddress() + "\n");
}
public void sendMessage(String username, String message, InetAddress address) {
byte data[] = new byte[2048];
char usernameChar[] = username.toCharArray();
char messageChar[] = message.toCharArray();
for (int i = 0; i < usernameChar.length; i++) data[i] = (byte)usernameChar[i];
data[usernameChar.length + 1] = (byte)':';
for (int c = 0; c < messageChar.length; c++) data[usernameChar.length + c + 2] = (byte)messageChar[c];
try {
DatagramSocket outSocket = new DatagramSocket(OutPort);
DatagramPacket dataOut = new DatagramPacket(data, 2048, address, InPort);
outSocket.send(dataOut);
} catch (Exception e) {
System.out.println(e);
}
}
public void reciveMessages(JTextArea content) {
new Thread("PortListener") {
public void run() {
try {
byte inData[] = new byte[2048];
DatagramSocket inSocket = new DatagramSocket(InPort);
DatagramPacket dataIn = new DatagramPacket(inData, 2048);
while (true) {
inSocket.receive(dataIn);
content.append(new String(dataIn.getData(), 0, dataIn.getLength()));
}
} catch (Exception e) {
System.out.println(e);
}
}
}.start();
}
public void errorDialog(String cause) {
}
}
ПРОБЛЕМА: Я запускаю код сервера на ВМ, и консоль никогда не возвращает "НОВЫЙ ПОЛЬЗОВАТЕЛЬ:", и ни одно из сообщений не проходит.
Я совершенно не знаком с сетями Java и сделал это после того, как закончил главу по руководству по Java (книга опубликована Oracle), и мне понадобилось несколько советов о том, как заставить это работать.
Я понятия не имею, если это простая ошибка или вся идея и теория ошибочны.
МОИ ТЕОРИИ:
Сервер неправильно прослушивает пакеты.
Размеры данных клиента и сервера различны.
IP-адрес сервера неверен (например, отсутствует внутренний IP-адрес), и мне нужно использовать SocketAddress.
ЧТО Я ЗНАЮ:
Я сделал версию этой программы, где я скомпилировал ее, а затем перекомпилировал ее с переключенными портами (чтобы исходящие данные стали входящими данными) и работал как на моем компьютере, так и система работала нормально.
1 ответ
Хорошо, после прохождения вашего кода я сделал рабочую версию. Вот что вам нужно отредактировать и почему (некоторые из них могут быть ненужными, но именно это заставило меня работать):
Возможно, я немного расстроился с номерами строк, так как добавил немного печати и комментариев, чтобы помочь мне понять код. Прокомментируйте, если я пропустил исправление / не объяснил что-то ясно.
Клиент сервера:
В строке 9 вам не нужно указывать порт для исходящего сокета, как указано в пакетах.
DatagramSocket dataOut=new DatagramSocket();
В строке 18 я не уверен, что вы надеялись достичь с помощью вызова метода toString() массива, но вы должны преобразовать байтовый массив обратно в строку, например, так:
String message = new String(dataIncoming.getData());
В строке 24 вы переходите к userNum, но userNum - это индекс следующей позиции массива, который нужно заполнить, так что там ничего нет. Измените его на менее чем
for(int i=0;i<userNum;i++)
Клиент сообщения:
строка 58: toString() является избыточным для строки
username=usernameInput.getText().toUpperCase();
строка 107: точно так же, как сервер, вам не нужно объявлять порт, так как это делается в пакете
DatagramSocket outSocket=new DatagramSocket();
Строка 108: Поскольку вы отправляете данные в порт, который прослушивает сервер (выход), вы должны отправлять в выход, а не в порт
DatagramPacket dataOut=new DatagramPacket(data,2048,address,OutPort);
Наконец, строка 123: я вижу, что вы пытались сделать, но это все равно даст вам строку длиной 2048 и много нечитаемых символов. Также линия не будет прекращена. Используйте trim() для уменьшения текста и \n для завершения строки.
content.append(new String(dataIn.getData()).trim()+"\n");