プログラマメモ2: 失敗

ドメインクラスを継承して。。。失敗 - grails 2013/10/19

grailsです。ベースのドメインクラスはお手製のツールで生成して、そのクラスを継承してXxxExというドメインクラスをつくりその中で

static mapping = { table 'xxx' }

として、参照するテーブルはひとつにして、実装はXxxExのほうにして、コントローラーはXxxExのほうに用意する方式をとりたいなーと思いやっていたら、どうもうまく、できませんでした。

XxxExのほうからうまく親クラスのプロパティがみえてないようでして。。。。

面倒なのでこの方式は放棄の方向で。。。

2774 - Memory Limit Exceeded 2012/09/28

2774 -- Long Long Message

Memory Limit Exceeded
Memory超過でfailed

考え方はまちがってないと思うんだけど...

まちがってるな... とりあえずおいておこう。。。
通らないけど、動作としては問題ないかな....

package p2774_suffixarray;

import java.util.ArrayList;
import java.util.Collections;
import java.util.Scanner;

public class Main {

    static class A implements Comparable {
        String s;
        int marker;

        public A(String s, int marker) {
            this.s = s;
            this.marker = marker;
        }

        @Override
        public int compareTo(Object o) {
            return s.compareTo(((A) o).s);
        }

        public String toString() {
            return s + ":" + marker;
        }
    }

    public static void main(String[] args) {
        Scanner scanner = new Scanner(System.in);
        String line1 = scanner.nextLine();
        String line2 = scanner.nextLine();
        char[] cs1 = line1.toCharArray();
        char[] cs2 = line2.toCharArray();
        ArrayList<A> list = new ArrayList<Main.A>();

        for (int i = 0; i < cs1.length; i++) {
            char[] cs = new char[cs1.length - i];
            System.arraycopy(cs1, i, cs, 0, cs.length);
            list.add(new A(new String(cs), 0));
        }

        for (int i = 0; i < cs2.length; i++) {
            char[] cs = new char[cs2.length - i];
            System.arraycopy(cs2, i, cs, 0, cs.length);
            list.add(new A(new String(cs), 1));
        }

        int max = 0;
        Collections.sort(list);

        // for (A a : list) {
        // System.out.println(a);
        // }
        for (int i = 1; i < list.size(); i++) {
            A a1 = list.get(i - 1);
            A a2 = list.get(i);
            if (a1.marker == a2.marker)
                continue;
            int n = LCP(a1.s, a2.s);
            max = max < n ? n : max;

        }
        System.out.println(max);
    }

    static int LCP(String s1, String s2) {
        char[] cs1 = s1.toCharArray();
        char[] cs2 = s2.toCharArray();
        int len1 = s1.length();
        int len2 = s2.length();
        int min = len1 < len2 ? len1 : len2;
        int ret = 0;
        for (int i = 0; i < min; i++) {
            if (cs1[i] != cs2[i])
                break;
            ret++;
        }

        return ret;
    }
}

mapでってやってぜんぜんだめなやつ

import java.util.Map;
import java.util.Map.Entry;
import java.util.Scanner;
import java.util.TreeMap;

public class Main {

    public static void main(String[] args) {
        Scanner scanner = new Scanner(System.in);
        String line1 = scanner.nextLine();
        String line2 = scanner.nextLine();
        char[] cs1 = line1.toCharArray();
        char[] cs2 = line2.toCharArray();
        Map<String,Integer> set1 = new TreeMap<String, Integer>();
        for(int i=0;i<cs1.length;i++){
            char[] cs = new char[cs1.length - i];
            System.arraycopy(cs1, i, cs, 0, cs.length);
            set1.put(new String(cs), 0);
        }

        for(int i=0;i<cs2.length;i++){
            char[] cs = new char[cs2.length - i];
            System.arraycopy(cs2, i, cs, 0, cs.length);
            set1.put(new String(cs), 1);
        }

        int max = 0;
        Entry<String, Integer> tmp = null;
        for (Entry<String, Integer> set: set1.entrySet()) {
            if(tmp == null){
                tmp = set;
                continue;
            }
            if(tmp.getValue() == set.getValue()) continue;
            int n = LCP(tmp.getKey(),set.getKey());
            max = max < n ? n:max;
            tmp = set;
        }

        System.out.println(max);
    }

    static int LCP(String s1, String s2){
        char[] cs1 = s1.toCharArray();
        char[] cs2 = s2.toCharArray();
        int len1 = s1.length();
        int len2 = s2.length();
        int min = len1 < len2 ? len1:len2;
        int ret = 0;
        for(int i=0;i<min;i++){
            if(cs1[i] != cs2[i]) break;
             ret++;
        }

        return ret;
    }
}

失敗、cometを使ってtail -fの内容を送りたい。 2008/02/03

comet java tomcat アイデアレベル失敗

クライアントでサーバー側のログをみたいということで、tomcat6に入っているcometさんの機能を使えないかなというわけで、頭をひねってみたのでした。

安直にtail -fをコマンド実行して標準出力の内容をせっせっとcomet使って、クライアントに送ればいいじゃんと思ったわけです。

方々を参考にして簡単に実装してみましたが、結果は、「もっと工夫しないとだめ」です。

工夫する必要がある箇所は、ずばりログのとりこぼしがないようにしないといけないところです。

ログのとりこぼしがないようにするためには、どこまでのログをクライアントは受信されたのかという情報をもたせないとできない。それで、その情報をもとにして、サーバーがログを送ってあげる。

あと、CometサーバーとCometクライアントの仕組みがよくわからないです。
基本はLong Pollingなんだというキーワード的にはわかってるんですが....

サーバー側がずーと書き込めるストリームをもちつづけて、だらだら書けば、クライアントに表示できるのであれば簡単だなぁと思ったのですが、その場合のクライアントの実装が思いつかないので、XmlHttpRequest方式(たぶん)で。

しかし、サーバー側の書き込みが終了したということを通知する方法がわからなかったので、BEGINで受け取ったイベントに対してTIMEOUTを設定して、必ずその時間がたったらクライアントはレスポンスを受け取り、処理をして再接続という実装（のつもり）にしてみました。

すぐにクライアントに反映されないので、メリットが感じられないような...

ログのように常に変化し続けるものを表示する場合ってiframe方式(たぶん)がいいのかもしれない。

理解不足、曲解、だめだめですが、とりあえず晒しておくことにします。

<html>
<head>
<script type="text/javascript" src="jquery-1.2.2.min.js"></script>
<script type="text/javascript" >
var isStop = false;
var cash_log1 ="";
var cash_log2 ="";
var cnt =0;
function oo(){
$.ajax({
url: 'http://localhost:8090/examples/tail',
type: 'POST',
dataType: "text",
timeout: 60000,
error: function(){
if(isStop) return;
alert('Error loading text document');
},
success: function(data){

if(isStop) return;
if(!(0 < data.length)){
setTimeout(oo, 1);
return;
}

cash_log1 = cash_log2;
cash_log2 = data;

$('#pp').val(cash_log1 + cash_log2);
setTimeout(oo, 1);
}
});

}
</script>
</head>
<body onload="oo();">
<input type="button" onclick="javascript:isStop=true;" value="stop"/>
<input type="button" onclick="javascript:isStop=false;oo();" value="start"/>
<div id="p"></div>
<textarea id="pp" cols=100 rows=10>
</textarea>
</body>
</html>

import java.io.IOException;
import java.io.InputStream;
import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.Scanner;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;

import org.apache.catalina.CometEvent;
import org.apache.catalina.CometProcessor;

public class TailServlet extends HttpServlet implements CometProcessor {

private static final long serialVersionUID = 1L;
protected ArrayList<CometEvent> connections = new ArrayList<CometEvent>();
protected MessageSender messageSender = null;

public void init() throws ServletException {
messageSender = new MessageSender(getInitParameter("targetFile"));
Thread messageSenderThread = new Thread(messageSender, "MessageSender["
+ getServletContext().getContextPath() + "]");
messageSenderThread.setDaemon(true);
messageSenderThread.start();
}

public void destroy() {
connections.clear();
messageSender.stop();
messageSender = null;
}

public void event(CometEvent event) throws IOException, ServletException {

HttpServletRequest request = event.getHttpServletRequest();
if (event.getEventType() == CometEvent.EventType.BEGIN) {

// timeoutを起こしてクライアントにいったんデータを返す。
event.setTimeout(new Integer(5000));
log("Begin for session: " + request.getSession(true).getId());
log(connections.toString());
synchronized (connections) {
connections.add(event);
}

} else if (event.getEventType() == CometEvent.EventType.ERROR) {
log("Error for session: " + request.getSession(true).getId());
log("EventSubType: " + event.getEventSubType());
synchronized (connections) {
boolean isRemoved = connections.remove(event);
log(" isRemoved:" + isRemoved);
}
event.close();
} else if (event.getEventType() == CometEvent.EventType.END) {
log("End for session: " + request.getSession(true).getId());
log("EventSubType: " + event.getEventSubType());
synchronized (connections) {
boolean isRemoved = connections.remove(event);
log(" isRemoved:" + isRemoved);
}
event.close();
} else if (event.getEventType() == CometEvent.EventType.READ) {
}
}

public class MessageSender implements Runnable {
protected boolean running = true;
String targetFile;

public MessageSender(String targetFile) {
this.targetFile = targetFile;
}

public void stop() {
running = false;
}

public void run() {
String command = "/usr/bin/tail -f " + targetFile;
Runtime runtime = Runtime.getRuntime();
Process process = null;
try {
process = runtime.exec(command);
InputStream in = process.getInputStream();
Scanner scanner = new Scanner(in);

while (scanner.hasNext() && running) {
String s = scanner.nextLine();
// log("o_o!==>" + s);
synchronized (connections) {
Iterator<CometEvent> iterator = connections.iterator();
while (iterator.hasNext()) {
CometEvent event = (CometEvent) iterator.next();
try {

PrintWriter writer = event
.getHttpServletResponse().getWriter();
writer.println(s);
writer.flush();

} catch (IOException e) {
log("IOExeption sending message", e);
} catch (UnsupportedOperationException e) {
e.printStackTrace();
}

}

}
}

} catch (IOException e1) {
e1.printStackTrace();
} finally {
if (process != null) {
try {
process.getErrorStream().close();
} catch (IOException e) {
}
try {
process.getInputStream().close();
} catch (IOException e) {
}
try {
process.getOutputStream().close();
} catch (IOException e) {
}
}
running = false;
}

}
}

}

プログラマメモ2 - programmer no memo2

目次

ドメインクラスを継承して。。。失敗 - grails 2013/10/19

2774 - Memory Limit Exceeded 2012/09/28

失敗、cometを使ってtail -fの内容を送りたい。 2008/02/03