Jakarta Commons 笔记，Part II

public class Blocking implements Runnable {
//    Queue queue = new LinkedBlockingDeque();
    Buffer queue = BlockingBuffer.decorate(new BoundedFifoBuffer());
 
    @SuppressWarnings({ "static-access", "unchecked" })
    public static void main(String[] args) throws InterruptedException {
        Blocking ths = new Blocking();
        Thread t = new Thread(ths);
        t.start();
        ths.queue.add("Hello");
        t.sleep(500);
        ths.queue.add("Black Lee");
    }
 
    public void run() {
        while (true) {
            try {
                String msg = (String) queue.remove();
                System.out.println(msg);
            } catch (Exception e) {
            }
        }
    }
}

中间注释掉的那行，也是可以使用的。

Map map = new HashMap();
int j = MapUtils.getIntValue(map, "a");
System.out.println(j);
int i = map.get("a");
System.out.println(i);

<users>
  <user id="1">
    <name>Black Lee</name>
  </user>
  <user id="2">
    <name>Master</name>
  </user>
</users>

public class User {
    private int id;
    private String name;
    public User() {}
    public User(int i, String s) {
        id = i; name = s;
    }
    public int getId() { return id; }
    public void setId(int id) { this.id = id; }
    public String getName() { return name; }
    public void setName(String name) { this.name = name; }
    public String toString() {
        return "User#" + id + ", Name:" + name;
    }
}

<digester -rules>
	<pattern value="users/user">
		<object -create-rule classname="xml.User"/>
		<set -next-rule methodname="add" paramtype="java.lang.Object"/>
		<set -properties-rule/>
		<bean -property-setter-rule pattern="name"/>
	</pattern>
</digester>

public static void main(String[] args) throws IOException, SAXException {
    List users = new ArrayList();
    DigesterDemo demo = new DigesterDemo();
    URL rule = demo.getClass().getResource("./rule.xml");
    Digester digester = DigesterLoader.createDigester(rule);
    digester.push(users);
    InputStream xml = demo.getClass().getResourceAsStream("./users.xml");
    Object root = digester.parse(xml);
    System.out.println(root);
    System.out.println(users.get(0));
}

<info primitiveType="attribute">
  <element name="user">
    <attribute name="id" property="id"/>
    <adddefaults />
  </element>
</info>

public static void main(String[] args) throws IOException, SAXException, IntrospectionException {
    User u1 = new User(1, "Black Lee");
    User u2 = new User(2, "Master");
    BeanWriter writer = new BeanWriter();
    writer.enablePrettyPrint();
 
    BindingConfiguration cfg = new BindingConfiguration();
    cfg.setMapIDs(false);
    writer.setBindingConfiguration(cfg);
 
    List users = new ArrayList();
    users.add(u1); users.add(u2);
    writer.write("users", users); // 指定root node的名称
    writer.flush();
    System.out.println(writer.toString());
}

  <users>
    <user id="1">
      <name>Black Lee</name>
    </user>
    <user id="2">
      <name>Master</name>
    </user>
  </users>
org.apache.commons.betwixt.io.BeanWriter@1430b5c

    public static void googleLogin(HttpClient client, NameValuePair[] nvps) throws IOException,
        HttpException {
    String uri = "https://www.google.com/accounts/ServiceLoginAuth";
    HttpMethod method = new PostMethod(uri);
    for (int i = 0; i < nvps.length; i++) {
        NameValuePair nvp = nvps[i];
        if (nvp.getName().equalsIgnoreCase("email")) nvp.setValue("xxxxxx@gmail.com");
        if (nvp.getName().equalsIgnoreCase("passwd")) nvp.setValue("xxxxxx");
    }
    method.setQueryString(nvps);
//  method.setFollowRedirects(true);// 应该是Post请求不能直接进行重定向
    int status = client.executeMethod(method);
    System.out.println(status);
    if (status == 302) {
        Header loc = method.getResponseHeader("location");
        System.out.println(loc);
        method.releaseConnection();
        method = new GetMethod(loc.getValue());
        method.setFollowRedirects(true);
        status = client.executeMethod(method);
        System.out.println("Goto: " + loc.getValue() + ", Get:" + status);
        System.out.println(method.getResponseBodyAsString());
    }
    if (status == 200) System.out.println(method.getResponseBodyAsString());
    }
 
    public static NameValuePair[] googleGetLoginPage(HttpClient client) throws IOException, HttpException, Exception {
    String uri = "https://www.google.com/accounts/ServiceLoginAuth";
    HttpMethod method = new GetMethod(uri);
    int status = client.executeMethod(method);
    System.out.println(status);
    HttpState state = client.getState();
    Cookie[] cookies = state.getCookies();
    for (Cookie cookie : cookies) {
        System.out.println("Set-Cookie: " + cookie.getName() + "\t" + cookie.getValue());
    }
    Header[] headers = method.getResponseHeaders();
    for (Header header : headers) {
        System.out.println("Header: " + header.getName() + "\t" + header.getValue());
    }
    HtmlCleaner cleaner = new HtmlCleaner();
    TagNode html = cleaner.clean(method.getResponseBodyAsStream());
    TagNode form = (TagNode) (html.evaluateXPath("//form[@id='gaia_loginform']")[0]);
    Object[] objs = form.evaluateXPath("//input");
    NameValuePair[] nvps = new NameValuePair[objs.length];
    for (int i = 0; i < objs.length; i++) {
        TagNode node = (TagNode) objs[i];
        nvps[i] = new NameValuePair(node.getAttributeByName("name"), node.getAttributeByName("value"));
    }
    return nvps;
}

[DEBUG] header - >> "POST /accounts/ServiceLoginAuth?dsh=7609767927588628425&GALX=ldpKR85s3P0&Email=xxxxxx%40gmail.com&Passwd=xxxxx&PersistentCookie=yes&rmShown=1&signIn=Sign+in&asts= HTTP/1.1[\r][\n]"
[DEBUG] header - >> "User-Agent: Jakarta Commons-HttpClient/3.1[\r][\n]"
[DEBUG] header - >> "Host: www.google.com[\r][\n]"
[DEBUG] header - >> "Cookie: $Version=0; GALX=ldpKR85s3P0; $Path=/accounts[\r][\n]"
[DEBUG] header - >> "Content-Length: 0[\r][\n]"
[DEBUG] header - >> "[\r][\n]"
[DEBUG] header - << "HTTP/1.1 302 Moved Temporarily[\r][\n]"
[DEBUG] header - << "HTTP/1.1 302 Moved Temporarily[\r][\n]"
[DEBUG] header - << "Content-Type: text/html; charset=UTF-8[\r][\n]"