С какими протоколами работал

Опыт работы с сетевыми протоколами

За 10+ лет разработки на Java я работал с различными сетевыми протоколами. Понимание протоколов — критически важно для написания надёжных и производительных приложений.

HTTP / HTTPS

Самый распространённый протокол для веб-приложений.

Используемые библиотеки:

• java.net.HttpURLConnection — встроенная поддержка
• Apache HttpClient — полнофункциональный HTTP клиент
• OkHttp — современный клиент с пулингом соединений
• Spring RestTemplate — удобный wrapper
• `Spring WebClient** — асинхронный, non-blocking клиент

Пример на Spring Boot:

@Service
public class HttpService {
    private final WebClient webClient;
    private final RestTemplate restTemplate;
    
    public HttpService(WebClient.Builder webClientBuilder) {
        this.webClient = webClientBuilder
            .baseUrl("https://api.example.com")
            .defaultHeader("User-Agent", "MyApp/1.0")
            .build();
        
        this.restTemplate = new RestTemplate();
    }
    
    // Синхронный запрос
    public UserDto getUserSync(String id) {
        return restTemplate.getForObject(
            "https://api.example.com/users/" + id,
            UserDto.class
        );
    }
    
    // Асинхронный запрос (non-blocking)
    public Mono<UserDto> getUserAsync(String id) {
        return webClient.get()
            .uri("/users/{id}", id)
            .retrieve()
            .bodyToMono(UserDto.class)
            .timeout(Duration.ofSeconds(5))
            .retryWhen(Retry.backoff(3, Duration.ofSeconds(1)))
            .onErrorResume(e -> Mono.error(new UserNotFoundException(id)));
    }
    
    // POST с телом запроса
    public Mono<UserDto> createUser(CreateUserRequest request) {
        return webClient.post()
            .uri("/users")
            .contentType(MediaType.APPLICATION_JSON)
            .body(Mono.just(request), CreateUserRequest.class)
            .retrieve()
            .bodyToMono(UserDto.class);
    }
}

WebSocket

Для real-time двусторонней коммуникации.

Используемые библиотеки:

• Spring WebSocket — встроенная поддержка в Spring
• Tyrus — reference implementation JSR 356
• `Netty** — для high-performance приложений

Пример WebSocket в Spring:

// Конфигурация
@Configuration
@EnableWebSocket
public class WebSocketConfig implements WebSocketConfigurer {
    @Override
    public void registerWebSocketHandlers(WebSocketHandlerRegistry registry) {
        registry.addHandler(chatWebSocketHandler(), "/ws/chat")
            .setAllowedOrigins("*");
    }
    
    @Bean
    public WebSocketHandler chatWebSocketHandler() {
        return new ChatWebSocketHandler();
    }
}

// Handler
@Component
public class ChatWebSocketHandler extends TextWebSocketHandler {
    private final Set<WebSocketSession> sessions = ConcurrentHashMap.newKeySet();
    
    @Override
    public void afterConnectionEstablished(WebSocketSession session) throws Exception {
        sessions.add(session);
        System.out.println("Client connected: " + session.getId());
    }
    
    @Override
    protected void handleTextMessage(WebSocketSession session, TextMessage message) throws Exception {
        String payload = message.getPayload();
        // Broadcast сообщение всем клиентам
        for (WebSocketSession s : sessions) {
            if (s.isOpen()) {
                s.sendMessage(new TextMessage(
                    "User " + session.getId() + ": " + payload
                ));
            }
        }
    }
    
    @Override
    public void afterConnectionClosed(WebSocketSession session, CloseStatus status) throws Exception {
        sessions.remove(session);
        System.out.println("Client disconnected: " + session.getId());
    }
}

// Тестирование
@SpringBootTest(webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
public class WebSocketTest {
    @Test
    public void testWebSocket() throws Exception {
        String url = "ws://localhost:8080/ws/chat";
        WebSocketContainer container = ContainerProvider.getWebSocketContainer();
        Session session = container.connectToServer(
            new Endpoint() {
                @Override
                public void onOpen(Session session, EndpointConfig config) {
                    try {
                        session.getAsyncRemote().sendText("Hello");
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            },
            new URI(url)
        );
    }
}

TCP/UDP (Socket Programming)

Для низкоуровневой коммуникации, если HTTP/WebSocket недостаточно.

Примеры использования:

• Game servers
• Real-time trading systems
• VoIP applications
• DNS queries (UDP)

Пример TCP server:

public class TcpServer {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(9999);
        System.out.println("Server listening on port 9999");
        
        while (true) {
            Socket clientSocket = serverSocket.accept();
            // Обработка в отдельном потоке
            new Thread(new ClientHandler(clientSocket)).start();
        }
    }
}

public class ClientHandler implements Runnable {
    private Socket socket;
    
    public ClientHandler(Socket socket) {
        this.socket = socket;
    }
    
    @Override
    public void run() {
        try (
            InputStream input = socket.getInputStream();
            OutputStream output = socket.getOutputStream()
        ) {
            byte[] buffer = new byte[1024];
            int bytesRead = input.read(buffer);
            
            String message = new String(buffer, 0, bytesRead);
            String response = "Echo: " + message;
            output.write(response.getBytes());
            output.flush();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

// Лучше использовать Netty для high-performance:
@Component
public class NettyServer {
    public void start() throws InterruptedException {
        EventLoopGroup bossGroup = new NioEventLoopGroup();
        EventLoopGroup workerGroup = new NioEventLoopGroup();
        
        try {
            ServerBootstrap bootstrap = new ServerBootstrap()
                .group(bossGroup, workerGroup)
                .channel(NioServerSocketChannel.class)
                .childHandler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel ch) {
                        ch.pipeline().addLast(
                            new StringDecoder(),
                            new StringEncoder(),
                            new ChannelInboundHandlerAdapter() {
                                @Override
                                public void channelRead(ChannelHandlerContext ctx, Object msg) {
                                    System.out.println("Received: " + msg);
                                    ctx.writeAndFlush("Echo: " + msg + "\n");
                                }
                            }
                        );
                    }
                });
            
            ChannelFuture future = bootstrap.bind(9999).sync();
            future.channel().closeFuture().sync();
        } finally {
            bossGroup.shutdownGracefully();
            workerGroup.shutdownGracefully();
        }
    }
}

gRPC

Для микросервисной коммуникации, более эффективный чем REST.

Преимущества:

• Binary protocol (более компактный)
• HTTP/2 multiplexing
• Bidirectional streaming
• Strongly typed

Пример gRPC сервиса:

// user_service.proto
syntax = "proto3";

package com.example.grpc;

message User {
    string id = 1;
    string name = 2;
    string email = 3;
}

message GetUserRequest {
    string user_id = 1;
}

service UserService {
    rpc GetUser(GetUserRequest) returns (User);
    rpc ListUsers(Empty) returns (stream User);
}

// Реализация сервиса
public class UserServiceImpl extends UserServiceGrpc.UserServiceImplBase {
    @Override
    public void getUser(GetUserRequest request, StreamObserver<User> responseObserver) {
        String userId = request.getUserId();
        
        User user = User.newBuilder()
            .setId(userId)
            .setName("John Doe")
            .setEmail("john@example.com")
            .build();
        
        responseObserver.onNext(user);
        responseObserver.onCompleted();
    }
    
    @Override
    public void listUsers(Empty request, StreamObserver<User> responseObserver) {
        // Server streaming
        for (int i = 1; i <= 5; i++) {
            User user = User.newBuilder()
                .setId("user" + i)
                .setName("User " + i)
                .setEmail("user" + i + "@example.com")
                .build();
            responseObserver.onNext(user);
        }
        responseObserver.onCompleted();
    }
}

// Запуск
public class GrpcServer {
    public static void main(String[] args) throws IOException, InterruptedException {
        Server server = ServerBuilder
            .forPort(50051)
            .addService(new UserServiceImpl())
            .build();
        
        server.start();
        System.out.println("gRPC Server started on port 50051");
        server.awaitTermination();
    }
}

MQTT

Для IoT приложений и publish-subscribe messaging.

public class MqttService {
    private MqttClient mqttClient;
    
    public void connect(String brokerUrl) throws MqttException {
        mqttClient = new MqttClient(brokerUrl, MqttClient.generateClientId());
        mqttClient.setCallback(new MqttCallback() {
            @Override
            public void connectionLost(Throwable cause) {
                System.out.println("Connection lost");
            }
            
            @Override
            public void messageArrived(String topic, MqttMessage message) {
                String payload = new String(message.getPayload());
                System.out.println("Received: " + topic + " -> " + payload);
            }
            
            @Override
            public void deliveryComplete(IMqttDeliveryToken token) {
            }
        });
        
        mqttClient.connect();
    }
    
    public void publish(String topic, String message) throws MqttException {
        mqttClient.publish(topic, message.getBytes(), 1, false);
    }
    
    public void subscribe(String topic) throws MqttException {
        mqttClient.subscribe(topic);
    }
}

Apache Kafka

Для event streaming и data pipelines.

@Service
public class KafkaService {
    @KafkaListener(topics = "user-events")
    public void consume(String message) {
        System.out.println("Consumed: " + message);
    }
    
    @Autowired
    private KafkaTemplate<String, UserEvent> kafkaTemplate;
    
    public void publish(UserEvent event) {
        kafkaTemplate.send("user-events", event.getId(), event);
    }
}

AMQP / RabbitMQ

Для асинхронной обработки задач.

@Configuration
public class RabbitConfig {
    @Bean
    public Queue taskQueue() {
        return new Queue("tasks");
    }
    
    @Bean
    public DirectExchange exchange() {
        return new DirectExchange("task-exchange");
    }
    
    @Bean
    public Binding binding(Queue queue, DirectExchange exchange) {
        return BindingBuilder.bind(queue)
            .to(exchange)
            .with("task.#");
    }
}

@Service
public class TaskProducer {
    @Autowired
    private RabbitTemplate rabbitTemplate;
    
    public void sendTask(Task task) {
        rabbitTemplate.convertAndSend("task-exchange", "task.process", task);
    }
}

@Service
public class TaskConsumer {
    @RabbitListener(queues = "tasks")
    public void processTask(Task task) {
        System.out.println("Processing: " + task);
    }
}

FTP / SFTP

Для работы с файлами и данными, передаваемыми по протоколу FTP.

public class FtpService {
    public void uploadFile(String host, String username, String password, 
                          String localFile, String remoteFile) throws IOException {
        FTPClient ftpClient = new FTPClient();
        ftpClient.connect(host);
        ftpClient.login(username, password);
        ftpClient.setFileType(FTP.BINARY_FILE_TYPE);
        
        try (InputStream input = new FileInputStream(localFile)) {
            ftpClient.storeFile(remoteFile, input);
        }
        
        ftpClient.logout();
        ftpClient.disconnect();
    }
}

Другие протоколы

• SSH — управление серверами (JSch библиотека)
• LDAP — аутентификация пользователей
• DNS — разрешение имён
• SMTP — отправка email
• POP3/IMAP — получение email

Выводы

Знание сетевых протоколов позволяет:

• Выбрать оптимальный протокол для каждой задачи
• Писать эффективный код для сетевой коммуникации
• Отлаживать проблемы с соединением
• Оптимизировать latency и bandwidth
• Проектировать масштабируемые системы

Каждый протокол имеет свои преимущества и недостатки. Опыт позволяет выбрать правильный инструмент для конкретной задачи.