maven debug 断点定位 source jar

2014-08-04

eclipse 有两个debug插件：

一、m2e.sourcelookup 插件：

https://github.com/bjmi/m2e.sourcelookup

阅读全文

Java内存压缩解压带密码zip

2014-06-05

压缩类ZipEncryptOutputStream.java

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
import java.io.IOException;
import java.io.OutputStream;
import java.security.SecureRandom;
import java.util.ArrayList;
import java.util.Arrays;
import static com.zk.zip.ZipExpand.*;

/**
 * Output stream that can be used to password-protect zip files.
 *
 * <h3>Example usage:</h3>
 * <p>Creating a password-protected zip file:</p>
 * <pre>
 *  ZipEncryptOutputStream zeos = new ZipEncryptOutputStream(new FileOutputStream(fileName), password);
 *  ZipOutputStream zos = new ZipOuputStream(zdis);
 *  ... create zip file using the standard JDK ZipOutputStream in zos variable ...
 * </pre>
 * <p>Converting a plain zip file to a password-protected zip file:</p>
 * <pre>
 *  FileInputStream src = new FileInputStream(srcFile);
 *  ZipEncryptOutputStream dest = new ZipEncryptOutputStream(new FileOutputStream(destFile), password);
 *
 *  // should wrap with try-catch-finally, do the close in finally
 *  int b;
 *  while ((b = src.read()) > -1) {
 *      dest.write(b);
 *  }
 *
 *  src.close();
 *  dest.close();
 * </pre>
 */
public class ZipEncryptOutputStream extends OutputStream {
    private final OutputStream delegate;
    private final int keys[] = new int[3];
    private final int pwdKeys[] = new int[3];

    private int copyBytes;
    private int skipBytes;
    private State state = State.NEW_SECTION;
    private State futureState;
    private Section section;
    private byte[] decryptHeader;
    private final ArrayList<int[][]> crcAndSize = new ArrayList<int[][]>();
    private final ArrayList<Integer> localHeaderOffset = new ArrayList<Integer>();
    private ArrayList<int[]> fileData;
    private int[][] condition;
    private int fileIndex;
    private int[] buffer;
    private int bufOffset;
    private int fileSize;
    private int bytesWritten;
    private int centralRepoOffset;

    private static final int ROW_SIZE = 65536;

    /**
     * Convenience constructor taking password as a string.
     *
     * @param delegate Output stream to write the password-protected zip to.
     * @param password Password to use for protecting the zip.
     */
    public ZipEncryptOutputStream(OutputStream delegate, String password) {
        this(delegate, password.toCharArray());
    }

    /**
     * Safer version of the constructor. Takes password as a char array that can
     * be nulled right after calling this constructor instead of a string that may
     * stay visible on the heap for the duration of application run time.
     *
     * @param delegate Output stream to write the password-protected zip to.
     * @param password Password to use for protecting the zip.
     */
    public ZipEncryptOutputStream(OutputStream delegate, char[] password) {
        this.delegate = delegate;
        pwdKeys[0] = 305419896;
        pwdKeys[1] = 591751049;
        pwdKeys[2] = 878082192;
        for (int i = 0; i < password.length; i++) {
            ZipExpand.updateKeys((byte) (password[i] & 0xff), pwdKeys);
        }
    }

    private static enum State {NEW_SECTION, SECTION_HEADER, FLAGS, REPO_OFFSET, CRC, FILE_HEADER_OFFSET,
        COMPRESSED_SIZE_READ, HEADER, DATA, FILE_BUFFERED, BUFFER, BUFFER_COPY, BUFFER_UNTIL, TAIL}
    private static enum Section {LFH, CFH, ECD}

    @Override
    public void write(int b) throws IOException {
        if (skipBytes > 0) {
            skipBytes--;
            return;
        }
        if (copyBytes == 0) {
            switch (state) {
                case NEW_SECTION:
                    if (b != 0x50) {
                        throw new IllegalStateException("Unexpected value read at offset " + bytesWritten + ": " + b + " (expected: " + 0x50 + ")");
                    }
                    buffer(new int[4], State.SECTION_HEADER, 0x50);
                    return;
                case SECTION_HEADER:
                    identifySectionHeader();
                    break;
                case FLAGS:
                    copyBytes = 7;
                    state = State.CRC;
                    if (section == Section.LFH) {
                        if ((b & 1) == 1) {
                            throw new IllegalStateException("ZIP already password protected.");
                        }
                        if ((b & 64) == 64) {
                            throw new IllegalStateException("Strong encryption used.");
                        }
                        if ((b & 8) == 8) {
                            bufferUntil(State.FILE_BUFFERED, CFH_SIGNATURE, LFH_SIGNATURE);
                        }
                    }
                    b = b & 0xf7 | 1;
                    break;
                case CRC:
                    if (section == Section.CFH) {
                        int[][] cns = crcAndSize.get(fileIndex);
                        for (int j = 0; j < 3; j++) {
                            for (int i = 0; i < 4; i++) {
                                writeToDelegate(cns[j][i]);
                            }
                        }
                        skipBytes = 11;
                        copyBytes = 14;
                        state = State.FILE_HEADER_OFFSET;
                    } else {
                        int[] cns = new int[16];
                        buffer(cns, State.COMPRESSED_SIZE_READ, b);
                    }
                    return;
                case FILE_HEADER_OFFSET:
                    writeAsBytes(localHeaderOffset.get(fileIndex));
                    fileIndex++;
                    skipBytes = 3;
                    copyBytesUntil(State.SECTION_HEADER, CFH_SIGNATURE, ECD_SIGNATURE);
                    return;
                case COMPRESSED_SIZE_READ:
                    int[][] cns = new int[][] {
                        {buffer[0], buffer[1], buffer[2], buffer[3]},
                        {buffer[4], buffer[5], buffer[6], buffer[7]},
                        {buffer[8], buffer[9], buffer[10], buffer[11]}
                    };
                    adjustSize(cns[1]);
                    crcAndSize.add(cns);
                    for (int j = 0; j < 3; j++) {
                        for (int i = 0; i < 4; i++) {
                            writeToDelegate(cns[j][i]);
                        }
                    }
                    copyBytes = buffer[12] + buffer[14] + (buffer[13] + buffer[15]) * 256 - 1;
                    state = State.HEADER;
                    if (copyBytes < 0) {
                        throw new IllegalStateException("No file name stored in the zip file.");
                    }
                    break;
                case HEADER:
                    writeDecryptHeader();
                    fileSize = decode(crcAndSize.get(crcAndSize.size() - 1)[1]);
                    state = State.DATA;
                    // intentionally no break
                case DATA:
                    b = encrypt(b);
                    fileSize--;
                    if (fileSize == 0) {
                        state = State.NEW_SECTION;
                    }
                    break;
                case BUFFER:
                    buffer[bufOffset] = b;
                    bufOffset++;
                    if (bufOffset == buffer.length) {
                        state = futureState;
                    }
                    return;
                case BUFFER_COPY:
                    buffer[bufOffset] = b;
                    if (checkCondition()) {
                        bufOffset = 0;
                        state = futureState;
                    }
                    break;
                case BUFFER_UNTIL:
                    int col = fileSize % ROW_SIZE;
                    if (col == 0) {
                        fileData.add(new int[ROW_SIZE]);
                    }
                    int[] row = fileData.get(fileData.size() - 1);
                    row[col] = b;
                    buffer[bufOffset] = b;
                    fileSize++;
                    if (checkCondition()) {
                        fileSize -= buffer.length;
                        state = futureState;
                    }
                    return;
                case FILE_BUFFERED:
                    row = fileData.get(0);
                    int r = 0;
                    int pointer = 16 + row[12] + row[14] + (row[13] + row[15]) * 256;
                    cns = new int[3][4];
                    readFromFileBuffer(fileSize - 12, cns[0]);
                    readFromFileBuffer(fileSize - 8, cns[1]);
                    readFromFileBuffer(fileSize - 4, cns[2]);
                    fileSize = decode(cns[1]);
                    adjustSize(cns[1]);
                    crcAndSize.add(cns);
                    for (int i = 0; i < 4; i++) {
                        row[i] = cns[0][i];
                        row[i + 4] = cns[1][i];
                        row[i + 8] = cns[2][i];
                    }
                    for (int i = 0; i < pointer; i++) {
                        writeToDelegate(row[i]);
                    }
                    writeDecryptHeader();
                    for (int i = 0; i < fileSize; i++) {
                        writeToDelegate(encrypt(row[pointer]));
                        pointer++;
                        if (pointer == ROW_SIZE) {
                            pointer = 0;
                            r++;
                            row = fileData.get(r);
                        }
                    }
                    fileData = null;
                    identifySectionHeader();
                    break;
                case REPO_OFFSET:
                    writeAsBytes(centralRepoOffset);
                    skipBytes = 3;
                    state = State.TAIL;
                    return;
                case TAIL:
                    break;
            }
        } else {
            copyBytes--;
        }
        writeToDelegate(b);
    }

    private void writeToDelegate(int b) throws IOException {
        delegate.write(b);
        bytesWritten++;
    }

    private static void adjustSize(int[] values) {
        int inc = DECRYPT_HEADER_SIZE;
        for (int i = 0; i < 4; i++) {
            values[i] = values[i] + inc;
            inc = values[i] >> 8;
            values[i] &= 0xff;
        }
    }

    private static int decode(int[] value) {
        return value[0] + (value[1] << 8) + (value[2] << 16) + (value[3] << 24);
    }

    private void writeAsBytes(int value) throws IOException {
        for (int i = 0; i < 4; i++) {
            writeToDelegate(value & 0xff);
            value >>= 8;
        }
    }

    private void identifySectionHeader() throws IllegalStateException, IOException {
        if (Arrays.equals(buffer, LFH_SIGNATURE)) {
            section = Section.LFH;
            copyBytes = 1;
            state = State.FLAGS;
            localHeaderOffset.add(bytesWritten);
        } else if (Arrays.equals(buffer, CFH_SIGNATURE)) {
            section = Section.CFH;
            copyBytes = 3;
            state = State.FLAGS;
            if (centralRepoOffset == 0) {
                centralRepoOffset = bytesWritten;
            }
        } else if (Arrays.equals(buffer, ECD_SIGNATURE)) {
            section = Section.ECD;
            copyBytes = 11;
            state = State.REPO_OFFSET;
        } else {
            throw new IllegalStateException("Unknown header: " + Arrays.asList(buffer).toString());
        }
        flushBuffer();
    }

    private void readFromFileBuffer(int offset, int[] target) {
        int r = offset / ROW_SIZE;
        int c = offset % ROW_SIZE;
        int[] row = fileData.get(r);
        for (int i = 0; i < target.length; i++) {
            target[i] = row[c];
            c++;
            if (c == ROW_SIZE) {
                c = 0;
                r++;
                row = fileData.get(r);
            }
        }
    }

    @Override
    public void close() throws IOException {
        super.close();
        delegate.close();
    }

    private void initKeys() {
        System.arraycopy(pwdKeys, 0, keys, 0, keys.length);
    }

    private void updateKeys(byte charAt) {
        ZipExpand.updateKeys(charAt, keys);
    }

    private byte encryptByte() {
        int temp = keys[2] | 2;
        return (byte) ((temp * (temp ^ 1)) >>> 8);
    }

    private int encrypt(int b) {
        int newB = (b ^ encryptByte()) & 0xff;
        updateKeys((byte) b);
        return newB;
    }

    private void writeDecryptHeader() throws IOException {
        initKeys();
        int[] crc = crcAndSize.get(crcAndSize.size() - 1)[0];
        SecureRandom random = new SecureRandom();
        decryptHeader = new byte[DECRYPT_HEADER_SIZE];
        random.nextBytes(decryptHeader);
        decryptHeader[DECRYPT_HEADER_SIZE - 2] = (byte) crc[2];
        decryptHeader[DECRYPT_HEADER_SIZE - 1] = (byte) crc[3];
        for (int i = 0; i < DECRYPT_HEADER_SIZE; i++) {
            writeToDelegate(encrypt(decryptHeader[i]));
        }
    }

    private void buffer(int[] values, State state, int... knownValues) {
        System.arraycopy(knownValues, 0, values, 0, knownValues.length);
        buffer = values;
        bufOffset = knownValues.length;
        this.state = State.BUFFER;
        futureState = state;
    }

    private void flushBuffer() throws IOException {
        for (int i = 0; i < bufOffset; i++) {
            writeToDelegate(buffer[i]);
        }
    }

    private void copyBytesUntil(State state, int[]... condition) {
        futureState = state;
        this.condition = condition;
        bufOffset = 0;
        buffer = new int[condition[0].length];
        this.state = State.BUFFER_COPY;
    }

    private void bufferUntil(State state, int[]... condition) {
        copyBytesUntil(state, condition);
        fileData = new ArrayList<int[]>();
        fileSize = 0;
        this.state = State.BUFFER_UNTIL;
    }

    private boolean checkCondition() {
        boolean equals = true;
        for (int i = 0; i < condition.length; i++) {
            equals = true;
            for (int j = 0; j <= bufOffset; j++) {
                if (condition[i][j] != buffer[j]) {
                    equals = false;
                    break;
                }
            }
            if (equals) {
                bufOffset++;
                break;
            }
        }
        if (!equals) {
            bufOffset = 0;
        }
        return equals && (buffer.length == bufOffset);
    }
}

阅读全文

Centos安装gcc gcc-c++

2013-05-13
1
yum -y install gcc gcc-c++

阅读全文

Centos配置nfs

2013-05-13

1、配置：

服务端：

1
2
3
#vi /etc/exports 
增加例如：
/opt/storage　192.168.0.*(rw)　　 (IP)就是客户端允许访问ip地址(rw) 权限

阅读全文

Centos安装JDK

2013-05-11

一.jdk1.6安装

1. 从网站上下载jdk1.6包(jdk-6u10-linux-i586-rpm.bin )

上传到linux系统的/usr/local/目录下

阅读全文

Centos scp 拷贝文件

2013-05-10

复制文件或目录命令

复制文件：

（1）将本地文件拷贝到远程

scp 文件名 用户名@计算机IP或者计算机名称:远程路径

阅读全文

tomcat memcached-session-manager使用spring security序列化问题

2013-05-09

tomcat异常：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
警告: Could not load session with id 2CD7BCC8414A6DF09EF97E07FBCDABD3-n2 from memcached.
com.esotericsoftware.kryo.SerializationException: Unable to deserialize object of type: java.util.concurrent.ConcurrentHashMap
	at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:593)
	at com.esotericsoftware.kryo.ObjectBuffer.readObject(ObjectBuffer.java:213)
	at de.javakaffee.web.msm.serializer.kryo.KryoTranscoder.deserializeAttributes(KryoTranscoder.java:261)
	at de.javakaffee.web.msm.TranscoderService.deserializeAttributes(TranscoderService.java:169)
	at de.javakaffee.web.msm.TranscoderService.deserialize(TranscoderService.java:126)
	at de.javakaffee.web.msm.MemcachedSessionService.loadFromMemcached(MemcachedSessionService.java:1119)
	at de.javakaffee.web.msm.MemcachedSessionService.findSession(MemcachedSessionService.java:597)
	at de.javakaffee.web.msm.MemcachedBackupSessionManager.findSession(MemcachedBackupSessionManager.java:216)
	at org.apache.catalina.connector.Request.doGetSession(Request.java:2419)
	at org.apache.catalina.connector.Request.getSession(Request.java:2157)
	at org.apache.catalina.connector.RequestFacade.getSession(RequestFacade.java:833)
	at org.apache.catalina.connector.RequestFacade.getSession(RequestFacade.java:844)
	at org.apache.jasper.runtime.PageContextImpl._initialize(PageContextImpl.java:146)
	at org.apache.jasper.runtime.PageContextImpl.initialize(PageContextImpl.java:124)
	at org.apache.jasper.runtime.JspFactoryImpl.internalGetPageContext(JspFactoryImpl.java:107)
	at org.apache.jasper.runtime.JspFactoryImpl.getPageContext(JspFactoryImpl.java:63)
	at org.apache.jsp.login_jsp._jspService(login_jsp.java:61)
	at org.apache.jasper.runtime.HttpJspBase.service(HttpJspBase.java:70)
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:717)
	at org.apache.jasper.servlet.JspServletWrapper.service(JspServletWrapper.java:388)
	at org.apache.jasper.servlet.JspServlet.serviceJspFile(JspServlet.java:313)
	at org.apache.jasper.servlet.JspServlet.service(JspServlet.java:260)
	at javax.servlet.http.HttpServlet.service(HttpServlet.java:717)
	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:290)
	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
	at org.springframework.web.filter.CharacterEncodingFilter.doFilterInternal(CharacterEncodingFilter.java:88)
	at org.springframework.web.filter.OncePerRequestFilter.doFilter(OncePerRequestFilter.java:76)
	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:235)
	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
	at com.autoradio.mz.util.filter.AddHttpHeaderFilter.doFilter(AddHttpHeaderFilter.java:29)
	at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:235)
	at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:206)
	at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:233)
	at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:191)
	at de.javakaffee.web.msm.RequestTrackingContextValve.invoke(RequestTrackingContextValve.java:99)
	at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:127)
	at de.javakaffee.web.msm.RequestTrackingHostValve.invoke(RequestTrackingHostValve.java:165)
	at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:102)
	at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:109)
	at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:293)
	at org.apache.coyote.http11.Http11Processor.process(Http11Processor.java:859)
	at org.apache.coyote.http11.Http11Protocol$Http11ConnectionHandler.process(Http11Protocol.java:602)
	at org.apache.tomcat.util.net.JIoEndpoint$Worker.run(JIoEndpoint.java:489)
	at java.lang.Thread.run(Thread.java:662)
Caused by: com.esotericsoftware.kryo.SerializationException: Unable to deserialize object of type: org.springframework.security.core.context.SecurityContextImpl
	at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:571)
	at com.esotericsoftware.kryo.serialize.MapSerializer.readObjectData(MapSerializer.java:129)
	at com.esotericsoftware.kryo.Serializer.readObject(Serializer.java:61)
	at com.esotericsoftware.kryo.Kryo.readObject(Kryo.java:589)
	... 43 more
Caused by: com.esotericsoftware.kryo.SerializationException: Serialization trace:
authorities (com.autoradio.mz.security.springsecurity.LoginUser)
principal (org.springframework.security.authentication.UsernamePasswordAuthenticationToken)
authentication (org.springframework.security.core.context.SecurityContextImpl)
	at com.esotericsoftware.kryo.serialize.FieldSerializer.readObjectData(FieldSerializer.java:238)
	at com.esotericsoftware.kryo.serialize.ReferenceFieldSerializer.readObjectData(ReferenceFieldSerializer.java:81)
	at com.esotericsoftware.kryo.serialize.FieldSerializer.readObjectData(FieldSerializer.java:220)
	at com.esotericsoftware.kryo.serialize.ReferenceFieldSerializer.readObjectData(ReferenceFieldSerializer.java:81)
	at com.esotericsoftware.kryo.serialize.FieldSerializer.readObjectData(FieldSerializer.java:220)
	at com.esotericsoftware.kryo.serialize.ReferenceFieldSerializer.readObjectData(ReferenceFieldSerializer.java:81)
	at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:566)
	... 46 more
Caused by: java.lang.ClassCastException: org.springframework.security.core.authority.SimpleGrantedAuthority cannot be cast to java.lang.Comparable
	at java.util.TreeMap.put(TreeMap.java:542)
	at java.util.TreeSet.add(TreeSet.java:238)
	at com.esotericsoftware.kryo.serialize.CollectionSerializer.readObjectData(CollectionSerializer.java:113)
	at com.esotericsoftware.kryo.Kryo.readClassAndObject(Kryo.java:566)
	at de.javakaffee.kryoserializers.UnmodifiableCollectionsSerializer.readObjectData(UnmodifiableCollectionsSerializer.java:84)
	at com.esotericsoftware.kryo.serialize.FieldSerializer.readObjectData(FieldSerializer.java:220)
	... 52 more

阅读全文

Centos 安装 setup

2013-05-08

安装setuptool

1
yum install setuptool

阅读全文

Centos 开机自启动

2013-05-08

添加启动执行：

1
vi /etc/rc.d/rc.local

阅读全文

Clojure 例子（编译后java调用与.clj形式调用）

2013-05-08

在网上找了好久没找到 clojure 入门例子，自己写一个分享一下吧。

eclipse插件：

URL http://ccw.cgrand.net/updatesite

阅读全文