求教如何能实时的将socket服务端接受的数据存入数据库

问题描述

现有一个TCPsocket服务端,并发连接数据大概有1W左右,没个连接没隔30秒发一条数据到服务端,如何将这些数据能实时的插入到数据库中!

解决方案

解决方案二:
所有的连接把收到的数据放到Queue里,然后单独启动一个线程循环取Queue里的数据进行存储。
解决方案三:
队列+数据库批处理
解决方案四:
引用1楼wqc5461的回复:

所有的连接把收到的数据放到Queue里,然后单独启动一个线程循环取Queue里的数据进行存储。

现在是这样的处理机制,连接少可以,但是连接数一多入库的速度就跟不上接收速度!
解决方案五:
引用3楼a8282542的回复:

Quote: 引用1楼wqc5461的回复:
所有的连接把收到的数据放到Queue里,然后单独启动一个线程循环取Queue里的数据进行存储。

现在是这样的处理机制,连接少可以,但是连接数一多入库的速度就跟不上接收速度!

那就用线程池多启动几个这样的线程。
解决方案六:
引用4楼wqc5461的回复:

Quote: 引用3楼a8282542的回复:
Quote: 引用1楼wqc5461的回复:
所有的连接把收到的数据放到Queue里,然后单独启动一个线程循环取Queue里的数据进行存储。

现在是这样的处理机制,连接少可以,但是连接数一多入库的速度就跟不上接收速度!

那就用线程池多启动几个这样的线程。

入库已经开启多个线程了,但是每秒只能处理70-80个
解决方案七:
引用5楼a8282542的回复:

Quote: 引用4楼wqc5461的回复:
Quote: 引用3楼a8282542的回复:
Quote: 引用1楼wqc5461的回复:
所有的连接把收到的数据放到Queue里,然后单独启动一个线程循环取Queue里的数据进行存储。

现在是这样的处理机制,连接少可以,但是连接数一多入库的速度就跟不上接收速度!

那就用线程池多启动几个这样的线程。

入库已经开启多个线程了,但是每秒只能处理70-80个

压力在数据库I/O并不在程序。

时间: 2024-10-21 23:30:04

求教如何能实时的将socket服务端接受的数据存入数据库的相关文章

java ocket 反向-java Socket服务端反向查数据

问题描述 java Socket服务端反向查数据 需求是 两个java web项目,用socket实现数据即时查询 client向server注册,并保持连接 server向client发送请求,client返回数据. 我现在不知道怎么用ServerSocket向Socket对象发送请求,并且能得到回复. 帮我考虑一下,多谢. 解决方案 http://bbs.51cto.com/thread-1084435-1.html 一个简单的Demo 解决方案二: 看一下例子就行了http://blog.

udp-UDP通信中服务端接受数据计算数据包个数

问题描述 UDP通信中服务端接受数据计算数据包个数 UDP通信中客户端通过多线程发送数据,服务端单线程接受数据,出现的"丢包"(我在服务端计算出来的包个数)现象很严重,通过wireshark抓包发现没有任何数据包丢失,菜鸟求解答.代码如下: /*基于LINUX的udp的通信,服务器端*/#include #include #include #include #include #include #include char buf[1024 * 32] = {0}; int main(in

volley框架服务端接受代码

问题描述 volley框架服务端接受代码 客户端用volley框架写的,服务端不知道怎么接受客户端发来的请求,求大神帮忙啊!!! 急急急!!! 客户端请求为: public void testVolleyGet() { String httpurl = "http://192.168.1.106:5432/fdfa/Accept"; //RequestQueue requestQueue = Volley.newRequestQueue(getApplicationContext())

用c#写的上位机 通过socket从下位机得到数据汇成折线图

问题描述 我打算用c#写上位机通过socket接收下位机传来的温度湿度光照强度的数据需要接收这些数据然后分别绘制成温度曲线图湿度曲线图光照强度曲线图我想问问各位大神socket接收的数据格式是怎么样的能把接收的这些数据区分开哪个是温度的数据哪个湿度数据然后采用什么样的方法能分别接收数据同时绘制成三张曲线图 解决方案 解决方案二:socket接收的数据格式是怎么样的取决于你和下位机开发者的约定.解决方案三:那对不同数据怎么区分像温度和光照解决方案四:不同的传感器会有不同的地址码,比如温度地址是00

大数据服务还是那个大数据服务吗?

2012年大数据是个流行词,没想到4年过后,在一些大数据论坛上还有人会说"如果我有大数据,我会怎样怎样--"好吧,如果还停留在如果上,就不该随便上论坛演讲,讲不好说不准工作都没了.现在大数据挖掘的技术都很成熟,更完善更系统的解决方案早已有人做得非常好.如果连数据都还没有,那就什么都不用提了.毕竟,人工智能+大数据的生态模式已经开启. 7月初,据外媒福布斯报道百度将人工智能+大数据为中国政府采集数据提供支持.7月13日,李彦宏在百度的开放云战略发布会上首度公开百度开放云"人工智

Java基于socket服务实现UDP协议的方法

  本文实例讲述了Java基于socket服务实现UDP协议的方法.分享给大家供大家参考.具体如下: 示例1: 接收类: ? 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 package com.socket.demo; import java.io.IOException; import java.net.DatagramPacket; import java.net

Mpass – PHP做Socket服务的解决方案

一般很少有用PHP做服务的, 但是如果你的已有业务逻辑都是PHP实现的, 而现在却需要基于已有的业务逻辑提供一套Socket服务, 怎么办? 当然, 解决方法很多, 但最简单的办法, 还是直接使用PHP做Socket服务. 而这样做要解决的问题有很多, 主要要解决的问题有如下几个: 1. 作为后台服务,需要常驻后台运行, 那么丁点的内存泄露都是不能接受的. 2. 作为后台服务,畸形数据导致进程异常退出, 也是不可接受的. 3. 作为后台服务, 要能做到graceful restart. 4. 作

android通过socket通信实现客户端读取服务端的二进制数据,并展示在textview控件上

问题描述 android通过socket通信实现客户端读取服务端的二进制数据,并展示在textview控件上 客户端通过socket通信,完成读取服务端的二进制数据读取,并将数据显示在textview控件上,数据全为整型 解决方案 之前接触一些,但不是我我写的.JNI中C读取,生成Native方法.上层调用 解决方案二: 底层c来封装so文件调用socket API.上面Java调用so 解决方案三: ....java自己有socket啊,ls各位回答的什么意思.... 简单的socket网上教

socket服务端必须写在wcf或winform中吗

问题描述 没做过socket,现在要做socket的服务端,我现在将代码写在web项目的类库中,不清楚socket服务是否随着web项目启动而启动,还是需要重新起一个winform或wcf项目,请指点下呀 解决方案 解决方案二:和通常的socket一样写就可以了解决方案三:需要单独写一个socket程序,可以是控制台,winform,wpf,跟wcf不是一回事.解决方案四:写个单独服务,部署在服务器.解决方案五:也可以卸载web项目的gloax文件中解决方案六:也可以windowsservice