在Angular 8中处理SSE连接错误并重新连接的一种解决方法是使用RxJS的retryWhen操作符。下面是一个示例代码：

1. 首先，创建一个SSEService服务，负责处理SSE连接和重新连接的逻辑。

import { Injectable } from '@angular/core';
import { Observable } from 'rxjs';

@Injectable({
  providedIn: 'root'
})
export class SSEService {

  private eventSource: EventSource;

  constructor() { }

  public connect(url: string): Observable {
    return new Observable(observer => {
      this.eventSource = new EventSource(url);

      this.eventSource.onmessage = event => {
        observer.next(event);
      };

      this.eventSource.onerror = error => {
        observer.error(error);
      };

      return () => {
        this.eventSource.close();
      };
    });
  }

  public reconnect(url: string): Observable {
    return this.connect(url).pipe(
      retryWhen(errors => errors)
    );
  }
}

2. 然后，在你的组件中使用SSEService服务来订阅SSE事件并处理连接错误。

import { Component, OnInit } from '@angular/core';
import { SSEService } from './sse.service';

@Component({
  selector: 'app-sse',
  template: `
    

      
{{ message }}
    
  `,
  styleUrls: ['./sse.component.css']
})
export class SSEComponent implements OnInit {

  public messages: string[] = [];

  constructor(private sseService: SSEService) { }

  ngOnInit() {
    const url = 'http://localhost:3000/sse'; // SSE服务器的URL

    this.sseService.reconnect(url).subscribe(
      event => {
        this.messages.push(event.data);
      },
      error => {
        console.error('SSE连接错误:', error);
      }
    );
  }
}

在上面的代码中，SSEService服务通过连接到指定的SSE服务器（在这里假设是localhost:3000/sse）并订阅事件来获取SSE数据。在连接错误时，它会使用retryWhen操作符进行重新连接。

请注意，上述代码只是示例，并假设SSE服务器的URL是'http://localhost:3000/sse'。你需要根据你的实际情况进行调整。

希望这可以帮助你处理Angular 8中的SSE连接错误和重新连接的问题！