init

18045010223

2025-07-07 4d55075574ff1d55c1f56f89f5f3f95889258914

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
package cn.org.hentai.jtt1078.test;
 
import cn.org.hentai.jtt1078.flv.FlvEncoder;
import cn.org.hentai.jtt1078.server.Jtt1078Decoder;
import cn.org.hentai.jtt1078.util.ByteHolder;
import cn.org.hentai.jtt1078.util.ByteUtils;
import cn.org.hentai.jtt1078.util.Packet;
 
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.LinkedList;
 
/**
 * Created by matrixy on 2019/12/16.
 */
public class RTPGenerate
{
    public static void main(String[] args) throws Exception
    {
        InputStream input = new FileInputStream("d:\\test\\1078\\streamax-20191209.bin");
        LinkedList<Packet> packets = readPackets(input);
 
        for (int i = 0; i < 100; i++)
        {
            String sim = String.format("013800138%03d", i);
            int channel = 1;
 
            try (OutputStream output = new FileOutputStream("d:\\test\\1078\\temp\\" + sim + "-" + channel + ".bin"))
            {
                for (Packet p : packets)
                {
                    p.seek(8).putBytes(toBCD(sim));
                    p.seek(14).putByte((byte)channel);
                    output.write(p.getBytes());
                }
                System.out.println(String.format(" -> %s-%d generated...", sim, channel));
            }
            catch(Exception ex)
            {
                ex.printStackTrace();
                System.out.println(ex);
            }
        }
 
        input.close();
    }
 
    public static LinkedList<Packet> readPackets(InputStream input) throws Exception
    {
        int len = -1;
        byte[] block = new byte[1024];
        Jtt1078Decoder decoder = new Jtt1078Decoder();
 
        LinkedList<Packet> packets = new LinkedList();
 
        while ((len = input.read(block)) > -1)
        {
            decoder.write(block, 0, len);
            while (true)
            {
                Packet p = decoder.decode();
                if (p == null) break;
 
                packets.add(p);
            }
        }
 
        return packets;
    }
 
    public static byte[] toBCD(String sim)
    {
        byte[] bcd = new byte[sim.length() / 2];
        for (int i = 0, k = 0, l = sim.length(); i < l; i+=2)
        {
            char a = (char)(sim.charAt(i) - '0');
            char b = (char)(sim.charAt(i + 1) - '0');
            bcd[k++] = ((byte)(a << 4 | b));
        }
        return bcd;
    }
}