Last active
July 15, 2019 08:28
-
-
Save ahmed-BH/b69f4a787195afffd24e165359b71606 to your computer and use it in GitHub Desktop.
Java socket (tcp/udp) example
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
/*-------------------------------------------------------------------- | |
* | |
* TCP Socket client | |
* | |
*------------------------------------------------------------------*/ | |
String host = "0.0.0.0"; | |
int port = 50236; | |
InetAddress server = InetAddress.getByName(host); | |
Socket socket = new Socket(server, port); | |
String message = "this is message"; | |
//setup the read (in) and write (out) | |
out = new PrintWriter( new BufferedWriter( new OutputStreamWriter(socket.getOutputStream())),true); | |
in = new BufferedReader(new InputStreamReader(socket.getInputStream())); | |
/*-------------------------------------------------------------------- | |
* | |
* TCP Socket server | |
* | |
*------------------------------------------------------------------*/ | |
ServerSocket serverSocket = new ServerSocket(6789); | |
while (true) { | |
Socket client = serverSocket.accept(); | |
BufferedReader inFromClient = | |
new BufferedReader(new InputStreamReader(client.getInputStream())); | |
DataOutputStream outToClient = new DataOutputStream(client.getOutputStream()); | |
} | |
/*-------------------------------------------------------------------- | |
* | |
* UDP Broadcast Socket | |
* | |
*------------------------------------------------------------------*/ | |
public static void broadcast(String broadcastMessage, InetAddress address, int port) throws IOException { | |
DatagramSocket socket = new DatagramSocket(); | |
socket.setBroadcast(true); | |
byte[] buffer = broadcastMessage.getBytes(); | |
DatagramPacket packet = new DatagramPacket(buffer, buffer.length, address, port); | |
socket.send(packet); | |
byte[] buf = new byte[256]; | |
DatagramPacket packet = new DatagramPacket(buf, buf.length); | |
socket.receive(packet); | |
socket.close(); | |
} |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment