- 综合排序
- 最热优先
- 最新优先
- 来自专栏Bypass
如何编写一个SQL注入工具
requests import urllib import re values={} def get(url,values): data = urllib.urlencode(values) geturl +data response = requests.get(geturl) result=response.content find_list=re.findall(r"qwe~ +data response = requests.get(geturl) if response.content.find('qwertyasd')>0: +data response = requests.get(geturl) if response.content.find('qwertyasd')>0 union"+i+j+k+"select*/ 1,user()" geturl=url+payload #print geturl
96610发布于 2020-02-26 - 来自专栏技术男的宅之路
深入Dubbo源码 - Dubbo消费者调用过程
directory中获取调用的方法信息中存储的配置信息Constants.MOCK_KEY（是否使用mock模式，默认为false） String value = directory.getUrl logger.info("force-mock: " + invocation.getMethodName() + " force-mock enabled , url : " + directory.getUrl getInterface().getName() + " was successful by the provider " + invoker.getUrl ().getHost(), invoker.getUrl().getPort()); if (invocation instanceof ，本次调用是否为单向调用 int timeout = getUrl().getMethodParameter(methodName, Constants.TIMEOUT_KEY,
87120发布于 2019-09-19 - 来自专栏JAVA烂猪皮
Dubbo性能调优参数及原理
new ServerBootstrap(channelFactory); final NettyHandler nettyHandler = new NettyHandler(getUrl (), invocation); boolean isOneway = RpcUtils.isOneway(getUrl(), invocation); int timeout = getUrl().getMethodParameter(methodName, Constants.TIMEOUT_KEY,Constants.DEFAULT_TIMEOUT); if (isOneway) { boolean isSent = getUrl().getMethodParameter(methodName, Constants.SENT_KEY, , 0); RpcStatus count = RpcStatus.getStatus(invoker.getUrl(), invocation.getMethodName()); if
1.9K10发布于 2018-08-03 - 来自专栏码匠的流水账
聊聊dubbo的MonitorFilter
> invoker, Invocation invocation) throws RpcException { if (invoker.getUrl().hasParameter(MONITOR_KEY remoteHost, long start, boolean error) { try { URL monitorUrl = invoker.getUrl ().getParameter(GROUP_KEY); String version = invoker.getUrl().getParameter(VERSION_KEY); localPort; String remoteKey, remoteValue; if (CONSUMER_SIDE.equals(invoker.getUrl >[0], new Object[0]); Invoker invoker = mock(Invoker.class); given(invoker.getUrl()).
42210发布于 2019-07-10 - 来自专栏码匠的流水账
聊聊dubbo的Invoker select
logger.warn("force-mock: " + invocation.getMethodName() + " force-mock enabled , url : " + directory.getUrl getInterface().getName() + " was successful by the provider " + invoker.getUrl new RpcException(e.getMessage(), e); } finally { providers.add(invoker.getUrl + providers.size() + "/" + copyInvokers.size() + ") from the registry " + directory.getUrl invoker.isAvailable() && getUrl() !
79930发布于 2019-06-17 - 来自专栏码匠的流水账
聊聊dubbo的Invoker select
invocation) throws RpcException { Result result = null; String value = directory.getUrl logger.warn("force-mock: " + invocation.getMethodName() + " force-mock enabled , url : " + directory.getUrl getInterface().getName() + " was successful by the provider " + invoker.getUrl new RpcException(e.getMessage(), e); } finally { providers.add(invoker.getUrl invoker.isAvailable() && getUrl() !
73420发布于 2019-06-16 - 来自专栏码农沉思录
Dubbo性能调优原来是这么回事
index.getAndIncrement() % clients.length]; } try { boolean isAsync = RpcUtils.isAsync(getUrl (), invocation); boolean isOneway = RpcUtils.isOneway(getUrl(), invocation); int timeout = getUrl().getMethodParameter(methodName, Constants.TIMEOUT_KEY,Constants.DEFAULT_TIMEOUT); if (isOneway) { boolean isSent = getUrl().getMethodParameter(methodName, Constants.SENT_KEY , 0); RpcStatus count = RpcStatus.getStatus(invoker.getUrl(), invocation.getMethodName()); if
3.1K20发布于 2019-06-20 - 来自专栏cs
python下载万方数据库文献
page_cnt=' geturl=head+endstp[0]+"&language="+endstp[2]+"&resourceType="+endstp[6]+"&source="+endstp &resourceId="+endstp[1]+"&resourceTitle="+endstp[4]+"&isoa="+endstp[5]+"&type="+endstp[0] print(geturl >' text=get_html(geturl).text print() sucurl=re.findall(re1,text) print(sucurl) return =getdownurl(url) get_pdf(geturl,title) except: print("has =getdownurl(url) get_pdf(geturl,title) except: print("has
1.7K30发布于 2018-06-08 - 来自专栏码匠的流水账
聊聊dubbo的MonitorFilter
> invoker, Invocation invocation) throws RpcException { if (invoker.getUrl().hasParameter(MONITOR_KEY remoteHost, long start, boolean error) { try { URL monitorUrl = invoker.getUrl ().getParameter(GROUP_KEY); String version = invoker.getUrl().getParameter(VERSION_KEY); localPort; String remoteKey, remoteValue; if (CONSUMER_SIDE.equals(invoker.getUrl >[0], new Object[0]); Invoker invoker = mock(Invoker.class); given(invoker.getUrl()).
88820发布于 2019-06-30 - 来自专栏cmazxiaoma的架构师之路
Android多线程+单线程+断点续传+进度条显示下载
; } public void setCompeleted(int compeleted) { this.compeleted = compeleted; } public String getUrl ,new String[]{info.getThreadId(),info.getUrl()}); } //关闭db public void close(){ db.close(); } / ,new String[]{info.getUrl(),info.getThreadId()}); if(rowId! ()); newInfo.setDownloading(true); map.put(mInfo.getUrl(),newInfo); prepare(newInfo); } //停止下载任务 public void stop() { map.get(mInfo.getUrl()).setDownloading(false); map.get(mInfo.getUrl
2.3K30发布于 2018-06-05 - 来自专栏中间件兴趣圈
源码分析Dubbo异步调用与事件回调机制
Invocation invocation) throws RpcException { 2 final boolean isAsync = RpcUtils.isAsync(invoker.getUrl Method onInvokeMethod = (Method) StaticContext.getSystemContext().get(StaticContext.getKey(invoker.getUrl onInvokeInst == null) { // @4 10 throw new IllegalStateException("service:" + invoker.getUrl "method" : 11 "instance") + " found. url:" + invoker.getUrl()); 12 } (), invocation); // @1 3 boolean isOneway = RpcUtils.isOneway(getUrl(), invocation
2.6K10发布于 2019-06-10 - 来自专栏码匠的流水账
聊聊dubbo-go的DubboInvoker
BaseInvoker{ url: url, available: true, destroyed: false, } } // GetUrl ... func (bi *BaseInvoker) GetUrl() common.URL { return bi.url } // IsAvailable ... func (bi *BaseInvoker (*invocation_impl.RPCInvocation) for _, k := range attachmentKey { if v := di.GetUrl().GetParam k, v) } } // put the ctx into attachment di.appendCtx(ctx, inv) url := di.GetUrl di.reqNum = -1 logger.Infof("dubboInvoker is destroyed,url:{%s}", di.GetUrl
40630发布于 2020-07-29 - 来自专栏码匠的流水账
聊聊dubbo的ForkingClusterInvoker
().getParameter(FORKS_KEY, DEFAULT_FORKS); final int timeout = getUrl().getParameter(TIMEOUT_KEY public void setUp() throws Exception { dic = mock(Directory.class); given(dic.getUrl given(invoker1.invoke(invocation)).willThrow(new RuntimeException()); given(invoker1.getUrl given(invoker2.invoke(invocation)).willThrow(new RuntimeException()); given(invoker2.getUrl given(invoker3.invoke(invocation)).willThrow(new RuntimeException()); given(invoker3.getUrl
61000发布于 2019-08-22 - 来自专栏码匠的流水账
聊聊dubbo的ForkingClusterInvoker
().getParameter(FORKS_KEY, DEFAULT_FORKS); final int timeout = getUrl().getParameter(TIMEOUT_KEY public void setUp() throws Exception { dic = mock(Directory.class); given(dic.getUrl given(invoker1.invoke(invocation)).willThrow(new RuntimeException()); given(invoker1.getUrl given(invoker2.invoke(invocation)).willThrow(new RuntimeException()); given(invoker2.getUrl given(invoker3.invoke(invocation)).willThrow(new RuntimeException()); given(invoker3.getUrl
59740发布于 2019-08-27 - 来自专栏软件开发-青出于蓝
Dubbo集群容错模式之Failover实现 原
List<Invoker<T>> copyinvokers = invokers; checkInvokers(copyinvokers, invocation); int len = getUrl " + getInterface().getName() + " was successful by the provider " + invoker.getUrl providers.size() + "/" + copyinvokers.size() + ") from the registry " + directory.getUrl le = new RpcException(e.getMessage(), e); } finally { providers.add(invoker.getUrl (" + providers.size() + "/" + copyinvokers.size() + ") from the registry " + directory.getUrl
97320发布于 2019-04-15 - 来自专栏码匠的流水账
聊聊dubbo-go的TpsLimitFilter
context.Context, invoker protocol.Invoker, invocation protocol.Invocation) protocol.Result { url := invoker.GetUrl if len(tpsLimiter) > 0 { allow := extension.GetTpsLimiter(tpsLimiter).IsAllowable(invoker.GetUrl constant.TPS_REJECTED_EXECUTION_HANDLER_KEY；对于有配置tpsLimiter的执行extension.GetTpsLimiter(tpsLimiter).IsAllowable(invoker.GetUrl constant.TPS_REJECTED_EXECUTION_HANDLER_KEY；对于有配置tpsLimiter的执行extension.GetTpsLimiter(tpsLimiter).IsAllowable(invoker.GetUrl
25520发布于 2020-07-21 - 来自专栏技术之路
MVC 路由生成URL Url.Action&Html.ActionLink
Url.Action 我们从官方的注释中可以看到每个参数应该传什么样的值，下来我们来使用这个方法，看看生成的URL是什么，下面的是在页面中的代码 <a href="@Url.Action("GetURL ", "URL", new { id = 1001})">action操作 <a href="@Url.Action("GetURL", "URL", new { id = 1001, controller}/{action}/{id} Html.ActionLink 这个方法传的参数看起来会比较复杂，我们通过实例来看就可以很清楚 @Html.ActionLink("详细信息", "GetURL ", "URL", new { id = 1001}, new { @class = "stulink", title = "操作" }) @Html.ActionLink("详细信息", "GetURL
57810编辑于 2024-04-23 - 来自专栏用户5325874的专栏
dubbo源码解析——服务调用过程
{ Result result = null; // 获取mock参数，从而判断是否需要mock String value = directory.getUrl logger.warn("force-mock: " + invocation.getMethodName() + " force-mock enabled , url : " + directory.getUrl invokers, invocation); // invocation ID将被添加在异步操作 RpcUtils.attachInvocationIdIfAsync(getUrl if (destroyed) { throw new RpcException("Directory already destroyed .url: " + getUrl getInterface().getName() + " was successful by the provider " + invoker.getUrl
56010发布于 2020-01-16 - 来自专栏码匠的流水账
聊聊dubbo的NettyServer
ChannelHandler handler) throws RemotingException { super(url, handler); localAddress = getUrl ().toInetSocketAddress(); String bindIp = getUrl().getParameter(Constants.BIND_IP_KEY, getUrl ().getHost()); int bindPort = getUrl().getParameter(Constants.BIND_PORT_KEY, getUrl().getPort int idleTimeout = UrlUtils.getIdleTimeout(getUrl()); NettyCodecAdapter adapter = new NettyCodecAdapter(getCodec(), getUrl(), NettyServer.this); ch.pipeline
93700发布于 2019-08-30 - 来自专栏码匠的流水账
聊聊dubbo的NettyServer
ChannelHandler handler) throws RemotingException { super(url, handler); localAddress = getUrl ().toInetSocketAddress(); String bindIp = getUrl().getParameter(Constants.BIND_IP_KEY, getUrl ().getHost()); int bindPort = getUrl().getParameter(Constants.BIND_PORT_KEY, getUrl().getPort int idleTimeout = UrlUtils.getIdleTimeout(getUrl()); NettyCodecAdapter adapter = new NettyCodecAdapter(getCodec(), getUrl(), NettyServer.this); ch.pipeline
69520发布于 2019-09-03
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号