My problem is it doesn't work I'll tell you what I've done and what I've tried ( I get this exception : )
first I made help classes (in eclipce) :
Server :
Client :
The Client class :
The MessageHandler class :
then I created a very basic test program in Greenfoot the only thing it has is a world
I had trouble with using my liberarie in greenfoot because my eclipce and greenfoot used differend java versions
the server continging to run
exporting the greenfoot project to a jar file (still not fixed (It appeared when I update Greenfoot to a version without JDK)
and portforwarding
you don't need to read all the code to be able to help you can help if you just know what the ConnectException is
java.net.ConnectException: Connection refused: connect at java.net.DualStackPlainSocketImpl.connect0(Native Method) at java.net.DualStackPlainSocketImpl.socketConnect(DualStackPlainSocketImpl.java:79) at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:350) at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:206) at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:188) at java.net.PlainSocketImpl.connect(PlainSocketImpl.java:172) at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392) at java.net.Socket.connect(Socket.java:589) at java.net.Socket.connect(Socket.java:538) at java.net.Socket.<init>(Socket.java:434) at java.net.Socket.<init>(Socket.java:211) at fejfo.Client.<init>(Client.java:38) at Strater.act(Strater.java:66) at greenfoot.core.Simulation.actWorld(Simulation.java:600) at greenfoot.core.Simulation.runOneLoop(Simulation.java:535) at greenfoot.core.Simulation.runContent(Simulation.java:215) at greenfoot.core.Simulation.run(Simulation.java:205)
package fejfo;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.List;
public class Server implements Runnable {
public final long sleepTime; //try connecting ones per second
ServerSocket server;
List<Socket> clients;
static IOHelp io = new IOHelp();
public Server() throws IOException {
this(25565,100);
}
public Server(int port) throws IOException {
this(port,100);
}
public Server(long sleepTime) throws IOException {
this(25565,sleepTime);
}
public Server(int port,long sleepTime) throws IOException {
this.sleepTime = sleepTime;
try {
System.out.println("connecting to port " + port);
server = new ServerSocket(port);
} catch (IOException e) {
System.err.println("Could not listen on port: " + port);
throw e;
}
Thread t = new Thread(this);
t.start();
}
boolean active = true;
public void stop() {
active = false;
}
@Override
public void run() {
while(active) {
try {
Socket clientSocket = server.accept();
clients.add(clientSocket);
for(Socket s : clients) {
//PrintWriter out = new PrintWriter(s.getOutputStream(), true);
BufferedReader in = new BufferedReader(new InputStreamReader(s.getInputStream()));
String input;
while((input = in.readLine()) != null) {
String[] parts = input.split(",");
for (int i = 0; i < parts.length; i++) {
try {
String part = parts[i];
String nextPart = parts[i+1];
if(part == "getOthers") {
byte[] clientPort = nextPart.getBytes();
Socket client = null;
for(Socket pClient : clients) {
if(pClient.getLocalAddress().getAddress() == clientPort) {
client = pClient;
break;
}
}
if(client == null) return;
clients.remove(client);
send(clients, clientPort);
clients.add(client);
}else if(part == "send" || part == "sendAll") {
send(nextPart);
}else if(part == "sendTo") {
byte[] clientPort = nextPart.getBytes();
send(parts[i+2],clientPort);
}else {
System.err.println("SERVER:"+s.getLocalAddress().getAddress() +" sended an unknown command :" + input);
send("SERVER: you sended an unknown command :" + input,s.getLocalAddress().getAddress());
}
}catch(ArrayIndexOutOfBoundsException e) {
e.printStackTrace();
System.err.println("SERVER: a client sended an invallid command(not enuf parts) :" + input);
send("SERVER: a client sended an invallid command(not enuf parts) :" + input);
}
}
}
}
try {
Thread.sleep(sleepTime);
} catch (InterruptedException e) {
e.printStackTrace();
System.err.println("Thead could not sleep for " + sleepTime);
}
} catch (IOException e) {
System.err.println("could not add an extra client : Accept failed");
}
}
}
public void send(Object data) throws IOException {
String stringForm = io.stringize(data);
for(Socket s : clients) {
PrintWriter out = new PrintWriter(s.getOutputStream(), true);
//BufferedReader in = new BufferedReader(new InputStreamReader(s.getInputStream()));
//String inputLine, outputLine;
out.println(stringForm);
out.close();
}
}
public void send(Object data,byte[] targetIP) throws IOException {
String stringForm = io.stringize(data);
for(Socket s : clients) {
if(s.getLocalAddress().getAddress() == targetIP) {
PrintWriter out = new PrintWriter(s.getOutputStream(), true);
//BufferedReader in = new BufferedReader(new InputStreamReader(s.getInputStream()));
//String inputLine, outputLine;
out.println(stringForm);
out.close();
}
}
}
}
package fejfo;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.List;
public class Client implements Runnable {
private Socket socket;
private PrintWriter out;
private BufferedReader in;
public long sleepTime = 100; //check for incomming messages 10 times per second
public MessageHandler handler;
private List<Socket> others;
public static IOHelp io = new IOHelp();
public Client(String ip,MessageHandler m) throws IOException {
this(ip,25565,m);
}
public Client(String ip, int port,MessageHandler m) throws IOException {
handler = m;
socket = new Socket(ip, port);
out = new PrintWriter(socket.getOutputStream(),true);
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
Thread t = new Thread(this);
t.start();
}
public Client(String ip,long sleepTime,MessageHandler m) throws IOException {
this(ip,25565,sleepTime,m);
}
public Client(String ip, int port,long sleepTime,MessageHandler m) throws IOException {
handler = m;
socket = new Socket(ip, port);
out = new PrintWriter(socket.getOutputStream(),true);
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
this.sleepTime = sleepTime;
Thread t = new Thread(this);
t.start();
}
public void send(Object data) throws IOException {
out.println("send,"+io.stringize(data));
}
public void sendTo(byte[] ip,Object data) throws IOException {
out.println("sendTo,"+ip+io.stringize(data));
}
public void sendTo(Socket other,Object data) throws IOException {
out.println("sendTo,"+other.getLocalAddress().getAddress()+io.stringize(data));
}
boolean active = true;
@SuppressWarnings("unchecked")
@Override
public void run() {
// Auto-generated method stub
while(active) {
try {
Thread.sleep(sleepTime);
} catch (InterruptedException e) {
// Auto-generated catch block
e.printStackTrace();
}
String input;
try {
while((input = in.readLine()) != null) {
if(io.deSerialize(input) instanceof List<?>) {
others = (List<Socket>) io.deSerialize(input);
}else handler.reicive(input);
}
} catch (IOException e) {
// Auto-generated catch block
e.printStackTrace();
} catch (ClassNotFoundException e) {
// Auto-generated catch block
e.printStackTrace();
}
}
}
public void stop() {
active = false;
}
public List<Socket> getOthers() {
return others;
}
}
package fejfo;
public abstract interface MessageHandler {
public abstract void reicive(String data);
}import greenfoot.*; // (World, Actor, GreenfootImage, Greenfoot and MouseInfo)
import fejfo.Server;
import javax.swing.JOptionPane;
import fejfo.MessageHandler;
import fejfo.Client;
import java.awt.Color;
import java.io.IOException;
/**
* Write a description of class Strater here.
*
* @author (your name)
* @version (a version number or a date)
*/
public class Strater extends World implements MessageHandler
{
/**
* Constructor for objects of class Strater.
*
*/
public Strater()
{
// Create a new world with 600x400 cells with a cell size of 1x1 pixels.
super(600, 400, 1);
setBackground(new GreenfootImage("press h to host(make a server) or j to join ",30,Color.GREEN,Color.WHITE,Color.GREEN));
JOptionPane.showMessageDialog(null,"active, press h to host or j to join");
Greenfoot.start();
}
boolean made = false;
boolean joined = false;
boolean inServerMode = true;
Server server;
Client client;
public void act() {
if(Greenfoot.isKeyDown("&")) {
inServerMode = ! inServerMode;
}else if(Greenfoot.isKeyDown("h") && made == false && inServerMode) {
made = true;
int port;
try {
port = Integer.parseInt(JOptionPane.showInputDialog("enter port"));
}catch(NumberFormatException e) {
e.printStackTrace();
port = 25565;
}
try {
server = new Server(port,100);
}catch(IOException e) {
e.printStackTrace();
}
}else if(Greenfoot.isKeyDown("s") && made == true && inServerMode) {
server.stop();
server = null;
}else if(Greenfoot.isKeyDown("j") && joined == false && inServerMode) {
joined = true;
String ip = JOptionPane.showInputDialog("enter ip");
int port;
try {
port = Integer.parseInt(JOptionPane.showInputDialog("enter port"));
}catch(NumberFormatException e) {
e.printStackTrace();
port = 25565;
}
try {
client = new Client(ip,port,100,this);
}catch(IOException e) {
e.printStackTrace();
}
}
String key = Greenfoot.getKey();
if(key != null && client != null && joined) {
try {
client.send(key);
}catch(IOException e) {
e.printStackTrace();
}
}
}
public void reicive(String message) {
System.out.println("got message : " + message);
}
}
