Institute of Information Science - University of Miskolc

User Tools

Site Tools

Trace:
tanszek:oktatas:iss_t:java_example_for_blocking_and_non-blocking_socket

Differences

This shows you the differences between two versions of the page.

Link to this comparison view

Both sides previous revisionPrevious revision
Next revision		Previous revision
tanszek:oktatas:iss_t:java_example_for_blocking_and_non-blocking_socket [2024/03/04 07:55] – [Blocking TCP sockets in Java] kneheztanszek:oktatas:iss_t:java_example_for_blocking_and_non-blocking_socket [2024/03/04 08:00] (current) – [Blocking UDP sockets in Java] knehez
Line 75: Line 75:
 === Blocking Socket client source === === Blocking Socket client source ===
 <sxh java> <sxh java>
 +    package org.ait;
     import java.io.IOException;     import java.io.IOException;
     import java.io.ObjectInputStream;     import java.io.ObjectInputStream;
Line 145: Line 146:
  
 <sxh java> <sxh java>
-  package org.ait; +package org.ait; 
-   + 
-  import java.io.BufferedReader; +import java.io.BufferedReader; 
-  import java.io.InputStreamReader; +import java.io.InputStreamReader; 
-  import java.net.DatagramPacket; +import java.net.DatagramPacket; 
-  import java.net.DatagramSocket; +import java.net.DatagramSocket; 
-  import java.net.InetAddress; +import java.net.InetAddress; 
-   + 
-  public class UDPClient { +public class UDPClient { 
- public static void main(String args[]) throws Exception { +    public static void main(String args[]) throws Exception { 
- BufferedReader inFromUser = new BufferedReader(new InputStreamReader(System.in)); +        BufferedReader inFromUser = new BufferedReader(new InputStreamReader(System.in)); 
- DatagramSocket clientSocket = new DatagramSocket(); +        DatagramSocket clientSocket = new DatagramSocket(); 
- InetAddress IPAddress = InetAddress.getByName("localhost"); +        InetAddress IPAddress = InetAddress.getByName("localhost"); 
-  + 
- byte[] sendData = new byte[1024]; +        byte[] sendData = new byte[1024]; 
- byte[] receiveData = new byte[1024]; +        byte[] receiveData = new byte[1024]; 
-  + 
- String sentence = inFromUser.readLine(); +        String sentence = inFromUser.readLine(); 
- sendData = sentence.getBytes(); +        sendData = sentence.getBytes(); 
-  + 
- DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, 8080); +        DatagramPacket sendPacket = new DatagramPacket(sendData, sendData.length, IPAddress, 8080); 
- clientSocket.send(sendPacket); +        clientSocket.send(sendPacket); 
-  + 
- DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length); +        DatagramPacket receivePacket = new DatagramPacket(receiveData, receiveData.length); 
- clientSocket.receive(receivePacket); +        clientSocket.receive(receivePacket); 
- String modifiedSentence = new String(receivePacket.getData()); +        String modifiedSentence = new String(receivePacket.getData()); 
-  + 
- System.out.println("converted:" + modifiedSentence); +        System.out.println("converted:" + modifiedSentence); 
- clientSocket.close(); +        clientSocket.close(); 
- } +    } 
- }+}
 </sxh> </sxh>
  
Line 181: Line 182:
  
 <sxh java> <sxh java>
-  package org.ait; +package org.ait; 
-   + 
-  import java.net.DatagramPacket; +import java.net.DatagramPacket; 
-  import java.net.DatagramSocket; +import java.net.DatagramSocket; 
-  import java.net.InetAddress; +import java.net.InetAddress; 
-   + 
-  public class UDPServer { +public class UDPServer { 
- public static void main(String args[]) throws Exception { +    public static void main(String args[]) throws Exception { 
-  + 
- DatagramSocket serverSocket = new DatagramSocket(8080); +        DatagramSocket serverSocket = new DatagramSocket(8080); 
-  + 
- byte[] bytesReceived = new byte[1024]; +        byte[] bytesReceived = new byte[1024]; 
- byte[] bytesSent = new byte[1024]; +        byte[] bytesSent = new byte[1024]; 
-  + 
-  +        DatagramPacket receivePacket = new DatagramPacket(bytesReceived, bytesReceived.length); 
- DatagramPacket receivePacket = new DatagramPacket(bytesReceived, bytesReceived.length); +        // here we are waiting for the packets 
- // here we are waiting for the packets +        serverSocket.receive(receivePacket); 
- serverSocket.receive(receivePacket); + 
-  +        String textMessage = new String(receivePacket.getData()); 
- String textMessage = new String(receivePacket.getData()); + 
-  +        System.out.println("I got: " + textMessage); 
- System.out.println("I got: " + textMessage); + 
-  +        InetAddress IPAddress = receivePacket.getAddress(); 
- InetAddress IPAddress = receivePacket.getAddress(); +        int port = receivePacket.getPort(); 
- int port = receivePacket.getPort(); + 
-  +        String upperCaseText = textMessage.toUpperCase(); 
- String upperCaseText = textMessage.toUpperCase(); +        bytesSent = upperCaseText.getBytes(); 
- bytesSent = upperCaseText.getBytes(); + 
-  +        // send back 
- // send back +        DatagramPacket sendPacket = new DatagramPacket(bytesSent, bytesSent.length, IPAddress, port); 
- DatagramPacket sendPacket = new DatagramPacket(bytesSent, bytesSent.length, IPAddress, port); +        serverSocket.send(sendPacket); 
- serverSocket.send(sendPacket); +        serverSocket.close(); 
- serverSocket.close(); + 
-  +    } 
- } +}
-  }+
 </sxh> </sxh>
  
tanszek/oktatas/iss_t/java_example_for_blocking_and_non-blocking_socket.1709538939.txt.gz · Last modified: 2024/03/04 07:55 by knehez