景

項(xiàng)目中自定義了攔截器Filter，項(xiàng)目中使用了spring security，它也有對(duì)應(yīng)的攔截器，我想讓我自定義的Filter在spring security的攔截器前執(zhí)行。

因?yàn)槲易远x的攔截器，需要提前做一些邏輯處理；然后spring security的攔截器需要用到這部分的處理結(jié)果；所以我必須要想辦法讓我自定義的攔截器靠前執(zhí)行。

那就一起來看看spring security設(shè)置的攔截器的默認(rèn)優(yōu)先級(jí)等級(jí)是多少吧。

模擬場(chǎng)景

自定義攔截器如下：

@Slf4j
public class MyOncePerRequestFilter extends OncePerRequestFilter {
    @Override
    protected void doFilterInternal(HttpServletRequest request, HttpServletResponse response, FilterChain filterChain)
            throws ServletException, IOException {
        log.info("======== MyOncePerRequestFilter ========");
        filterChain.doFilter(request, response);
    }
}

@Configuration
public class Config {
    @Bean
    public FilterRegistrationBean<MyOncePerRequestFilter> i18nFilterRegistrationBean() {
        FilterRegistrationBean<MyOncePerRequestFilter> registrationBean = new FilterRegistrationBean();
        MyOncePerRequestFilter myOncePerRequestFilter = new MyOncePerRequestFilter();
        registrationBean.setFilter(myOncePerRequestFilter);
        registrationBean.addUrlPatterns("/*");
        registrationBean.setOrder(-1);
        return registrationBean;
    }
}

spring security的簡(jiǎn)單配置如下：

@Slf4j
public class MyTokenStore implements TokenStore {
    @Override
    public OAuth2AccessToken readAccessToken(String tokenValue) {
        log.info("======== readAccessToken ========");
        return new DefaultOAuth2AccessToken(tokenValue);
    }

    @Override
    public OAuth2Authentication readAuthentication(OAuth2AccessToken token) {
        Authentication authentication = new AbstractAuthenticationToken(Sets.newHashSet()) {
            {
                super.setAuthenticated(true);
            }
            @Override
            public Object getCredentials() {
                return null;
            }
            @Override
            public Object getPrincipal() {
                return StringUtils.EMPTY;
            }
        };
        OAuth2Request request =
                new OAuth2Request(null, null, null, true,
                        Sets.newHashSet(), Sets.newHashSet(), null, null, null);
        return new OAuth2Authentication(request, authentication);
    }

    @Override public OAuth2Authentication readAuthentication(String token) {
        return null;
    }

    @Override
    public void storeAccessToken(OAuth2AccessToken token, OAuth2Authentication authentication) {
    }

    @Override public void removeAccessToken(OAuth2AccessToken token) {

    }

    @Override public void storeRefreshToken(OAuth2RefreshToken refreshToken, OAuth2Authentication authentication) {
    }

    @Override public OAuth2RefreshToken readRefreshToken(String tokenValue) {
        return null;
    }

    @Override public OAuth2Authentication readAuthenticationForRefreshToken(OAuth2RefreshToken token) {
        return null;
    }

    @Override public void removeRefreshToken(OAuth2RefreshToken token) {
    }

    @Override public void removeAccessTokenUsingRefreshToken(OAuth2RefreshToken refreshToken) {
    }

    @Override public OAuth2AccessToken getAccessToken(OAuth2Authentication authentication) {
        return null;
    }

    @Override public Collection<OAuth2AccessToken> findTokensByClientIdAndUserName(String clientId, String userName) {
        return null;
    }

    @Override public Collection<OAuth2AccessToken> findTokensByClientId(String clientId) {
        return null;
    }
}

@Configuration
@EnableResourceServer
@EnableWebSecurity
public class MyResourceServerConfigurerAdapter extends ResourceServerConfigurerAdapter {

    @Override
    public void configure(ResourceServerSecurityConfigurer resources) {
        MyTokenStore tokenStore = new MyTokenStore();
        resources.tokenStore(tokenStore);
    }

    @Override
    public void configure(HttpSecurity http) throws Exception {
        http.csrf().disable()
                .authorizeRequests().anyRequest().authenticated()
                .and().anonymous().key("anonymousUser")
                .and().httpBasic();
    }
}

啟動(dòng)類如下：

@RestController
public class MyController {
    @GetMapping("/hello")
    public String hello() {
        return "hello,world!";
    }
}

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
public class Starter {
    public static void main(String[] args) {
        SpringApplication.run(Starter.class, args);
    }
}

啟動(dòng)后，訪問 http://127.0.0.1:8080/hello?access_token=123

日志打印如下：

102149 [http-nio-8080-exec-1] INFO  c.e.l.s.mvc.security.MyTokenStore - ======== readAccessToken ======== 
102149 [http-nio-8080-exec-1] INFO  c.e.l.s.m.s.MyOncePerRequestFilter - ======== MyOncePerRequestFilter ======== 

從結(jié)果可以看出，spring security的攔截器是比我們自定義的攔截器先執(zhí)行的，而我們自定義的攔截器的優(yōu)先級(jí)是registrationBean.setOrder(-1)

我猜應(yīng)該是這個(gè)值決定了執(zhí)行順序，那就帶著這個(gè)猜想往下看一下吧。

是不是因?yàn)閛rder的值

在之前的配置中，我們將自定義的攔截器順序置為-1

我們先在MyOncePerRequestFilter.doFilterInternal打個(gè)斷點(diǎn)，看一下執(zhí)行鏈的順序：

從這條鏈中，我們猜測(cè)springSecurityFilterChain的order是-100，我們自定義的攔截器是在它后面的

那我們直接把我們的攔截器設(shè)置成-101，registrationBean.setOrder(-101);，再來嘗試一下：

從斷點(diǎn)結(jié)果可以看出，我們的設(shè)置是有效的，并且起到了作用，而且打印日志也說明了結(jié)果，如下：

11956 [http-nio-8080-exec-1] INFO  c.e.l.s.m.s.MyOncePerRequestFilter - ======== MyOncePerRequestFilter ======== 
98419 [http-nio-8080-exec-1] INFO  c.e.l.s.mvc.security.MyTokenStore - ======== readAccessToken ======== 

找出在哪里賦予的order值

這個(gè)過程是極其枯燥的，所以就先給結(jié)果了，如下：

spring security的攔截器鏈?zhǔn)窃谙旅孢@部分創(chuàng)建的：

@Configuration(proxyBeanMethods = false)
@ConditionalOnWebApplication(type = Type.SERVLET)
@EnableConfigurationProperties(SecurityProperties.class)
@ConditionalOnClass({ AbstractSecurityWebApplicationInitializer.class, SessionCreationPolicy.class })
@AutoConfigureAfter(SecurityAutoConfiguration.class)
public class SecurityFilterAutoConfiguration {
	private static final String DEFAULT_FILTER_NAME = AbstractSecurityWebApplicationInitializer.DEFAULT_FILTER_NAME;
	@Bean
	@ConditionalOnBean(name = DEFAULT_FILTER_NAME)
	public DelegatingFilterProxyRegistrationBean securityFilterChainRegistration(
			SecurityProperties securityProperties) {
		DelegatingFilterProxyRegistrationBean registration = new DelegatingFilterProxyRegistrationBean(
				DEFAULT_FILTER_NAME);
		registration.setOrder(securityProperties.getFilter().getOrder()); // 這里
		registration.setDispatcherTypes(getDispatcherTypes(securityProperties));
		return registration;
	}
}

public abstract class AbstractSecurityWebApplicationInitializer implements WebApplicationInitializer {
    public static final String DEFAULT_FILTER_NAME = "springSecurityFilterChain";
}

@ConfigurationProperties(prefix = "spring.security")
public class SecurityProperties {
	public static final int DEFAULT_FILTER_ORDER = OrderedFilter.REQUEST_WRAPPER_FILTER_MAX_ORDER - 100; // 這里

	private final Filter filter = new Filter();
	public Filter getFilter() {
		return this.filter;
	}
	public static class Filter {
		private int order = DEFAULT_FILTER_ORDER; // 這里
		public int getOrder() {
			return this.order;
		}
		public void setOrder(int order) {
			this.order = order;
		}
	}
}

public interface OrderedFilter extends Filter, Ordered {
	int REQUEST_WRAPPER_FILTER_MAX_ORDER = 0; // 這里
}

從上面的代碼可以看出，默認(rèn)值是-100，同樣也可以使用spring.security.filter.order來自定義值。

下面是尋找此過程的歷程：

繼續(xù)從這里開始，ApplicationFilterChain.internalDoFilter如下：

可以看出所有的攔截器都是在filters中，我們可以看這個(gè)值是怎么來的，通過調(diào)試，是在ApplicationFilterChain.addFilter這個(gè)地方，如下：

它是被ApplicationFilterFactory.createFilterChain調(diào)用的，如下：

所以filters是根據(jù)filterMaps來添加的，我們?cè)賮砜匆幌耭ilterMaps是怎么來的，一共涉及到兩個(gè)地方，如下：

StandardContext.addFilterMap和StandardContext.addFilterMapBefore如下：

看一下調(diào)用鏈：

原來是被ServletWebServerApplicationContext.selfInitialize調(diào)用的，如下：

ServletWebServerApplicationContext.getServletContextInitializerBeans如下：

ServletContextInitializerBeans構(gòu)造函數(shù)如下：

所有的攔截器都是通過addServletContextInitializerBeans(beanFactory);和addAdaptableBeans(beanFactory);來把bean加進(jìn)來的

經(jīng)過一番調(diào)試，終于找到spring security這個(gè)攔截器定義順序的位置，SecurityFilterAutoConfiguration.securityFilterChainRegistration如下：

可以看到SecurityProperties securityProperties是注入進(jìn)來的，找到這個(gè)類看一下，securityProperties.filter.order如下：

@ConfigurationProperties(prefix = "spring.security")
public class SecurityProperties {
	public static final int DEFAULT_FILTER_ORDER = OrderedFilter.REQUEST_WRAPPER_FILTER_MAX_ORDER - 100;
	private final Filter filter = new Filter();
	private final User user = new User();
	public static class Filter {
		/**
		 * Security filter chain order.
		 */
		private int order = DEFAULT_FILTER_ORDER;
		public int getOrder() {
			return this.order;
		}
		public void setOrder(int order) {
			this.order = order;
		}
	}
}
public interface OrderedFilter extends Filter, Ordered {
	/**
	 * Filters that wrap the servlet request should be ordered less than or equal to this.
	 */
	int REQUEST_WRAPPER_FILTER_MAX_ORDER = 0;
}

到此我們也找到了這個(gè)默認(rèn)值，是根據(jù)spring.security.filter.order來決定的，默認(rèn)值是-100

解決辦法

第一種就是修改自己的順序：

@Configuration
public class Config {
    @Bean
    public FilterRegistrationBean<MyOncePerRequestFilter> i18nFilterRegistrationBean() {
        FilterRegistrationBean<MyOncePerRequestFilter> registrationBean = new FilterRegistrationBean();
        MyOncePerRequestFilter myOncePerRequestFilter = new MyOncePerRequestFilter();

        registrationBean.setFilter(myOncePerRequestFilter);
        registrationBean.addUrlPatterns("/*");
        registrationBean.setOrder(-101); // 這里
        return registrationBean;
    }
}

第二種就是修改spring security攔截器的順序：

spring:
  security:
    filter:
      order: 0

大家可以自己跑跑試試看，完結(jié)撒花~~~~~~

原文地址：https://www.cnblogs.com/eaglelihh/p/15009562.html

述：本文將討論如何用最簡(jiǎn)單的術(shù)語在網(wǎng)站上運(yùn)行 C# 代碼。半技術(shù)講座我使用了 wasm-tools-net7，這是一個(gè)基于 wasm-tools 的工作負(fù)載，沒有包含任何額外的包。我的重點(diǎn)是簡(jiǎn)單性和主要主題。徹底了解該主題可提供完成所有其他任務(wù)所需的信息。如何工作？WebAssembly 工作原理：序列圖創(chuàng)建演示創(chuàng)建項(xiàng)目我用的是net7，但這取決于你。Dotnet new console -o WASM_Demo cd WASM_Demo Dotnet workload install wasm-tools-net7此時(shí)，需要對(duì) csproj 文件進(jìn)行修改。Project Sdk=Mi

本文將討論如何用最簡(jiǎn)單的術(shù)語在網(wǎng)站上運(yùn)行 C# 代碼。

半技術(shù)講座

我使用了 wasm-tools-net7，這是一個(gè)基于 wasm-tools 的工作負(fù)載，沒有包含任何額外的包。我的重點(diǎn)是簡(jiǎn)單性和主要主題。徹底了解該主題可提供完成所有其他任務(wù)所需的信息。

如何工作？

WebAssembly 工作原理：序列圖

創(chuàng)建演示

創(chuàng)建項(xiàng)目

• 我用的是net7，但這取決于你。

Dotnet new console -o WASM_Demo  
  
cd WASM_Demo  
  
Dotnet workload install wasm-tools-net7

此時(shí)，需要對(duì) csproj 文件進(jìn)行修改。

<Project Sdk="Microsoft.NET.Sdk">

    <PropertyGroup>
        <OutputType>Exe</OutputType>
        <TargetFramework>net7.0</TargetFramework>
        <ImplicitUsings>enable</ImplicitUsings>
        <Nullable>enable</Nullable>

        <RuntimeIdentifier>browser-wasm</RuntimeIdentifier>
        <WasmMainJSPath>main.js</WasmMainJSPath>
        <AllowUnsafeBlocks>true</AllowUnsafeBlocks>
    </PropertyGroup>

    <ItemGroup>
        <WasmExtraFilesToDeploy Include="index.html" />
        <WasmExtraFilesToDeploy Include="main.js" />
    </ItemGroup>

</Project>

我們添加了什么：

• RuntimeIdentifier （wasm-tools 需要）
• WasmMainJSPath （wasm-tools 需要）
• AllowUnsafeBlocks（JSExportAttribute 需要不安全的代碼）
• ItemGroup （Include as resource）導(dǎo)入 index.html導(dǎo)入main.js

返回到program.cs文件，需要考慮某些規(guī)則。

• 類必須是公共的和部分的。
• 函數(shù)必須是公共的和靜態(tài)的，并且必須使用 [JSExport] 進(jìn)行屬性化。

讓我們舉個(gè)例子。

using System.Runtime.InteropServices.JavaScript;

namespace WASM_Demo;

public partial class Program
{
    static void Main(string[] args) { }

    [JSExport]
    public static string Response()
    {
        return """
               <h1>
                   Hello World
               </h1>
               """;
    }
}

沒關(guān)系，但是我們?nèi)绾卧跒g覽器中運(yùn)行此代碼？

運(yùn)行這個(gè)程序的代碼是dotnet.js的，它自帶了wasm-tools，所以沒有必要擔(dān)心它。要使用此dotnet.js，我們只需使用一個(gè)名為 main.js 的文件。

import { dotnet } from './dotnet.js'

const is_browser = typeof window != "undefined";
if (!is_browser) throw new Error(`Expected to be running in a browser`);

const { setModuleImports, getAssemblyExports, getConfig, runMainAndExit } = await dotnet
    .withDiagnosticTracing(false)
    .withApplicationArgumentsFromQuery()
    .create();

const config = getConfig();
const exports = await getAssemblyExports(config.mainAssemblyName);

const html = 
    exports
        .WASM_Demo    // Namespace
        .Program      // Class Name
        .Response();  // Function Name

// Regular javascript code
document.getElementById("app").innerHTML = `${html}`;

await runMainAndExit(config.mainAssemblyName, [] /* Console App Args */);

index.html頁面的模板已經(jīng)準(zhǔn)備完畢。

<!DOCTYPE html>
<html lang="en">
    <head>
        <title>WASM Demo</title>
        <meta charset="UTF-8" />
        <meta name="viewport" content="width=device-width, initial-scale=1.0" />
        <link rel="modulepreload" href="./dotnet.js" />
    </head>
    
    <body>
        <main id="app"></main>
        <script type="module" src="./main.js"></script>
    </body>
</html>

現(xiàn)在，讓我們?cè)倏匆槐檫@個(gè)過程，

• HTTP 請(qǐng)求傳入
• WASM-Tools 處理此問題并發(fā)送index.html文件。
• index.html文件請(qǐng)求dotnet.js和main.js文件，dotnet.js由 WASM-Tools 發(fā)送，main.js是我們的自定義代碼。
• 通過在 main.js 中使用 dotnet.js，我們可以進(jìn)入 C# 代碼中的 Program 類，調(diào)用 Response 函數(shù)并在 main.js 中進(jìn)行我們想要的任何客戶端更改。

我們還有一件事要做，你需要打開一個(gè)名為 runtimeconfig.template.json 的文件，并將以下 JSON 數(shù)據(jù)放入其中。

{
  "wasmHostProperties": {
    "perHostConfig": [
      {
        "name": "browser",
        "html-path": "index.html",
        "Host": "browser"
      }
    ]
  }
}

我們已經(jīng)到了盡頭，程序現(xiàn)在可以運(yùn)行了。唯一需要的命令是：

Dotnet run -c Release

常見問題

我可以托管所有文件而不是 wasm-tools 嗎？又是如何做到的呢？

當(dāng)然，但它可能會(huì)變得有點(diǎn)復(fù)雜，你用 wasm-tools 制作的項(xiàng)目不能用于任何其他目的，即控制臺(tái)應(yīng)用程序不起作用，wasm-tools 可以工作。因?yàn)槲覀冞x擇 browser-wasm 作為 RuntimeIdentifier，并且多個(gè) RuntimeIdentifiers 在 .NET 中不可用。作為替代方法，您可以打開兩個(gè)項(xiàng)目，將第一個(gè)項(xiàng)目設(shè)置為 WASM 項(xiàng)目，然后在第二個(gè)項(xiàng)目中將其設(shè)置為控制臺(tái)應(yīng)用程序，然后生成第一個(gè)項(xiàng)目并托管輸出文件夾，所有 DLL 和文件都將在那里。

這個(gè)演示只是索引文件，我可以做多頁嗎？又是如何做到的呢？

當(dāng)然，但這比你想象的要難得多，因?yàn)檫@樣做的方法是一種叫做SPA（單頁應(yīng)用程序）的方法，用戶總是在同一頁面上，只是內(nèi)容發(fā)生了變化。有多種方法可以做到這一點(diǎn)。所以它可以用你的創(chuàng)造力來完成。

我可以像計(jì)數(shù)器一樣做動(dòng)態(tài)代碼嗎？又是如何做到的呢？

_是的，我也這樣做了，你可以一遍又一遍地調(diào)用 C# 函數(shù)，如果你只是將導(dǎo)出綁定到 window 對(duì)象，你可以從每個(gè) JavaScript 代碼中調(diào)用它。

@Component
@Configuration
public class RabbitMqConfig {
 @Bean
 public Queue curQueue() {
 Map<String, Object> args = new HashMap<String, Object>();
 //超時(shí)后的轉(zhuǎn)發(fā)器 過期轉(zhuǎn)發(fā)到 delay_queue_exchange
 args.put("x-dead-letter-exchange", "delay_queue_exchange");
 //routingKey 轉(zhuǎn)發(fā)規(guī)則
 args.put("x-dead-letter-routing-key", "user.#");
 //過期時(shí)間 20 秒
 args.put("x-message-ttl", 20000);
 return new Queue("cur_queue", false, false, false, args);
 }
 @Bean
 public Queue delayQueue() {
 return new Queue("delay_queue");
 }
 @Bean
 TopicExchange exchange() {
 //當(dāng)前隊(duì)列
 return new TopicExchange("cur_queue_exchange");
 }
 @Bean
 TopicExchange exchange2() {
 //被轉(zhuǎn)發(fā)的隊(duì)列
 return new TopicExchange("delay_queue_exchange");
 }
 @Bean
 Binding bindingHelloQueue(Queue curQueue, TopicExchange exchange) {
 //綁定隊(duì)列到轉(zhuǎn)發(fā)器
 return BindingBuilder.bind(curQueue).to(exchange).with("user.#");
 }
 @Bean
 Binding bindingHelloQueue2(Queue delayQueue, TopicExchange exchange2) {
 return BindingBuilder.bind(delayQueue).to(exchange2).with("user.#");
 }
}

@Component
public class MqEventSender {
 Logger logger = LoggerFactory.getLogger(MqEventSender.class);
 @Autowired
 private RabbitTemplate rabbitTemplate;
 /**
 * 消息沒有設(shè)置 時(shí)間
 * 發(fā)生到隊(duì)列 cur_queue_exchange
 * @param msg
 */
 public void sendMsg(String msg) {
 logger.info("發(fā)送消息： " + msg);
 rabbitTemplate.convertAndSend("cur_queue_exchange", "user.ss", msg);
 }
 /**
 * 消息設(shè)置時(shí)間
 * 發(fā)生到隊(duì)列 cur_queue_exchange
 * @param msg
 */
 public void sendMsgWithTime(String msg) {
 logger.info("發(fā)送消息： " + msg);
 MessageProperties messageProperties = new MessageProperties();
 //過期時(shí)間設(shè)置 10 秒
 messageProperties.setExpiration("10000");
 Message message = rabbitTemplate.getMessageConverter().toMessage(msg, messageProperties);
 rabbitTemplate.convertAndSend("cur_queue_exchange", "user.ss", message);
 }
}

/**
 * Created by linli on 2017/8/21.
 * 監(jiān)聽 被丟到 超時(shí)隊(duì)列內(nèi)容
 */
@Component
@RabbitListener(queues = "delay_queue")
public class DelayQueueListener {
 public static Logger logger = LoggerFactory.getLogger(AddCommentsEventListener.class);
 @RabbitHandler
 public void process(@Payload String msg) {
 logger.info("收到消息 "+msg);
 }
}

/**
 * Created by linli on 2017/8/21.
 */
@RestController
@RequestMapping("/test")
public class TestContorller {
 @Autowired
 MqEventSender sender;
 @RequestMapping("/mq/delay")
 public String test() {
 sender.sendMsg("隊(duì)列延時(shí)消息!");
 sender.sendMsgWithTime("消息延時(shí)消息!");
 return "";
 }
}