报文解析入库java代码 报文解析入库java代码是什么

如何实现java解析网络协议报文

普通参数：

Content-Type: text/plain; charset=UTF-8

Content-Transfer-Encoding: 8bit

文件参数：

Content-Type: application/octet-stream

Content-Transfer-Encoding: binary

参数实体的最后一行是: --加上boundary加上--，最后换行，这里的 格式即为: --OCqxMF6-JxtxoMDHmoG5W5eY9MGRsTBp--。

模拟文件上传请求

public static void uploadFile(String fileName) {

try {

// 换行符

final String newLine = "\r\n";

final String boundaryPrefix = "--";

// 定义数据分隔线

String BOUNDARY = "========7d4a6d158c9";

// 服务器的域名

URL url = new URL("");

HttpURLConnection conn = (HttpURLConnection) url.openConnection();

// 设置为POST情

conn.setRequestMethod("POST");

// 发送POST请求必须设置如下两行

conn.setDoOutput(true);

conn.setDoInput(true);

conn.setUseCaches(false);

// 设置请求头参数

conn.setRequestProperty("connection", "Keep-Alive");

conn.setRequestProperty("Charsert", "UTF-8");

conn.setRequestProperty("Content-Type", "multipart/form-data; boundary=" + BOUNDARY);

OutputStream out = new DataOutputStream(conn.getOutputStream());

// 上传文件

File file = new File(fileName);

StringBuilder sb = new StringBuilder();

sb.append(boundaryPrefix);

sb.append(BOUNDARY);

sb.append(newLine);

// 文件参数,photo参数名可以随意修改

sb.append("Content-Disposition: form-data;name=\"photo\";filename=\"" + fileName

+ "\"" + newLine);

sb.append("Content-Type:application/octet-stream");

// 参数头设置完以后需要两个换行，然后才是参数内容

sb.append(newLine);

sb.append(newLine);

// 将参数头的数据写入到输出流中

out.write(sb.toString().getBytes());

// 数据输入流,用于读取文件数据

DataInputStream in = new DataInputStream(new FileInputStream(

file));

byte[] bufferOut = new byte[1024];

int bytes = 0;

// 每次读1KB数据,并且将文件数据写入到输出流中

while ((bytes = in.read(bufferOut)) != -1) {

out.write(bufferOut, 0, bytes);

}

// 最后添加换行

out.write(newLine.getBytes());

in.close();

// 定义最后数据分隔线，即--加上BOUNDARY再加上--。

byte[] end_data = (newLine + boundaryPrefix + BOUNDARY + boundaryPrefix + newLine)

.getBytes();

// 写上结尾标识

out.write(end_data);

out.flush();

out.close();

// 定义BufferedReader输入流来读取URL的响应

// BufferedReader reader = new BufferedReader(new InputStreamReader(

// conn.getInputStream()));

// String line = null;

// while ((line = reader.readLine()) != null) {

// System.out.println(line);

// }

} catch (Exception e) {

System.out.println("发送POST请求出现异常！" + e);

e.printStackTrace();

}

}

相关问答

Q1: java一段报文求解析出其中的msg插入到数据库，先谢过大神！

给你一个例子：

public class testJson{

 public static void main(String[] args) {

  String json = "{x:'1',y:'2',userId:'112',element:[{id:'123',name:'haha'},{id:'456',name:'hehe'}]}";

  

   JSONObject obj = JSONObject.fromObject(json);

   String x = obj.getString("x");

   String userid = obj.getString("userId");

   System.out.println("x is:" + x);

   System.out.println("userId is:" + userid);

  

   // 数组array结果：[{"id":"123","name":"haha"},{"id":"456","name":"hehe"}]

   JSONArray jsonArray = obj.getJSONArray("element");

   for (int i = 0; i  jsonArray.size(); i++) {

    System.out.println("element " + i + " :" + jsonArray.get(i));

   }

 }

}

输出：

x is:1

userId is:112

element 0 :{"id":"123","name":"haha"}

element 1 :{"id":"456","name":"hehe"}

其实就是java和json转换

Q2: java 实现抓取本地网卡TCP报文，然后解析，将其写入数据库 谁有样例代码，或者实现方式，

思路很简单开发一个小型的WEB应用，部署在长沙和北京两台服务器上，安装个tomact就可以运行和部署了这个WEB应用主要做如下事情：

接受请求，封装json串 （为什么JSON可以查一下网上大把的）1）收到http请求后，校验是否是来自另外一个服务器的请求（通过判断请求的IP地址是否否为另外一个服务器的IP地址即可）2）校验通过后读取本地服务器数据库，查询需要实时同步的数据表，查出需要同步的数据，组装成数据对象集（例如一个arraylist），然后转换为 json格式串，写入到response输出流中。

发请求获取返回结果，插入/更新数据库1）从reponse输出流中读取返回结果，将JSON串转化为对象集（网上大把的），然后开始更新/插入数据/删除数据——————————————————————————————————————由于涉及三种操作类型 更新 删除 插入 ，所以可以分别实现三个servlet来分别负责：1）查询新增数据/插入新增对象2) 查询更新数据/更新新增对象3)查询删除数据/删除待删除的对象——————————————————————————————————————定时调度同步程序使用timer写个jar程序，循环每5分钟利用httpconnnection一次请求之行下插入/更新/删除的servlet___________________________________________________________________

Q3: java解析报文

ByteBuffer bb = ByteBuffer.wrap(data, offset, length);

if (bb.remaining() MIN_HEADER_LENGTH) {

return this;

}

this.opCode = bb.get();

this.transactionId = bb.getInt();

按照这种节奏搞吧，这个很简单的啊，拿到BYTEBUFFER以后，一点一点的处理byte。

Q4: heapbuffer报文java怎么解析

heap buffer 和 direct buffer区别

在Java的NIO中，我们一般采用ByteBuffer缓冲区来传输数据，一般情况下我们创建Buffer对象是通过ByteBuffer的两个静态方法：

ByteBuffer.allocate(int capacity);

ByteBuffer.wrap(byte[] array);

查看JDK的NIO的源代码关于这两个部分：

/**allocate()函数的源码**/

public static ByteBuffer allocate(int capacity) {

if (capacity 0)

throw new IllegalArgumentException();

return new HeapByteBuffer(capacity, capacity);

}

/**wrap()函数的源码**/

public static ByteBuffer wrap(byte[] array) {

return wrap(array, 0, array.length);

}

//

public static ByteBuffer wrap(byte[] array,

int offset, int length)

{

try {

return new HeapByteBuffer(array, offset, length);

} catch (IllegalArgumentException x) {

throw new IndexOutOfBoundsException();

}

}

我们可以很清楚的发现，这两个方法都是实例化HeapByteBuffer来创建的ByteBuffer对象，也就是heap buffer. 其实除了heap buffer以外还有一种buffer，叫做direct buffer。我们也可以创建这一种buffer，通过ByteBuffer.allocateDirect(int capacity)方法，查看JDK源码如下：

public static ByteBuffer allocateDirect(int capacity) {

return new DirectByteBuffer(capacity);

}

我们发现该函数调用的是DirectByteBuffer(capacity)这个类，这个类就是创建了direct buffer。

报文解析入库java代码的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于报文解析入库java代码是什么、报文解析入库java代码的信息别忘了在本站进行查找喔。