org.keycloak.services.filters.KeycloakSessionServletFilter クラス

org.keycloak.services.filters.KeycloakSessionServletFilter の継承関係図

org.keycloak.services.filters.KeycloakSessionServletFilter 連携図

公開メンバ関数
void	init (FilterConfig filterConfig) throws ServletException
void	doFilter (ServletRequest servletRequest, ServletResponse servletResponse, FilterChain filterChain) throws IOException, ServletException
void	destroy ()

非公開メンバ関数
AsyncListener	createAsyncLifeCycleListener (final KeycloakSession session)
void	closeSession (KeycloakSession session)

詳解

著者

Bill Burke

バージョン

Revision

1

関数詳解

closeSession()

void org.keycloak.services.filters.KeycloakSessionServletFilter.closeSession ( KeycloakSession  session )

inlineprivate

                                                       {
        // KeycloakTransactionCommitter is responsible for committing the transaction, but if an exception is thrown it's not invoked and transaction
        // should be rolled back
        if (session.getTransactionManager() != null && session.getTransactionManager().isActive()) {
            session.getTransactionManager().rollback();
        }

        session.close();
        ResteasyProviderFactory.clearContextData();
    }

createAsyncLifeCycleListener()

AsyncListener org.keycloak.services.filters.KeycloakSessionServletFilter.createAsyncLifeCycleListener ( final KeycloakSession  session )

inlineprivate

                                                                                      {
        return new AsyncListener() {
            @Override
            public void onComplete(AsyncEvent event) {
                closeSession(session);
            }

            @Override
            public void onTimeout(AsyncEvent event) {
                closeSession(session);
            }

            @Override
            public void onError(AsyncEvent event) {
                closeSession(session);
            }

            @Override
            public void onStartAsync(AsyncEvent event) {
            }
        };
    }

destroy()

void org.keycloak.services.filters.KeycloakSessionServletFilter.destroy ( )

inline

                          {
    }

doFilter()

void org.keycloak.services.filters.KeycloakSessionServletFilter.doFilter ( ServletRequest  servletRequest, ServletResponse  servletResponse, FilterChain  filterChain  ) throws IOException, ServletException

inline

                                                                                                                                                       {
        servletRequest.setCharacterEncoding("UTF-8");

        final HttpServletRequest request = (HttpServletRequest)servletRequest;

        KeycloakSessionFactory sessionFactory = (KeycloakSessionFactory) servletRequest.getServletContext().getAttribute(KeycloakSessionFactory.class.getName());
        KeycloakSession session = sessionFactory.create();
        ResteasyProviderFactory.pushContext(KeycloakSession.class, session);
        ClientConnection connection = new ClientConnection() {
            @Override
            public String getRemoteAddr() {
                return request.getRemoteAddr();
            }

            @Override
            public String getRemoteHost() {
                return request.getRemoteHost();
            }

            @Override
            public int getRemotePort() {
                return request.getRemotePort();
            }

            @Override
            public String getLocalAddr() {
                return request.getLocalAddr();
            }

            @Override
            public int getLocalPort() {
                return request.getLocalPort();
            }
        };
        session.getContext().setConnection(connection);
        ResteasyProviderFactory.pushContext(ClientConnection.class, connection);

        KeycloakTransaction tx = session.getTransactionManager();
        ResteasyProviderFactory.pushContext(KeycloakTransaction.class, tx);
        tx.begin();

        try {
            filterChain.doFilter(servletRequest, servletResponse);
        } finally {
            if (servletRequest.isAsyncStarted()) {
                servletRequest.getAsyncContext().addListener(createAsyncLifeCycleListener(session));
            } else {
                closeSession(session);
            }
        }
    }

init()

void org.keycloak.services.filters.KeycloakSessionServletFilter.init ( FilterConfig  filterConfig ) throws ServletException

inline

                                                                        {
    }

---

このクラス詳解は次のファイルから抽出されました:

• D:/AppData/doxygen/keycloak/rest-service/src/services/src/main/java/org/keycloak/services/filters/KeycloakSessionServletFilter.java