67 lines
1.8 KiB
Java
67 lines
1.8 KiB
Java
//: network/ChatterClient.java
|
|
// ©2015 MindView LLC: see Copyright.txt
|
|
// {ValidateByHand}
|
|
// Tests the ChatterServer by starting multiple
|
|
// clients, each of which sends datagrams.
|
|
import java.net.*;
|
|
import java.io.*;
|
|
import net.mindview.util.*;
|
|
|
|
public class ChatterClient extends Thread {
|
|
// Can listen & send on the same socket:
|
|
private DatagramSocket s;
|
|
private InetAddress hostAddress;
|
|
private byte[] buf = new byte[1000];
|
|
private DatagramPacket dp =
|
|
new DatagramPacket(buf, buf.length);
|
|
private int id;
|
|
|
|
public ChatterClient(int identifier) {
|
|
id = identifier;
|
|
try {
|
|
// Auto-assign port number:
|
|
s = new DatagramSocket();
|
|
hostAddress =
|
|
InetAddress.getByName("localhost");
|
|
} catch(UnknownHostException e) {
|
|
System.err.println("Cannot find host");
|
|
System.exit(1);
|
|
} catch(SocketException e) {
|
|
System.err.println("Can't open socket");
|
|
e.printStackTrace();
|
|
System.exit(1);
|
|
}
|
|
System.out.println("ChatterClient starting");
|
|
}
|
|
public void sendAndEcho(String msg) {
|
|
try {
|
|
// Make and send a datagram:
|
|
s.send(Dgram.toDatagram(msg,
|
|
hostAddress,
|
|
ChatterServer.INPORT));
|
|
// Block until it echoes back:
|
|
s.receive(dp);
|
|
// Print out the echoed contents:
|
|
String rcvd = "Client #" + id +
|
|
", rcvd from " +
|
|
dp.getAddress() + ", " +
|
|
dp.getPort() + ": " +
|
|
Dgram.toString(dp);
|
|
System.out.println(rcvd);
|
|
} catch(IOException e) {
|
|
e.printStackTrace();
|
|
System.exit(1);
|
|
}
|
|
}
|
|
@Override
|
|
public void run() {
|
|
for(int i = 0; i <= 25; i++)
|
|
sendAndEcho("Client #" + id + ", message #" + i);
|
|
}
|
|
public static void main(String[] args) {
|
|
new TimedAbort(5); // Terminate after 5 seconds
|
|
for(int i = 0; i <= 10; i++)
|
|
new ChatterClient(i).start();
|
|
}
|
|
} ///:~
|