// tcpServerjava by fpont /
// usage : java tcpServer
// default port is
// connection to be closed by client
// this server handles only connection
import *;
import javaio*;
public class tcpServer {
public static void main(String args[]) {
int port;
ServerSocket server_socket;
BufferedReader input;
try {
port = IntegerparseInt(args[]);
}
catch (Exception e) {
Systemoutprintln(port = (default));
port = ;
}
try {
server_socket = new ServerSocket(port);
Systemoutprintln(Server waiting for client on port +
server_socketgetLocalPort());
// server infinite loop
while(true) {
Socket socket = server_socketaccept();
Systemoutprintln(New connection accepted +
socketgetInetAddress() +
: + socketgetPort());
input = new BufferedReader(new InputStreamReader(socketgetInputStream()));
// print received data
try {
while(true) {
String message = inputreadLine();
if (message==null) break;
Systemoutprintln(message);
}
}
catch (IOException e) {
Systemoutprintln(e);
}
// connection closed by client
try {
socketclose();
Systemoutprintln(Connection closed by client);
}
catch (IOException e) {
Systemoutprintln(e);
}
}
}
catch (IOException e) {
Systemoutprintln(e);
}
}
}
// tcpClientjava by fpont /
// usage : java tcpClient // default port is
import *;
import javaio*;
public class tcpClient {
public static void main(String[] args) {
int port = ;
String server = localhost;
Socket socket = null;
String lineToBeSent;
BufferedReader input;
PrintWriter output;
int ERROR = ;
// read arguments
if(argslength == ) {
server = args[];
try {
port = IntegerparseInt(args[]);
}
catch (Exception e) {
Systemoutprintln(server port = (default));
port = ;
}
}
// connect to server
try {
socket = new Socket(server port);
Systemoutprintln(Connected with server +
socketgetInetAddress() +
: + socketgetPort());
}
catch (UnknownHostException e) {
Systemoutprintln(e);
Systemexit(ERROR);
}
catch (IOException e) {
Systemoutprintln(e);
Systemexit(ERROR);
}
try {
input = new BufferedReader(new InputStreamReader(Systemin));
output = new PrintWriter(socketgetOutputStream()true);
// get user input and transmit it to server
while(true) {
lineToBeSent = inputreadLine();
// stop if input line is
if(lineToBeSentequals()) break;
outputprintln(lineToBeSent);
}
}
catch (IOException e) {
Systemoutprintln(e);
}
try {
socketclose();
}
catch (IOException e) {
Systemoutprintln(e);
}
}
}
