A kiválasztott változat és az aktuális verzió közötti különbségek a következők.
Előző változat mindkét oldalon Előző változat Következő változat | Előző változat | ||
tanszek:oktatas:tcp_socket_connection [2023/02/26 15:41] knehez [Alappéldák] |
tanszek:oktatas:tcp_socket_connection [2023/02/27 09:16] (aktuális) knehez [Exercise 1.] |
||
---|---|---|---|
Sor 1: | Sor 1: | ||
- | ====== Exercise ====== | + | ====== Socket client and server exercises ====== |
+ | |||
+ | ==== Exercise 1. ==== | ||
Create a simplified FTP (file transport) client and server where the client can send or download text files from the server: | Create a simplified FTP (file transport) client and server where the client can send or download text files from the server: | ||
Sor 7: | Sor 9: | ||
-) Server sends back the list of the downloadable files | -) Server sends back the list of the downloadable files | ||
-) Client lists the files and asks the user what action they want to take? Upload or download? ('u' or 'd') | -) Client lists the files and asks the user what action they want to take? Upload or download? ('u' or 'd') | ||
- | -) In both cases the uses must give the full file name with extension | + | -) In both cases users must give the full file name with extension |
-) The client sends the selected file to the server (upload) or downloads the selected file from the server to a specific directory. | -) The client sends the selected file to the server (upload) or downloads the selected file from the server to a specific directory. | ||
Sor 26: | Sor 28: | ||
-) If you press "u", /files/ is sent to the server | -) If you press "u", /files/ is sent to the server | ||
- | ====== Starting point of implementation ====== | + | ==== TCP style ==== |
Sor 34: | Sor 36: | ||
- | ==== 1.) Hagyományos blokkolt TCP alapú socket szerver ==== | ||
- | === Socket szerver kód === | + | ==== 1.) Traditional blocked TCP based socket server class in Java ==== |
+ | |||
+ | === Socket server source code === | ||
<code java> | <code java> | ||
import java.io.IOException; | import java.io.IOException; | ||
Sor 56: | Sor 59: | ||
void run() { | void run() { | ||
try { | try { | ||
- | // 1. szerver socket létrehozása | + | // 1. create a socket server listening to port 8080 |
providerSocket = new ServerSocket(8080, 10); | providerSocket = new ServerSocket(8080, 10); | ||
- | // 2. kapcsolódásra várakozás | + | // 2. waiting for the connection (here we are waiting until next connection) |
connection = providerSocket.accept(); | connection = providerSocket.accept(); | ||
- | // 3. Input és Output streamek megadása | + | // 3. create Input and Output streams |
out = new ObjectOutputStream(connection.getOutputStream()); | out = new ObjectOutputStream(connection.getOutputStream()); | ||
in = new ObjectInputStream(connection.getInputStream()); | in = new ObjectInputStream(connection.getInputStream()); | ||
- | // 4. socket kommunikáció | + | // 4. socket communication |
do { | do { | ||
try { | try { | ||
Sor 78: | Sor 81: | ||
ioException.printStackTrace(); | ioException.printStackTrace(); | ||
} finally { | } finally { | ||
- | // 4: kapcsolat lezárása | + | // 4: close connection |
try { | try { | ||
in.close(); | in.close(); | ||
Sor 107: | Sor 110: | ||
} | } | ||
</code> | </code> | ||
- | === Socket kliens kód === | + | === Socket client source === |
<code java> | <code java> | ||
import java.io.IOException; | import java.io.IOException; | ||
Sor 126: | Sor 129: | ||
void run() { | void run() { | ||
try { | try { | ||
- | // 1. socket kapcsolat létrehozása | + | // 1. try to connect to the socket: localhost:8080 |
requestSocket = new Socket("localhost", 8080); | requestSocket = new Socket("localhost", 8080); | ||
- | // 2. Input and Output streamek | + | // 2. Input and Output streams |
out = new ObjectOutputStream(requestSocket.getOutputStream()); | out = new ObjectOutputStream(requestSocket.getOutputStream()); | ||
in = new ObjectInputStream(requestSocket.getInputStream()); | in = new ObjectInputStream(requestSocket.getInputStream()); | ||
- | // 3: Kommunikáció | + | // 3: communications |
do { | do { | ||
try { | try { | ||
- | sendMessage("Hello szerver"); | + | sendMessage("Hello server"); |
sendMessage("bye"); | sendMessage("bye"); | ||
message = (String) in.readObject(); | message = (String) in.readObject(); | ||
Sor 146: | Sor 149: | ||
ioException.printStackTrace(); | ioException.printStackTrace(); | ||
} finally { | } finally { | ||
- | // 4: Kapcsolat zárása | + | // 4: close connection |
try { | try { | ||
in.close(); | in.close(); | ||
Sor 173: | Sor 176: | ||
} | } | ||
</code> | </code> | ||
+ | ==== Traditional UDP style ==== | ||
+ | The following Agent sends a message and waits for a response on port 8080, also with UDP. In the Eclipse IDE, the text you type on the console can be sent by pressing ctrl+z | ||
- | + | == Exercise 2. == | |
- | + | Modify the code so that you can transfer a burned-in name and existing text or image file larger than 2 kbytes and verify that it was successfully sent. | |
- | + | ||
- | + | ||
- | + | ||
- | ==== 2.) Hagyományos UDP alapú kommunikáció ==== | + | |
- | + | ||
- | 2.a) Az alábbi Ágens küld egy üzenetet és a 8080-as porton várja a választ rá, ugyancsak UDP-vel. Az eclipse fejlesztőkörnyezetben a consolon beírt szöveget ctrl+z leütésével lehet elküldeni. | + | |
- | + | ||
- | **Feladat**: módosítsuk a kódot, hogy át tudjon küldeni egy beégetett nevű, és létező, 2 kbyte-nál nagyobb szöveges vagy kép állományt és ellenőrizzük a sikeres küldést. | + | |
<code java> | <code java> | ||
Sor 214: | Sor 211: | ||
String modifiedSentence = new String(receivePacket.getData()); | String modifiedSentence = new String(receivePacket.getData()); | ||
- | System.out.println("átalakítva:" + modifiedSentence); | + | System.out.println("converted:" + modifiedSentence); |
clientSocket.close(); | clientSocket.close(); | ||
} | } | ||
Sor 220: | Sor 217: | ||
</code> | </code> | ||
- | 2.b) Az UDP szerver a 8080-as porton várja az ágensek üzeneteit és nagybetűre konvertálva visszaküldi a kliens UDP socketre. | + | 2.b) The UDP server waits for the agents messages on port 8080 and converts them to uppercase letters and sends them back to the client UDP socket. |
<code java> | <code java> | ||
Sor 239: | Sor 236: | ||
DatagramPacket receivePacket = new DatagramPacket(bytesReceived, bytesReceived.length); | DatagramPacket receivePacket = new DatagramPacket(bytesReceived, bytesReceived.length); | ||
- | // itt várakozik ameddig adat jön a 8080-as porton | + | // here we are waiting for the packets |
serverSocket.receive(receivePacket); | serverSocket.receive(receivePacket); | ||
- | String szoveg = new String(receivePacket.getData()); | + | String textMessage = new String(receivePacket.getData()); |
- | System.out.println("kaptam: " + szoveg); | + | System.out.println("I got: " + textMessage); |
InetAddress IPAddress = receivePacket.getAddress(); | InetAddress IPAddress = receivePacket.getAddress(); | ||
int port = receivePacket.getPort(); | int port = receivePacket.getPort(); | ||
- | String nagybetűsSzöveg = szoveg.toUpperCase(); | + | String upperCaseText = textMessage.toUpperCase(); |
- | bytesSent = nagybetűsSzöveg.getBytes(); | + | bytesSent = upperCaseText.getBytes(); |
- | // visszaküldi | + | // 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); |