///

With that you can connect the WebSocket and then send and receive messages:

<img src="/img/tutorial/websockets/image05.png">

## Handling disconnections and multiple clients { #handling-disconnections-and-multiple-clients }

如果你刚开始使用 **FastAPI**，可以先跳过本节。

///

## 使用场景 { #use-cases }

一些使用场景包括：

* 将非 JSON 的请求体转换为 JSON（例如 [`msgpack`](https://msgpack.org/index.html)）。
* 解压缩使用 gzip 压缩的请求体。
* 自动记录所有请求体日志。

## 处理自定义请求体编码 { #handling-custom-request-body-encodings }

来看如何用自定义的 `Request` 子类来解压 gzip 请求。

以及一个 `APIRoute` 子类来使用该自定义请求类。

### 创建自定义 `GzipRequest` 类 { #create-a-custom-gziprequest-class }

/// tip | 提示

import java.io.IOException;
import java.net.SocketException;
import java.net.SocketTimeoutException;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

/**
 * RDMA error handling and recovery logic.
 *
 * This class provides centralized error handling for RDMA operations,
 * including retry logic and fallback mechanisms.
 */
public class RdmaErrorHandler {

- Розпакування тіл запитів, стиснених gzip.
- Автоматичне логування всіх тіл запитів.

## Обробка користувацьких кодувань тіла запиту { #handling-custom-request-body-encodings }

Розгляньмо, як використати користувацький підклас `Request` для розпакування gzip-запитів.

А також підклас `APIRoute`, щоб застосувати цей користувацький клас запиту.

* gzip ile sıkıştırılmış request body'leri açmak (decompress).
* Tüm request body'lerini otomatik olarak loglamak.

## Özel request body encoding'lerini ele alma { #handling-custom-request-body-encodings }

Gzip request'lerini açmak için özel bir `Request` alt sınıfını nasıl kullanabileceğimize bakalım.

Ayrıca, o özel request sınıfını kullanmak için bir `APIRoute` alt sınıfı da oluşturacağız.

 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.core.timer;

/**
 * This is an interface for handling timeouts.
 *
 * @author higa
 *
 */
@FunctionalInterface
public interface TimeoutTarget {

    /**
     * Describes the processing for a timeout.
     */
    void expired();

            .named(parentBuilder.getName() + " [Map]")
            .suppressing(parentBuilder.getSuppressedTests())
            .suppressing(SetCreationTester.class.getMethods())
            // BiMap.entrySet() duplicate-handling behavior is too confusing for SetCreationTester
            .withSetUp(parentBuilder.getSetUp())
            .withTearDown(parentBuilder.getTearDown())
            .createTestSuite());
    /*

        return this;
    }

    /**
     * Connects to the URL and executes the request.
     *
     * @param actionListener the action listener for handling the response
     * @param exceptionListener the exception listener for handling exceptions
     */
    public void connect(final Consumer<HttpURLConnection> actionListener, final Consumer<Exception> exceptionListener) {
        final Runnable task = () -> {

import org.codelibs.fess.app.web.admin.dict.mapping.DownloadForm;

/**
 * Download body for mapping dictionary API operations.
 * This class extends the DownloadForm to provide request body handling
 * for downloading mapping dictionaries via REST API.
 *
 */
public class DownloadBody extends DownloadForm {

    /**
     * Default constructor.
     */
    public DownloadBody() {
        super();

 * specific language governing permissions and limitations
 * under the License.
 */
package org.apache.maven.artifact.repository.metadata;

/**
 * Assists in handling repository metadata.
 *
 */
@Deprecated
class MetadataUtils {

    public static Metadata cloneMetadata(Metadata src) {
        if (src == null) {
            return null;
        }