Angular/NGRX - 防止使用相同参数的重复请求
创始人
2024-10-21 12:02:23
0

在Angular应用中使用NGRX来管理状态时,我们可以通过一些技巧来防止发出重复的请求,尤其是在使用相同参数的情况下。下面是一个解决方法的代码示例:

  1. 首先,我们需要创建一个Action来表示请求的开始和结束,以及请求的结果。
import { createAction, props } from '@ngrx/store';

export const fetchUser = createAction('[User] Fetch User', props<{ id: string }>());
export const fetchUserSuccess = createAction('[User] Fetch User Success', props<{ user: User }>());
export const fetchUserFailure = createAction('[User] Fetch User Failure', props<{ error: string }>());
  1. 接下来,我们需要在Reducer中处理这些Action。
import { createReducer, on } from '@ngrx/store';
import { fetchUser, fetchUserSuccess, fetchUserFailure } from './user.actions';

export interface UserState {
  user: User | null;
  loading: boolean;
  error: string | null;
}

export const initialState: UserState = {
  user: null,
  loading: false,
  error: null
};

export const userReducer = createReducer(
  initialState,
  on(fetchUser, state => ({
    ...state,
    loading: true,
    error: null
  })),
  on(fetchUserSuccess, (state, { user }) => ({
    ...state,
    user,
    loading: false,
    error: null
  })),
  on(fetchUserFailure, (state, { error }) => ({
    ...state,
    loading: false,
    error
  }))
);
  1. 现在,在我们的组件中,我们可以使用一个Selector来获取用户的状态,以便根据需要发出请求。
import { Component } from '@angular/core';
import { Store } from '@ngrx/store';
import { fetchUser } from './user.actions';
import { selectUserLoading, selectUserError, selectUser } from './user.selectors';

@Component({
  selector: 'app-user',
  template: `
    
Loading...
{{ error }}
User: {{ user.name }}
` }) export class UserComponent { loading$ = this.store.select(selectUserLoading); error$ = this.store.select(selectUserError); user$ = this.store.select(selectUser); constructor(private store: Store) {} ngOnInit() { this.store.dispatch(fetchUser({ id: '123' })); } }
  1. 最后,我们可以使用一个Effect来拦截重复的请求,并防止它们被发送到服务器。
import { Injectable } from '@angular/core';
import { Actions, createEffect, ofType } from '@ngrx/effects';
import { mergeMap, filter } from 'rxjs/operators';
import { fetchUser, fetchUserSuccess, fetchUserFailure } from './user.actions';
import { UserService } from './user.service';

@Injectable()
export class UserEffects {
  fetchUser$ = createEffect(() =>
    this.actions$.pipe(
      ofType(fetchUser),
      mergeMap(action =>
        this.userService.getUser(action.id).pipe(
          filter(user => !user), // 过滤掉已经获取到的用户
          map(user => fetchUserSuccess({ user })),
          catchError(error => of(fetchUserFailure({ error })))
        )
      )
    )
  );

  constructor(
    private actions$: Actions,
    private userService: UserService
  ) {}
}

在上述代码中,我们使用了一个filter操作符来过滤掉已经获取到的用户,这样就可以防止重复的请求被发送到服务器。如果用户已经存在于状态中,我们可以选择不发出请求,或者在发出请求之前先检查用户状态。这取决于你的应用程序的需求。

通过以上的解决方法,我们可以确保在使用相同参数的情况下,不会发出重复的请求,并且有效地管理应用程序的状态。

相关内容

热门资讯

Android Recycle... 要在Android RecyclerView中实现滑动卡片效果,可以按照以下步骤进行操作:首先,在项...
安装apache-beam==... 出现此错误可能是因为用户的Python版本太低,而apache-beam==2.34.0需要更高的P...
Android - 无法确定任... 这个错误通常发生在Android项目中,表示编译Debug版本的Java代码时出现了依赖关系问题。下...
Android - NDK 预... 在Android NDK的构建过程中,LOCAL_SRC_FILES只能包含一个项目。如果需要在ND...
Akka生成Actor问题 在Akka框架中,可以使用ActorSystem对象生成Actor。但是,当我们在Actor类中尝试...
Agora-RTC-React... 出现这个错误原因是因为在 React 组件中使用,import AgoraRTC from “ago...
Alertmanager在pr... 首先,在Prometheus配置文件中,确保Alertmanager URL已正确配置。例如:ale...
Aksnginxdomainb... 在AKS集群中,可以使用Nginx代理服务器实现根据域名进行路由。以下是具体步骤:部署Nginx i...
AddSingleton在.N... 在C#中创建Singleton对象通常是通过私有构造函数和静态属性来实现,例如:public cla...
Alertmanager中的基... Alertmanager中可以使用repeat_interval选项指定在一个告警重复发送前必须等待...