本例是把多个线程访问数据库的请求,全部阻塞到一个线程. 这是实际编程中常见的一种问题. 示例源码下载,所需支持单元均在源码中,且附详细说明. TElegantThread 的父类是 TSimpleThread. unit uElegantThread; interface uses Classes, SysUtils, uSimpleThread, uSimpleList, uSyncObjs; type PSyncRec = ^TSyncRec; TSyncRec = record FMeth

uses HttpEncode: HttpEncode(AnsiToUtf8('***'))

http://www.cybletter.com/index.php?id=3 http://www.cybletter.com/index.php?id=30 Source Code http://www.cybletter.com/index.php?s=file_download&id=3 Full Paper www.cybletter.com/index.php?s=file_download&id=4 Alexandr ŠtefekMilitary Academy in Brn

android中涉及到将服务器中数据变化信息通知用户一般有两种办法,推送和轮询. 消息推送是服务端主动发消息给客户端,因为第一时间知道数据发生变化的是服务器自己,所以推送的优势是实时性高.但服务器主动推送需要单独开发一套能让客户端持久连接的服务端程序,不过现在已经有很多开源的代码实现了基于xmmp协议的推送方案,而且还可以使用谷歌的推送方案.但有些情况下并不需要服务端主动推送,而是在一定的时间间隔内客户端主动发起查询. 譬如有这样一个app,实时性要求不高,每天只要能获取10次最新数据就能满足要

高并发系统下, 有三把利器 缓存 降级 限流. 缓存: 将常用数据缓存起来, 减少数据库或者磁盘IO 降级: 保护核心系统, 降低非核心业务请求响应 限流: 在某一个时间窗口内对请求进行限速, 保护系统 本文主要介绍限流, 常见限流算法中又分为计数器算法, 漏桶算法, 令牌桶算法. 计数器算法 比较简单, 直接用一个map + counter即可实现. 请求来了, 以IP为key, 查询下之前响应次数, 如果调用次数超出MAX_COUT, 返回失败, 属于简单粗暴型选手. 漏桶算法 请求全部进入

客户端 package com.lsw.client; import java.io.*; import java.net.*; import java.util.*; public class HTTPClinet { public static void main(String[] args){ //确定http请求的uri String uri = "index.html"; if(args.length !=0) uri = args[0]; //按照get请求方式访问http

Java Thread系列(十)Future 模式 Future 模式适合在处理很耗时的业务逻辑时进行使用,可以有效的减少系统的响应时间,提高系统的吞吐量. 一.Future 模式核心思想 如下的请求调用过程时序图.当 call 请求发出时,需要很长的时间才能返回.左边的图需要一直等待,等返回数据后才能继续其他操作:而右边的 Future 模式的图中客户端则无需等到可以做其他的事情.服务器段接收到请求后立即返回结果给客户端,这个结果并不是真实的结果(是虚拟的结果),也就 是先获得一个假数据,然后

urlmon.dll中有一个用于下载的API,MSDN中的定义如下: HRESULT URLDownloadToFile(             LPUNKNOWN pCaller,       LPCTSTR szURL,      LPCTSTR szFileName,       DWORD dwReserved,       LPBINDSTATUSCALLBACK lpfnCB); Delphi的UrlMon.pas中有它的Pascal声明: function URLDownload

使用背景:在使用app或者pc网页时,可能由于网络原因,api接口可能被前端调用一个接口重复2次的情况,但是请求内容是一样的.这样在同一个短暂的时间内,就会有两个相同请求,而程序只希望处理第一个请求,第二个请求是重复的.比如创建订单,相同内容可能出现两次, 这样如果接口不处理,可能用户会创建2个订单. 分布式锁的接口幂等性实现 基于Redis实现分布式锁(前提是单台Redis),如果是多台Redis集群,可能有非同步的异常情况. 实现思路: 利用redis的setnx(key, value):“

原文:https://www.jianshu.com/p/326465500d1c?utm_campaign 使用场景 之前在实现熔断降级组件时,需要实现一个接口的超时中断,意思是,业务在使用熔断降级功能时,在平台上设置了一个超时时间,如果在请求进入熔断器开始计时,并且接口在超时时间内没有响应,则需要提早中断该请求并返回. 比如正常下游接口的超时时间为800ms,但是因为自身业务的特殊需求,最多只能等200ms,如果200ms之内没有数据返回,则返回降级数据.这里处理请求的线程可以看成是tomc

获取网络文件大小 //delphi 获取网络文件大小 function GetUrlFileSize(aURL: string): integer; var FileSize: integer; var IdHTTP: TidHttp; begin IdHTTP:= Tidhttp.Create(nil); IdHTTP.Head(aURL); FileSize := IdHTTP.Response.ContentLength; IdHTTP.Disconnect; Result := File

SynchronizationContext -MSDN 很让人失望 我不知道为什么,目前在.Net下关于这个类只有很少的资料.MSDN文档也只有很少的关于如何使用SynchronizationContext的资料.最开始的时候,我不得不说我在理解为什么有这个类以及怎么使用这个类上经历了一段困难的时间.通过阅读大量的相关资料,我最终搞明白了这个类的目的以及它应该如何去使用.我决定写这篇文章来帮助其他开发者理解如何使用这个类,这个类能干嘛以及它不能干嘛. 使用SynchronizationCont

SynchronizationContext -MSDN 很让人失望 我不知道为什么,目前在.Net下关于这个类只有很少的资料.MSDN文档也只有很少的关于如何使用SynchronizationContext的资料.最开始的时候,我不得不说我在理解为什么有这个类以及怎么使用这个类上经历了一段困难的时间.通过阅读大量的相关资料,我最终搞明白了这个类的目的以及它应该如何去使用.我决定写这篇文章来帮助其他开发者理解如何使用这个类,这个类能干嘛以及它不能干嘛. 使用SynchronizationCont

服务端 using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.IO; using System.Net; using System.Net.Sockets; using System.Text; using System.Threading; using System.Windows.For

TCP传送数据可以分为同步传送和异步传送,首先这里使用了TCP的同步传送方式,学习了TCP同步传送数据的原理. 同步工作方式是指利用TCP编写的程序执行到监听或者接受数据语句的时候,在未完成当前工作(侦听到连接请求或接收到对方发送来的数据)前不在继续往下执行,线程处于阻塞状态,直到该语句完成响应的工作以后才继续执行下一语句. TCP协议只需要将数据以字节流的形式发送到缓存,在他自己看来就好像已经完成了此动作,然而此时的数据让可能还在缓冲区.至于对方是否真正的接收到数据,就不再负责了.这以后可以继

package com.weijia.tests; import java.io.IOException; import java.net.InetSocketAddress; import java.net.ServerSocket; import java.net.Socket; import java.util.concurrent.Executor; import org.apache.http.HttpException; import org.apache.http.HttpRequ

Socket是网络编程的一个抽象的概念,通常我们用Socket来表示服务器与客户端间的网络连接, 即用Socket表示"打开了一个网络连接", 而打开一个网络连接需要知道目标电脑的ip地址以及端口号,然后指定协议的类型即可. 客户端 大多数的连接都是可靠的TCP连接,在创建TCP时,主动发起请求的就是客户端,被动响应请求的就是服务器端. 1.当我们创建一个基于TCP连接的Socket时可以这样做: //创建负责通讯的客户端Socket socket = new Socket(Addre

Android Http Server 1 引言          Android如何构建Http服务器呢?本文的小例子,约莫着,还是能做个参考的^^.恩,例子实现的是PC浏览手机文件,支持了下载和删除.   2 准备          Http协议现今还是RFC2616吧,其基础的知识还是有必要了解的.弄份协议规范书参考,是个不错的选择.之后呢,就可以开始了^^.            起初,想自己写个Http服务器学习来着,后来懒了==.有兴趣的,推荐NanoHTTPD,很小型的仅一个类的h

转自:http://www.cnblogs.com/zhili/archive/2012/08/25/2656840.html 前言 前面专题的例子都是基于应用层上的HTTP协议的介绍, 现在本专题来介绍下传输层协议——TCP协议,主要介绍下TCP协议的工作过程和基于TCP协议的一个简单的通信程序,下面就开始本专题的正文了. 一.TCP的工作过程 首先TCP是一种面向连接的,可靠的,基于字节流的传输层通信协议.TCP的工作过程可以分为三个阶段:一.连接的建立:  二.传输数据: 三.断开连接,下

http://www.cnblogs.com/chengxingliang/archive/2012/05/24/2515100.html 在Silverlight中进行通讯,只能使用4502-4534之间的端口进行数据传输,另外Silverlight客户端会自动向943端口的服务器端发送一个“<policy-file-request/>”的语句请求,然后服务器端943端口回发以下文件以许可Socket通讯. <?xml version="1.0" encoding=

最近在做一个机器人项目,要实时的接收机器人传回的坐标信息,并在客户端显示当前的地图和机器人的位置.当然坐标的回传是用的Socket,用的是C++的结构体表示的坐标信息.但是C#不能像C++那样很easy的把字节数组byte[]直接的转换成结构,来发送和接收.在C#中要多做一些工作.但是在C或者C++中这是一件很容易的事,只需要一个函数: void *memcpy(void *dest, const void *src, size_t n);//从源src所指的内存地址的起始位置开始拷贝n个字节到