Проект «SnakeProject» Михаила Козлова

⇒ ORACLE SQL \ JAVA ⇐

CISCO

Voice(Asterisk\Cisco)

Microsoft

Powershell

Python

SQL\T-SQL

FreeBSD and Nix

1С

Общая

WEB Разработка

Мото

10. Урок по Java. Сетевое программирование

В этом уроке мы посмотрим три примера из сетевого программирования в Java

Создадим первый проект, в нем класс Example

Наша программа выведет ip и имя хоста (на примере яндекса)

//Класс java.net определяет ip адреса и имена хостов import java.net.InetAddress; import java.net.UnknownHostException; class Example { public static void main(String arg[]) { try { // Создадим объект типа InetAddress InetAddress address = InetAddress.getByName("ya.ru"); // Вывод IP адреса хоста и имени System.out.println("IP хоста: " + address.getHostAddress() + ",имя хоста: " + address.getHostName()); } catch (UnknownHostException e) { System.out.println("Error"); } } }

Это все конечно весело, давайте перейдем к реализации посложнее

В консоли Eclipse внизу вводите сообщение, на него увидите ответ.

Реализация UDP сервера и клиента на Java:

Сервер:

import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; public class Example { public static void main(String args[]) { try { //Создаем сокет DatagramSocket sock = new DatagramSocket(7000); //буфер для получения входящих данных byte[] buffer = new byte[65536]; DatagramPacket incoming = new DatagramPacket(buffer, buffer.length); System.out.println("Ожидаем данные..."); while(true) { //Получаем данные sock.receive(incoming); byte[] data = incoming.getData(); String s = new String(data, 0, incoming.getLength()); System.out.println("Сервер получил: " + s); //Отправляем данные клиенту DatagramPacket dp = new DatagramPacket(s.getBytes() , s.getBytes().length , incoming.getAddress() , incoming.getPort()); sock.send(dp); } } catch(IOException e) { System.err.println("IOException " + e); } } }

Клиент:

import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetAddress; public class Example2 { public static void main(String args[]) { DatagramSocket sock = null; BufferedReader cin = new BufferedReader(new InputStreamReader(System.in)); try { sock = new DatagramSocket(); while(true) { //Ожидаем ввод сообщения серверу System.out.println("Введите сообщение серверу: "); String s = (String)cin.readLine(); byte[] b = s.getBytes(); //Отправляем сообщение DatagramPacket dp = new DatagramPacket(b , b.length , InetAddress.getByName("192.168.45.63") , 7000); sock.send(dp); //буфер для получения входящих данных byte[] buffer = new byte[65536]; DatagramPacket reply = new DatagramPacket(buffer, buffer.length); //Получаем данные sock.receive(reply); byte[] data = reply.getData(); s = new String(data, 0, reply.getLength()); System.out.println("Сервер: " + reply.getAddress().getHostAddress() + ", порт: " + reply.getPort() + ", получил: " + s); } }catch(IOException e) { System.err.println("IOException " + e); } } }

Перейдем к реализации TCP сервера и клиента:

Внизу Eclipse в консоли вводите сообщение, Вы увидите ответ.

Сервер

import java.io.BufferedReader; import java.io.DataOutputStream; import java.io.IOException; import java.io.InputStream; import java.io.OutputStream; import java.io.InputStreamReader; import java.net.ServerSocket; import java.net.Socket; public class Example { public static void main(String[] args) { int port = 7000; //Проверим доступность порта ServerSocket serverSocket = null; try { serverSocket = new ServerSocket(port); } catch (IOException e) { System.out.println("Порт: " + port + " - ошибка подключения!"); System.exit(-1); } //Создание клиента Socket clientSocket = null; try { clientSocket = serverSocket.accept(); } catch (IOException e) { System.out.println("Порт: " + port + " - ошибка подключения!"); System.exit(-1); } //Поток ввода от клиента, получаем из него сообщения InputStream inClientStream = null; try { inClientStream = clientSocket.getInputStream(); } catch (IOException e) { System.out.println("Невозможно получить поток ввода!"); System.exit(-1); } //Читаем поток BufferedReader reader = new BufferedReader(new InputStreamReader(inClientStream)); String readClientStream = null; try { while ((readClientStream = reader.readLine()) != null) { System.out.println("Сообщение от клиента: " + readClientStream); System.out.flush(); //Отсылаем сообщение обратно клиенту OutputStream outClientStream = null; outClientStream = clientSocket.getOutputStream(); DataOutputStream outDataClientStream = new DataOutputStream(outClientStream); try { outDataClientStream.writeUTF("Принял!"); } catch (IOException e) { e.printStackTrace(); } } } catch (IOException e) { System.out.println("Невозможно прочесть сообщение!"); System.exit(-1); } } }

Клиент

import java.io.BufferedReader; import java.io.BufferedWriter; import java.io.DataInputStream; import java.io.IOException; import java.io.InputStream; import java.io.InputStreamReader; import java.io.OutputStream; import java.io.OutputStreamWriter; import java.net.Socket; import java.net.UnknownHostException; public class Example2 { public static void main(String[] args) { String host = "localhost"; int port = 7000; String data; //Создаем сокет Socket socket = null; try { socket = new Socket(host, port); } catch (UnknownHostException e) { System.out.println("Неизвестный хост: " + host); System.exit(-1); } catch (IOException e) { System.out.println("Ошибка ввода/вывода при создании сокета " + host + ":" + port); System.exit(-1); } BufferedReader reader = new BufferedReader(new InputStreamReader(System.in)); //поток вывода, через который проходят сообщения OutputStream out = null; try { out = socket.getOutputStream(); } catch (IOException e) { System.out.println("Невозможно получить поток вывода!"); System.exit(-1); } //транслируем сообщения пользователя в поток вывода BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(out)); String ln = null; try { while ((ln = reader.readLine()) != null) { writer.write(ln + "\n"); writer.flush(); //Читаем обратное сообщение от сервера try{ InputStream iStream = socket.getInputStream(); DataInputStream inStream = new DataInputStream(iStream); data = inStream.readUTF(); System.out.println("Сервер ответил: " + data); }catch (IOException e) { e.printStackTrace(); } } } catch (IOException e) { System.out.println("Ошибка записи сообщения!"); System.exit(-1); } } }

Комментарии пользователей