Android Spingboot 实现SSE通信案例

import org.springframework.web.servlet.mvc.method.annotation.SseEmitter;
@RestController
public class SseController {
    @GetMapping(value = "/events", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public SseEmitter handleSseRequest() {
        SseEmitter emitter = new SseEmitter();
        new Thread(() -> {
            try {
                for (int i = 0; i < 10; i++) {
                    emitter.send("Message " + i);
                    Thread.sleep(2000);
                }
                emitter.complete();
            } catch (Exception e) {
                emitter.completeWithError(e);
            }
        }).start();
        return emitter;
    }
}

import android.os.Bundle;
import android.util.Log;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;
import androidx.appcompat.app.AppCompatActivity;
import org.jetbrains.annotations.NotNull;
import org.springframework.http.HttpHeaders;
import org.springframework.http.MediaType;
import org.springframework.web.reactive.function.client.WebClient;
public class MainActivity extends AppCompatActivity {
    private TextView textView;
    private Button startButton;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);
        textView = findViewById(R.id.textView);
        startButton = findViewById(R.id.startButton);
        startButton.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                startSseRequest();
            }
        });
    }
    private void startSseRequest() {
        WebClient webClient = WebClient.create("http://your-server-url");
        HttpHeaders headers = new HttpHeaders();
        headers.setContentType(MediaType.TEXT_EVENT_STREAM);
        webClient.get()
              .uri("/events")
              .headers(headers)
              .retrieve()
              .bodyToFlux(String.class)
              .subscribe(response -> {
                    Log.d("SSE", "Received: " + response);
                    textView.append(response + "\n");
                }, error -> {
                    Log.e("SSE", "Error: " + error.getMessage());
                });
    }
}