BlogJava-黑灵客栈

在传输层上压�~�WebService的请求和响应

黑灵 — Sun, 23 Jun 2013 13:45:00 GMT

摘要: 场景场景是这��L��Q�客��L��.NET 3.5应用�E�序�Q�WCF实现WebService调用�Q?服务端Java�Q�通过CXF提供WebService�? 有一个方法提供了有一个字�W�串�c�d��的参敎ͼ�实际生��环境里会�?00k以上的字�W�串。在�q�发量比较大的情况下�Q�带宽占用很严重。所以寻找一�U�可以把传输�?SOAP消息在客��L��压羃�Q�服务端解压�~�的�Ҏ��?�q�里提供的方式在是客��L��通过WCF�?.. 阅读全文

黑灵 2013-06-23 21:45 发表评论

在MongoDB里实现��@环序列功�?

黑灵 — Fri, 26 Apr 2013 14:57:00 GMT

环境是这��L��Q�服务器是用Java做的�Q?数据库是MongoDB

需求是�q�样的：我们的系�l�里要生成一个唯一ID�Q�前面的部分有一定的格式�Q��ƈ和时间关联， �_��到微�U�，考虑到同一微秒内有可能存在�q�发情况�Q? 所以后面在加两位序列号�Q?�pȝ��需要定义�ؓ1毫秒内的�q�发��于100个，所以后面两位就够用了�? Java服务器端有多台机器都可以用来生成�q�个唯一ID�Q�所以需要在不同的机器上不能生成相同的序列号�Q�所以需要在某一点上做全局的范围同步来保存�q�序�? ��L��唯一性�?其实如果不考虑需求里的唯一ID是有一定意义的格式的，用UUID或MongoDB的ObjectId都是更好的选择�Q�完全不需要在某一点上�q�行同步�Q�性能会更好�?/p>

�q�个可以生成序列��L��点，我们可以做一个序列号生成服务器来对应�Q?也可以用数据库来对应�? 单单��个简单的功能准备一个服务器来做昄��不合适�?但是我们用的MongoDB�q�没有类��g��MySQL或Oracle中的SELECT FOR UPDATE�q�样的锁机制�?所以没有办法简单的对这个序列号做原子操作�? 但是MongoDB的对单个document�q�行update操作中有很是��h��原子性的�Q?例如

$set
$unset
$inc
$push
$pushAll
$pull
$pullAll

我们可以利用�q�些原子操作�Q�在数据库层以乐观锁的�Ş式来实现循环序列字段。�ؓ了方便调用我把这�D�逻辑做成数据库中的Javascript函数�?�c�M��与MySQL中的存储�q�程�?/p>

首先我们需要一个collection来存攑ֺ�列号�Q��ƈ寚w��要的需要的序列可��行初始化。我们叫它counters�?/p>

Js代码

db.counters.save({_id:"SerialNo1", val:0, maxval:99})

然后我们想system.js里添加一个Javascript函数

Js代码

db.system.js.save({_id:"getNextUniqueSeq",
value:function (keyName) {
var seqObj = db.counters.findOne({_id:keyName});
if (seqObj == null) {
print("can not find record with key: " + keyName);
return -1;
}
// the max value of sequence
var maxVal = seqObj.maxval;
// the current value of sequence
var curVal = seqObj.val;
while(true){
// if curVal reach max, reset it
if(curVal >= maxVal){
db.counters.update({_id : keyName, val : curVal}, { $set : { val : 0 }}, false, false);
var err = db.getLastErrorObj();
if( err && err.code ) {
print( "unexpected error reset data: " + tojson( err ) );
return -2;
} else if (err.n == 0){
// fail to reset value, may be reseted by others
print("fail to reset value: ");
}
// get current value again.
seqObj = db.counters.findOne({_id:keyName});
maxVal = seqObj.maxval;
curVal = seqObj.val;
continue;
}
// if curVal not reach the max, inc it;
// increase
db.counters.update({_id : keyName, val : curVal}, { $inc : { val : 1 }}, false, false);
var err = db.getLastErrorObj();
if( err && err.code ) {
print( "unexpected error inc val: " + tojson( err ) );
return -3;
} else if (err.n == 0){
// fail to reset value, may be increased by others
print("fail to inc value: ");
// get current value again.
seqObj = db.counters.findOne({_id:keyName});
maxVal = seqObj.maxval;
curVal = seqObj.val;
continue;
} else {
var retVal = curVal + 1;
print("success to get seq : " + retVal);
// increase successful
return retVal;
}
}
}
});

上面�q�段会把指定的序列号的val�?1�Q�如果val辑ֈ�上限则从0开始。所以叫循环序列�?/p>

其实上面的实现在原理上和Java里的AtomicInteger�p�d��的功能实现是�c�M��的，利用循环重试和原子性的CAS来实现。这�U�实现方式在多线�E�的环境里由于锁�Q�Monitor�Q�的范围很小�Q�所以�ƈ发性上比排他锁要好一些�?/p>

下面我们用Java来测试一下这个函数的正确性�?卛_��多线�E�的情况下会不会得到重复的序列号�?/p>

�W�一个测试，val=0�Q?maxval=2000�Q?Java�?0个线�E�每个线�E��@环调�?00�ơ�?�?000�ơ�?所以正��的情况下，�?�?999应该每个数字只出��C��ơ�?/p>

Java代码

@Test
public void testGetNextUniqueSeq1() throws Exception {
final int THREAD_COUNT = 20;
final int LOOP_COUNT = 100;
Mongo mongoClient = new Mongo("172.17.2.100", 27017);
DB db = mongoClient.getDB("im");
db.authenticate("imadmin", "imadmin".toCharArray());
BasicDBObject q = new BasicDBObject();
q.put("_id", "UNIQUE_KEY");
BasicDBObject upd = new BasicDBObject();
BasicDBObject set = new BasicDBObject();
set.put("val", 0);
set.put("maxval", THREAD_COUNT * LOOP_COUNT);
upd.put("$set", set);
db.getCollection("counters").update(q, upd);
Thread[] threads = new Thread[THREAD_COUNT];
final int[][] results = new int[THREAD_COUNT][LOOP_COUNT];
for (int i = 0; i < THREAD_COUNT; i++) {
final int temp_i = i;
threads[i] = new Thread("" + i) {
@Override
public void run() {
try {
Mongo mongoClient = new Mongo("172.17.2.100", 27017);
DB db = mongoClient.getDB("im");
db.authenticate("imadmin", "imadmin".toCharArray());
for (int j = 0; j < LOOP_COUNT; j++) {
Object result = db.eval("getNextUniqueSeq(\"UNIQUE_KEY\")");
System.out.printf("Thread %s, seq=%d\n", Thread.currentThread().getName(), ((Double) result).intValue());
results[temp_i][j] = ((Double) result).intValue();
}
} catch (UnknownHostException e) {
e.printStackTrace();
}
}
};
}
for (Thread thread : threads) {
thread.start();
}
for (Thread thread : threads) {
thread.join();
}
for (int num = 1; num <= LOOP_COUNT * THREAD_COUNT; num++) {
// every number appear 1 times only!
int times = 0;
for (int j = 0; j < THREAD_COUNT; j++) {
for (int k = 0; k < LOOP_COUNT; k++) {
if (results[j][k] == num)
times++;
}
}
assertEquals(1, times);
}
}

然后我们再测试一下��@环的情况�?val=0, maxval=99�?同样是Java�?0个线�E�每个线�E��@环调�?00�ơ�?�?000�ơ。这�ơ从0�?9的数字每个应该取�?0�ơ�?/p>

Java代码

@Test
public void testGetNextUniqueSeq2() throws Exception {
final int THREAD_COUNT = 20;
final int LOOP_COUNT = 100;
Mongo mongoClient = new Mongo("172.17.2.100", 27017);
DB db = mongoClient.getDB("im");
db.authenticate("imadmin", "imadmin".toCharArray());
BasicDBObject q = new BasicDBObject();
q.put("_id", "UNIQUE_KEY");
BasicDBObject upd = new BasicDBObject();
BasicDBObject set = new BasicDBObject();
set.put("val", 0);
set.put("maxval", LOOP_COUNT);
upd.put("$set", set);
db.getCollection("counters").update(q, upd);
Thread[] threads = new Thread[THREAD_COUNT];
final int[][] results = new int[THREAD_COUNT][LOOP_COUNT];
for (int i = 0; i < THREAD_COUNT; i++) {
final int temp_i = i;
threads[i] = new Thread("" + i) {
@Override
public void run() {
try {
Mongo mongoClient = new Mongo("172.17.2.100", 27017);
DB db = mongoClient.getDB("im");
db.authenticate("imadmin", "imadmin".toCharArray());
for (int j = 0; j < LOOP_COUNT; j++) {
Object result = db.eval("getNextUniqueSeq(\"UNIQUE_KEY\")");
System.out.printf("Thread %s, seq=%d\n", Thread.currentThread().getName(), ((Double) result).intValue());
results[temp_i][j] = ((Double) result).intValue();
}
} catch (UnknownHostException e) {
e.printStackTrace();
}
}
};
}
for (Thread thread : threads) {
thread.start();
}
for (Thread thread : threads) {
thread.join();
}
for (int num = 1; num <= LOOP_COUNT; num++) {
// every number appear 20 times only!
int times = 0;
for (int j = 0; j < THREAD_COUNT; j++) {
for (int k = 0; k < LOOP_COUNT; k++) {
if (results[j][k] == num)
times++;
}
}
assertEquals(20, times);
}
}

�q�个��试跑了几次都是正确的�?/p>

�׃��没有可以�q�行�Ҏ��其他的实现方式（例如排他锁）所以没有做性能��试�?/p>

写在最后�?虽然MongoDB支持�c�M��于存储过�E�的Stored Javascript�Q�但是其实不��使用�q�个来解军_��杂问题。主要原因是没法调试�Q�维护�v来太不方�ѝ��而且�?.4之前MongoDB�Ҏ��务端 Javascript支持�q�不是很好，一个mongod�q�程同时只能执行一�D�Javascript。如果能在应用层解决掉还是在应用层里实现逻辑比较好�?/p>

黑灵 2013-04-26 22:57 发表评论

输出debug信息到postfix的log

黑灵 — Fri, 26 Apr 2013 11:25:00 GMT

可以通过以下讄��把postfix的debug�U�别的log打印出来.

/etc/postfix/main.cf

debug_peer_list = example.com
debug_peer_level = 2

/etc/postfix/master.cf

smtp inet n - n - - smtpd -v

黑灵 2013-04-26 19:25 发表评论

Java里的CompareAndSet(CAS)

黑灵 — Wed, 24 Apr 2013 09:20:00 GMT

Atomic 从JDK5开�? java.util.concurrent包里提供了很多面向�ƈ发编�E�的�c? 使用�q�些�c�d��多核CPU的机器上会有比较好的性能.
主要原因是这些类里面大多使用(��p�|-重试方式�?乐观锁而不是synchronized方式的悲观锁.

今天有时间跟�t�了一下AtomicInteger的incrementAndGet的实�?
本�h对�ƈ发编�E�也不是特别了解, 在这里就是做个笔�? 方便以后再深入研�I?

1. incrementAndGet的实�?br />

    public final int incrementAndGet() {
        for (;;) {
            int current = get();
            int next = current + 1;
            if (compareAndSet(current, next))
                return next;
        }
    }

首先可以看到他是通过一个无限��@�?spin)直到increment成功为止.
循环的内�Ҏ��
1.取得当前�?br />2.计算+1后的�?br />3.如果当前��D��有效(没有�?的话讄��那个+1后的�?br />4.如果讄��没成�?当前值已�l�无效了卌��别的�U�程改过�?, 再从1开�?

2. compareAndSet的实�?br />

    public final boolean compareAndSet(int expect, int update) {
        return unsafe.compareAndSwapInt(this, valueOffset, expect, update);
    }

直接调用的是UnSafe�q�个�cȝ��compareAndSwapInt�Ҏ��
全称�?/span>sun.misc.Unsafe. �q�个�c�L��Oracle(Sun)提供的实�? 可以在别的公司的JDK里就不是�q�个�c�M��

3. compareAndSwapInt的实�?br />

    /**
     * Atomically update Java variable to x if it is currently
     * holding expected.
     * @return true if successful
     */
    public final native boolean compareAndSwapInt(Object o, long offset,
                                                  int expected,
                                                  int x);

可以看到, 不是用Java实现�? 而是通过JNI调用操作�pȝ��的原生程�?

4. compareAndSwapInt的native实现
如果你下载了OpenJDK的源代码的话在hotspot\src\share\vm\prims\目录下可以找到unsafe.cpp

UNSAFE_ENTRY(jboolean, Unsafe_CompareAndSwapInt(JNIEnv *env, jobject unsafe, jobject obj, jlong offset, jint e, jint x))
  UnsafeWrapper("Unsafe_CompareAndSwapInt");
  oop p = JNIHandles::resolve(obj);
  jint* addr = (jint *) index_oop_from_field_offset_long(p, offset);
  return (jint)(Atomic::cmpxchg(x, addr, e)) == e;
UNSAFE_END

可以看到实际上调�?/span>Atomic�cȝ��cmpxchg�Ҏ��.

5. Atomic�?/span>cmpxchg
�q�个�cȝ��实现是跟操作�pȝ��有关, 跟CPU架构也有�? 如果是windows下x86的架�?br />实现在hotspot\src\os_cpu\windows_x86\vm\目录的atomic_windows_x86.inline.hpp文�g�?br />

inline jint     Atomic::cmpxchg    (jint     exchange_value, volatile jint*     dest, jint     compare_value) {
  // alternative for InterlockedCompareExchange
  int mp = os::is_MP();
  __asm {
    mov edx, dest
    mov ecx, exchange_value
    mov eax, compare_value
    LOCK_IF_MP(mp)
    cmpxchg dword ptr [edx], ecx
  }
}

在这里可以看到是用嵌入的汇编实现�? 关键CPU指��o�?/span> cmpxchg
到这里没法再往下找代码�? 也就是说CAS的原子性实际上是CPU实现�? 其实在这一点上�q�是有排他锁�? 只是比�v用synchronized, �q�里的排他时间要短的�? 所以在多线�E�情况下性能会比较好.

代码里有�?/span>alternative for InterlockedCompareExchange
�q�个InterlockedCompareExchange是WINAPI里的一个函�? 做的事情和上面这�D�|��~�是一��L��
http://msdn.microsoft.com/en-us/library/windows/desktop/ms683560%28v=vs.85%29.aspx

6. 最后再贴一下x86的cmpxchg指定

Opcode CMPXCHG

CPU: I486+
Type of Instruction: User

Instruction: CMPXCHG dest, src

Description: Compares the accumulator with dest. If equal the "dest"
is loaded with "src", otherwise the accumulator is loaded
with "dest".

Flags Affected: AF, CF, OF, PF, SF, ZF

CPU mode: RM,PM,VM,SMM
+++++++++++++++++++++++
Clocks:
CMPXCHG reg, reg 6
CMPXCHG mem, reg 7 (10 if compartion fails)

黑灵 2013-04-24 17:20 发表评论

黑灵 — Tue, 23 Apr 2013 14:02:00 GMT

�Ҏ�?br />http://mina.apache.org/mina-project/features.html

MINA是一个简单的却有功能丰富的网�l�应用程序框�Ӟ�� 它提供如下特性：

为各�U�传输类型提供一套统一的API

通过Java NIO实现 TCP/IP & UPD/IP通信

通过RXTX实现串口通信�Q�RS232�Q?/li>

VM内部��道通信

你可以实现自��q��通信方式

通过Filter接口实现扩展点；�c�M��与Servlet的Filter

低��和高�U�的API

低��Q��用ByteBuffer

高��Q�用戯��定义的消息对象和�~�码

可以自由定制的线�E�模�?/li>

单线�E?/li>

一个线�E�池

多个�U�程池（例如 SEDA�Q?/li>

利用Java5的SSLEngine实现的开��即用的SSL,TLS, StartTLS功能

�q�蝲保护 �?带宽限制

通过Mock对象可以�q�行单体��试

通过JMX��理服务�?/li>

通过StreamIoHandler支持��Z��的I/O

可以整合�q�PicoContainer和Spring�{�常用容�?/li>

很容易从Netty�q�移�q�来�?/li>

黑灵 2013-04-23 22:02 发表评论

Apache Mina 中文文��译 - 概述

黑灵 — Mon, 22 Apr 2013 15:13:00 GMT

概述
原文链接�Q�http://mina.apache.org/mina-project/index.html

Apache MINA 是一个网�l�应用框�Ӟ�� 它可以帮助你��单容易的开发高性能�Q�高可扩展性的�|�络应用�E�序。Apache MINA底层利用Java NIO实现�Q�在TCP/IP和UPD/IP�{�传输层上提供一个抽象的��Z��事�g驱动的异步API�?br />
Apache MINA一般被�U�Cؓ�Q?br />

一个NIO框架或库

客户端，服务器框架或�?/li>

一个网�l�Socket�?/li>

��管如此�Q�Apache MINA要提供的比上面说的多得多�?你可以看一下它的功能特性列表，利用�q�些�Ҏ��你可以快速开发网�l�应用程序，你还可以看一下�h们是怎么说MINA的�?请下载MINA的包�Q�尝试一下快速开始指南， ��览一下FAQ或者加入我们的�C�֌��?br />
Notice: Licensed to the Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. The ASF licenses this file to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at . http://www.apache.org/licenses/LICENSE-2.0 . Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

黑灵 2013-04-22 23:13 发表评论

Properties.storeToXML�Ҏ��抛出�I�指针哦!

黑灵 — Fri, 19 Apr 2013 08:42:00 GMT

今天��目里遇到的, 在这里做个记�?

�c�M��下面�q�段代码:

    @Test(expected = IOException.class)
    public void testPropertiesStoreToXml() throws IOException {
        Properties props = new Properties();
        props.put("key1", true);
        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        props.storeToXML(baos,null);
        String xml = new String(baos.toByteArray());
        Assert.fail("should not go to here");
    }

在生成XML的时候会抛出IOException. ��D��q�个IOException的是做XMLTransform的时候出��C��NullPointerException

感觉很奇�? 调试�q�Properties的代码看了一�?

    public String getProperty(String key) {
    Object oval = super.get(key);
    String sval = (oval instanceof String) ? (String)oval : null;
    return ((sval == null) && (defaults != null)) ? defaults.getProperty(key) : sval;
    }

原来Properties�q�货, 不是String的属性一码色的返回NULL�?

�l�果在XMLTransform的时�? 直接对这个NULL�q�行�Ҏ��调用.

后来看了一下Properties文��, Properties�l�承至Hashtable, 所以有put和putAll之类的方�? 但是不徏议��?
因�ؓ�q�些�Ҏ��不限定String�c�d��. 推荐使用setProperty�Ҏ��, �q�个�Ҏ��的��g��定是String.

Because Properties inherits from Hashtable, the put and putAll methods can be applied to a Properties object. Their use is strongly discouraged as they allow the caller to insert entries whose keys or values are not Strings. The setProperty method should be used instead. If the store or save method is called on a "compromised" Properties object that contains a non-String key or value, the call will fail. Similarly, the call to the propertyNames or list method will fail if it is called on a "compromised" Properties object that contains a non-String key.

OK,我承认是我不好好看文��就用了. 但是我脚的如果你把非String的��D��用一下toString再��用不是更好吗?

黑灵 2013-04-19 16:42 发表评论

黑灵 — Tue, 16 Apr 2013 16:42:00 GMT

通过Spring-mvc的@InitBinder注释的方法可以对WebDataBinder做一些初始化操作�?br />比如讄��Validator�?
我一直在惌��不能为每个Request或者每个Action�Ҏ��单独讄��Validator�?br />也就是说Controller里有多个被@InitBinder标注的方法�?在不同的Action时被分别调用�?br />
我注意到了@InitBinder的value参数�Q?br />
api docs里是�q�样描述的：
The names of command/form attributes and/or request parameters that this init-binder method is supposed to apply to.

Default is to apply to all command/form attributes and all request parameters processed by the annotated handler class. Specifying model attribute names or request parameter names here restricts the init-binder method to those specific attributes/parameters, with different init-binder methods typically applying to different groups of attributes or parameters.

是乎是可以针对不同的Form对象或命令调用不同的InitBinder�Ҏ��?/p>

于是我写了下面的Controller试了一�?/p>

@Controller
public class HomeController {

    private static final Logger logger = LoggerFactory.getLogger(HomeController.class);

    @InitBinder("action1")
    public void initBinder1(WebDataBinder binder){
        logger.info("initBinder1");
    }

    @InitBinder("action2")
    public void initBinder2(WebDataBinder binder){
        logger.info("initBinder2");
    }

    /**
     * Simply selects the home view to render by returning its name.
     */
    @RequestMapping(value = "/", method = RequestMethod.GET)
    public String home(Model model) {

        Date date = new Date();
        DateFormat dateFormat = DateFormat.getDateTimeInstance(DateFormat.LONG, DateFormat.LONG);

        String formattedDate = dateFormat.format(date);

        model.addAttribute("serverTime", formattedDate );

        return "home";
    }

    /**
     * Simply selects the home view to render by returning its name.
     */
    @RequestMapping(value = "/doit", method = RequestMethod.POST, params="action1")
    public String doit1(@RequestParam("value1") int value1,
            @RequestParam("action1") String action, Model model) {
        logger.info("value1={}",value1);

        Date date = new Date();
        DateFormat dateFormat = DateFormat.getDateTimeInstance(DateFormat.LONG, DateFormat.LONG);

        String formattedDate = dateFormat.format(date);

        model.addAttribute("serverTime", formattedDate );

        return "home";
    }

    /**
     * Simply selects the home view to render by returning its name.
     */
    @RequestMapping(value = "/doit", method = RequestMethod.POST, params="action2")
    public String doit2(@RequestParam("value1") int value1,
            @RequestParam("action2") String action, Model model) {
        logger.info("value1={}",value1);

        Date date = new Date();
        DateFormat dateFormat = DateFormat.getDateTimeInstance(DateFormat.LONG, DateFormat.LONG);

        String formattedDate = dateFormat.format(date);

        model.addAttribute("serverTime", formattedDate );

        return "home";
    }
}

画面上的Form是这��L��

我的意愿是如果画面上�Q�点击action1按钮择调用initBinder1�Ҏ��?如果点击action2按钮则调用initBinder2�Ҏ��?/p>

实际上也��实是这��L��?

当点击action1�Ӟ��logger.info("initBinder1"); 会执�?/span>

当点击action2是，logger.info("initBinder2"); 会执�?/span>

是乎是可以实现“每个Action�Ҏ��单独讄��Validator”这个目的�?/p>

但是其实�q�不是这��L��?/p>

我调式进��M��InitBinder相关的源代码InitBinderDataBinderFactory�Q?�l�果发现它只是在对action�q�个参数�l�定的时候调用了上面�q�个�Ҏ��Q?对value1�l�定的时候那个方法都没有调用。而我们常常要解决的是对同一个参数对于不同的action应用不同的Validator�?

所以目前还是没有好的方法能直接解决�q�个问题�Q?/p>

也许我们可以自己实现一个DataBinderFactory来解册��个问题�?/p>

黑灵 2013-04-17 00:42 发表评论

KMP��法里的next函数是怎么得到的？

黑灵 — Sun, 14 Apr 2013 15:24:00 GMT

今天看KMP��法�Q?一头雾��_��虽然��法的过�E�是明白了，但是怎么也想不出来怎么证明其中的next函数是怎么得到的�?br />也就是这�?p�?p�?p⑶�?.p(k-1�Q��?= ' p(j-k+1�Q�p(j-k+2�Q�……p(j-1�Q�’�?��Z��么找到这个k以后用k的元素比较字�W�串中i��p��了�?br />
现在扑ֈ�一个最接近明白的就是百度百�U�上�?br />
假设
��M��Q�s: ‘s�?s�?s�?……s(n�Q��?;
模式�?�Q�p: ‘p�?p�?p⑶�?.p(m�Q��?br />把课本上的这一�D늜�完后�Q��l?br />现在我们假设 ��M��W�i个字�W�与模式串的�W�j(j<=m�Q�个字符‘失配’后�Q�主串第i个字�W�与模式串的�W�k(k此时�Q�s(i�Q�≠p(j�Q�，�?br />��M��Q�s⑴…�?s(i-j+1�Q�…�?s(i-1�Q?s(i) ………�?
|| �Q�相配） || ≠（失配�Q?br />匚w��Ԍ��p�?...........p(j-1�Q?p(j)
由此�Q�我们得到关�p�d��Q?br />‘p�?p�?p⑶�?.p(j-1�Q��?= �?s(i-j+1�Q�……s(i-1�Q��?br />�׃��s(i�Q�≠p(j�Q�，接下来s(i�Q�将与p(k�Q��l�比较，则模式串中的前（k-1�Q�个字符的子串必��L��下列关�p�d��Q��ƈ且不可能存在 k�?gt;k 满��下列关系式：�Q�k‘p�?p�?p⑶�?.p(k-1�Q��?= �?s(i-k+1�Q�s(i-k+2�Q�……s(i-1�Q��?br />卻I��
��M��Q�s⑴……s(i-k +1�Q?s(i-k +2�Q?……s(i-1�Q?s(i) ………�?
|| �Q�相配） || ||�Q�有待比较）
匚w��Ԍ��p�?p�?…�?.... p(k-1�Q?p(k)
现在我们把前面�ȝ��的关�pȝ��合一�?br />有：
s⑴…s(i-j +1�Q��?s(i-k +1�Q?s(i-k +2�Q?…�?s(i-1�Q?s(i) …�?br />|| �Q�相配） || || || ≠（失配�Q?br />p�?……p(j-k+1�Q?p(j-k+2�Q?�?..... p(j-1�Q?p(j)
|| �Q�相配） || ||�Q�有待比较）
p�?p�?…�?..... p(k-1�Q?p(k)
�׃��Q�我们得到关�p�：
'p�?p�?p⑶�?.p(k-1�Q��?= ' p(j-k+1�Q�p(j-k+2�Q�……p(j-1�Q��?br />
不知道是从哪个课本上抄来的�?其实�q�是不太明白最后一步�?br />

黑灵 2013-04-14 23:24 发表评论

��单的监视某个端口的连接数的Linux命��o

黑灵 — Tue, 30 Oct 2012 01:38:00 GMT

首先创徏一个脚本文�? 我们叫他count_conn�?br />

#!/bin/sh
netstat -anp | grep :$1 | awk '{print $5}' | awk -F: '{print $1}' | sort | uniq -c

然后执行命��o:

watch -n 1 count_conn 8080

最后的参数��是你要监视的端�?

黑灵 2012-10-30 09:38 发表评论