import java.io.*;
import java.net.*;
public class VersendeHamster extends AllroundHamster {
protected DataOutputStream senke;
protected String host;
protected int port;
Zielposition zp = new Zielposition(4,5);
protected VersendeHamster(Hamster hamster) {
super(hamster);
this.senke = null;
}
public void Versenden(){
try{
if (this.senke != null) this.senke.writeInt(zp.getZielreihe());
this.schreib("habe versendet " + (zp.getZielreihe()));
// if (this.senke != null)this.senke.writeInt(s);
// this.schreib("habe versendet "+s);
// if (this.senke != null)this.senke.writeInt(k);
}
catch(Exception io){this.schreib("Fehler beim Schreiben");};
}
}
_____________________________________________________________________________________________________
import java.io.*;
import java.net.*;
public class SocketVersendeHamster extends VersendeHamster {
public SocketVersendeHamster(Hamster hamster, String host, int port) {
super(hamster);
try {
Socket socket = new Socket(host, port); // Verbindungsanforderung
this.senke = new DataOutputStream(socket.getOutputStream());
} catch (Exception exc) { this.senke = null;}//this.quelle = null;
}
}
______________________________________________________________________________________________________
void main() {
SocketVersendeHamster cezary = new SocketVersendeHamster(Hamster
.getStandardHamster(),"127.0.0.1",2345);
cezary.Versenden();
}
_________________________________________________________________________________________________________
import java.io.*;
public class Zielposition implements Serializable{
private volatile int Zielreihe;
private volatile int Zielspalte;
Zielposition(int r, int s){
this.Zielreihe = r;
this.Zielspalte = s;
}
public void setZielreihe(int r){
this.Zielreihe = r;}
public void setZielspalte(int s){
this.Zielspalte = s;}
public int getZielreihe(){
return this.Zielreihe;
}
public int getZielspalte(){
return this.Zielspalte;
}
}
____________________________________________________________________________________________________
import java.io.*;
import java.net.*;
public class EmpfangsHamster extends AllroundHamster {
protected int befehl;
protected DataInputStream quelle;
protected String host;
protected int port,r,s;
protected EmpfangsHamster(Hamster hamster) {
super(hamster);
this.quelle = null;
}
public void Empfangen(){
try {
int befehl = this.quelle.readInt();
this.schreib("habe nichts erhalten"+befehl);
while (befehl != -1) {
this.schreib("habe erhalten " + befehl); }
this.quelle.close();
}
catch(Exception exc){};
}
}
_________________________________________________________________________________________________________
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
public class SocketEmpfangsHamster extends EmpfangsHamster {
public SocketEmpfangsHamster(Hamster hamster, int port) {
super(hamster);
try {
ServerSocket serverSock = new ServerSocket(port);
this.schreib("warte auf Verbindung...");
while(true){
Socket socket = serverSock.accept();
this.schreib("Verbindung hergestellt");
this.quelle = new DataInputStream(socket.getInputStream());
}
}
catch (Exception exc) { this.quelle = null;}
}
}
_______________________________________________________________________________________________________
void main() {
SocketEmpfangsHamster markus = new SocketEmpfangsHamster
(Hamster.getStandardHamster(),2345);
markus.Empfangen();
}