オブジェクトを使用してメッセージを送信しようとしています。GUIを作成するコードと、接続がない場合はサーバーを作成するか、サーバーが利用可能な場合はクライアントとして機能するコードの別のチャンクがあります。ユーザーは GUI を介してメッセージを入力し、「コミュニケーター」を介して「メッセージ」オブジェクトとして送信します。コミュニケーターがクライアントとして設定されている場合、ユーザーはメッセージを送信できますが、サーバーとして設定されている場合は送信できません...
ユーザーがプログラムをサーバーとして設定してメッセージを送信しようとすると、次のエラーが発生します。
スレッド「AWT-EventQueue-0」での例外 java.lang.NullPointerException
そして、メッセージは送信されません
これは、コミュニケーターのコードです。一番下は、メッセージを送信する関数です。
package hunterinstant;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
import java.util.Scanner;
import java.util.logging.Level;
import java.util.logging.Logger;
/**
*
* @author Chris
*/
public class HunterCom implements Runnable {
private static String SERVER_IP = "127.0.0.1";
private static int SERVER_PORT = 5000;
Scanner scanner = new Scanner(System.in); //to read text from the console
Socket socket = null;
boolean client;
Conversation window;
ObjectOutputStream out = null;
public void initialize(Conversation c, String ip, String port) {
System.out.println(ip);
System.out.println(port);
SERVER_IP = ip;
SERVER_PORT = Integer.parseInt(port);
window = c;
}
public void run() {
try {
socket = new Socket(SERVER_IP, SERVER_PORT);
window.addText("Connected to server");
client = true;
} catch (Exception ex) {
window.addText("No Users Online: Waiting for connection");
client = false;
}
if (client == true) {
ObjectInputStream in = null;
while (true) {
try {
if (out == null) {
out = new ObjectOutputStream(socket.getOutputStream());
}
//get the reply from the server
if (in == null) {
in = new ObjectInputStream(socket.getInputStream());
}
Message message = (Message) in.readObject();
window.addText(message.getMessage());
//System.out.println("Server said: " + message.getMessage());
} catch (Exception ex) {
window.addText("Error: " + ex);
}
}
} // End Client
else {
ServerSocket serverSocket = null;
try {
serverSocket = new ServerSocket(SERVER_PORT);
} catch (IOException ex) {
window.addText("Error occured while creating the server socket");
return;
}
Socket socket = null;
try {
//Waits untill a connection is made, and returns that socket
socket = serverSocket.accept();
} catch (IOException ex) {
window.addText("Error occured while accepting the socket");
return;
}
window.addText("Connection created, client IP: " + socket.getInetAddress());
ObjectInputStream in = null;
while (true) {
try {
if (in == null) {
in = new ObjectInputStream(socket.getInputStream());
}
Message message = (Message) in.readObject();
window.addText(message.getMessage());
if (out == null) {
out = new ObjectOutputStream(socket.getOutputStream());
}
} catch (Exception ex) {
window.addText("Error: " + ex);
}
}
}
}
//THIS IS THE CODE THAT IS SUPPOSED TO SEND THE MESSAGE
public void sendMessage(String str)
{
try {
out.writeObject(new Message(str));
System.out.println("Hello");
out.flush();
} catch (IOException ex) {
Logger.getLogger(HunterCom.class.getName()).log(Level.SEVERE, null, ex);
}
}
}
これは、GUI からメッセージを送信することになっているコードです。
private void jButton1ActionPerformed(java.awt.event.ActionEvent evt) {
comunicator.sendMessage(jTextField1.getText());
jTextArea2.append(jTextField1.getText());
}
private void jTextField1KeyPressed(java.awt.event.KeyEvent evt) {
if(evt.getKeyCode()==10) // Has the user pressed enter?
{
comunicator.sendMessage(jTextField1.getText());
jTextArea2.append(jTextField1.getText());
}
}
初心者の質問で申し訳ありません...私はここで本当に明らかに愚かなことをしていると確信していますが、Javaを数か月しかやっておらず、これを理解しようと何時間も費やしました喜びもなく……