Skip to content

Commit

Permalink
Stream objects are resolved.
Browse files Browse the repository at this point in the history
  • Loading branch information
urvesh254 committed May 19, 2021
1 parent 40a5799 commit 01812ca
Show file tree
Hide file tree
Showing 2 changed files with 14 additions and 14 deletions.
12 changes: 6 additions & 6 deletions Client.java
Original file line number Diff line number Diff line change
Expand Up @@ -24,11 +24,11 @@ public Client() {
// socket = new Socket(ipAddress, PORT);
socket = new Socket(HOST_NAME, PORT);
t.start();
PrintWriter writer = new PrintWriter(socket.getOutputStream(), true);
DataOutputStream writer = new DataOutputStream(socket.getOutputStream());

// Sending Information of the client.
writer.println(clientName);
writer.println(InetAddress.getLocalHost());
writer.writeUTF(clientName);
writer.writeUTF(InetAddress.getLocalHost().toString());

System.out.println(String.format("\nYou are connected with %s\n", HOST_NAME));

Expand All @@ -37,7 +37,7 @@ public Client() {
message = clientInfo.readLine();
if (message.isEmpty())
continue;
writer.println(message);
writer.writeUTF(message);
} while (!message.toLowerCase().equals("exit"));
writer.close();
if (t.isAlive()) {
Expand Down Expand Up @@ -69,11 +69,11 @@ private void getClientInfo() throws IOException {
}

public void run() {
try(BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()))) {
try(DataInputStream reader = new DataInputStream(socket.getInputStream())) {

String message;
while (true) {
message = reader.readLine();
message = reader.readUTF();
System.out.println(message);
}
} catch (SocketException e) {
Expand Down
16 changes: 8 additions & 8 deletions Server.java
Original file line number Diff line number Diff line change
Expand Up @@ -13,21 +13,21 @@ public class Server implements Runnable {

public Server(Socket socket) {
this.socket = socket;
t = new Thread(this, "Accept");
t = new Thread(this);
t.start();
}

public void run() {
clients.add(socket);
try (BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()))) {
try (DataInputStream reader = new DataInputStream(socket.getInputStream())) {

clientName = reader.readLine();
clientName = reader.readUTF();
sendOtherClients(clientName + " is join the chat.");
System.out.println(clientName + " at " + reader.readLine() + " is join the chat.");
System.out.println(clientName + " at " + reader.readUTF() + " is join the chat.");

String message;
while (true) {
message = reader.readLine();
message = reader.readUTF();
if (message.toLowerCase().equals("exit")) {
throw new Exception();
} else {
Expand All @@ -46,14 +46,14 @@ public void run() {

private void sendOtherClients(String message) {
try {
PrintWriter writer;
DataOutputStream writer;
for (Socket client : clients) {
if (client == socket) {
continue;
}
try {
writer = new PrintWriter(client.getOutputStream(), true);
writer.println(message);
writer = new DataOutputStream(client.getOutputStream());
writer.writeUTF(message);
} catch (SocketException e) {
}
}
Expand Down

0 comments on commit 01812ca

Please sign in to comment.