SOCKET接收数据的同事并且将接收的数据转发到自己的服务端,以供别的客户端请求读取

1、假设我有一个socket客户端A,接收其他服务器的信息,解析完成之后,存到数据库,
2、同时要启动一个自己的服务端S,可以让其他的客户端假设B进行请求,输入账号密码,通过之后拿到A实时接收到的数据

2个回答

已经自己实现,生产者消费者模式

如果你想要的逻辑是这样的话,我给出我自己的建议:
1、客户端A接收到服务器的数据之后,保存到数据库;
2、(这里不知道你是否是必须启动一个本地服务器) 其实第二步可以选择使用http接口的方式,不用socket,因为是用户B主动请求数据。并不是客户端A获取到数据之后,进行实时转发给用户B!
3、如果是实时转发:建议本地服务端先启动好。用户B事先是连接上的,然后客户端A接收数据的同时,可以直接选择广播的方式进行将接收到的数据发送给用户B

(马上下班了。就不写代码上了。就写点思路建议了,看看就好)

weixin_42960721
徐良海哎哟是你呀 用http就保证不了实时,但是用广播不知道怎么写
一年多之前 回复
Csdn user default icon
上传中...
上传图片
插入图片
抄袭、复制答案,以达到刷声望分或其他目的的行为,在CSDN问答是严格禁止的,一经发现立刻封号。是时候展现真正的技术了!
其他相关推荐
c++socket客户端数据接收问题

本人刚接触这个东西,水平较低,在测试上位机客户端是否可以接受数据时,出现些问题,下位机发送的数据是ff,上位机接收的情况如图,会出现乱码,还有就是数据显示的很慢,最重要的是还需要不断抽拔与WiFi模块RX接口相连的线才能有数据显示,不知道是什么原因,程序是在网上找的socket客户端的程序,请大神们帮看一下,这个问题折磨我很久了,万分感谢。![图片说明](https://img-ask.csdn.net/upload/201608/25/1472136704_602387.png)

android 客户端socket接收数据时只能接收到1448个字节

byte[] buffer = new byte[1024 * 101]; while ((length = is.read(buffer)) != -1) { byte[] dataInstream = new byte[length]; System.arraycopy(buffer, 0, dataInstream, 0, length); } ```我在使用socket接收数据的时候,new一个缓冲区然后从输入流中读取数据到缓冲区可读到的数据只有1448个字节而实际服务端发送的字节数据流远远大于1448,困扰了几天了,有人能帮我解决这个问题吗 ```

求助,C# winform实现socket接收客户端数据,总是丢数据。

程序主体是client端发送数据给server端,server那边接收到信息就发送一条固定的确认信息给client。 出现的问题就是运行的时候会固定丢掉第二次返回的数据,第一次和其他时候的都正常。打断点调试的时候也是正常的,很懵啊。。 感觉跟UI刷新有关,却又解决不了。另开线程接收也会有这个问题。贴上代码,求助大神。 using System; using System.Collections.Generic; using System.ComponentModel; using System.Data; using System.Drawing; using System.Linq; using System.Text; using System.Windows.Forms; using System.Net; using System.Net.Sockets; using System.Threading; namespace SocketDemo_Client { public partial class MainForm : Form { public MainForm() { InitializeComponent(); } private Socket soc_client = null; private byte[] socket_buf = null; private Thread t_listener = null; private void MainForm_Load(object sender, EventArgs e) { if (socket_buf == null) { socket_buf = new byte[4096]; } } /// <summary> /// 连接按钮的点击事件 /// </summary> /// <param name="sender"></param> /// <param name="e"></param> private void btnConnect_Click(object sender, EventArgs e) { IPAddress host_ip = IPAddress.Parse(this.txtIP.Text); IPEndPoint end_ipe = new IPEndPoint(host_ip, Convert.ToInt32(this.txtPort.Text)); soc_client = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); soc_client.Connect(end_ipe); this.txtLog.AppendText("连接到" + soc_client.RemoteEndPoint.ToString() + "服务端。。。"); this.txtLog.AppendText(System.Environment.NewLine); } private void btnDisConnect_Click(object sender, EventArgs e) { this.txtLog.AppendText("关闭双向传输通道。。。"); this.txtLog.AppendText(System.Environment.NewLine); soc_client.Shutdown(SocketShutdown.Both); Thread.Sleep(500); this.txtLog.AppendText("关闭Socket对象。。。"); this.txtLog.AppendText(System.Environment.NewLine); soc_client.Close(); } private void btnSendMsg_Click(object sender, EventArgs e) { if (this.txtMsg.Text == "") { MessageBox.Show("输入发送内容啊骚年!"); return; } this.txtLog.AppendText("发送" + this.txtMsg.Text + "到服务端。。。"); this.txtLog.AppendText(System.Environment.NewLine); /* Array.Clear(socket_buf, 0, socket_buf.Length); socket_buf = Encoding.ASCII.GetBytes(this.txtMsg.Text); soc_client.Send(socket_buf); //清空发送框 this.txtMsg.Text = ""; //启动接收监听线程 if (t_listener == null) { t_listener = new Thread(MsgListener); t_listener.Start(); } if (t_listener.ThreadState == ThreadState.Suspended) { t_listener.Resume(); } */ string getStr = ""; getStr = SendAndReceive(this.txtMsg.Text); Thread.Sleep(2000); this.txtLog.AppendText("收到服务端信息:"); this.txtLog.AppendText(System.Environment.NewLine); this.txtLog.AppendText(getStr); this.txtLog.AppendText(System.Environment.NewLine); } /// <summary> /// /// </summary> private string SendAndReceive(string msg) { Array.Clear(socket_buf, 0, socket_buf.Length); socket_buf = Encoding.ASCII.GetBytes(msg); soc_client.Send(socket_buf); //清空发送框 this.txtMsg.Text = ""; string t = ""; soc_client.SetSocketOption(SocketOptionLevel.Socket, SocketOptionName.ReceiveTimeout, 500); Array.Clear(socket_buf, 0, socket_buf.Length); try { while (true) { int length = soc_client.Receive(socket_buf); t += Encoding.ASCII.GetString(socket_buf, 0, length); } } catch (SocketException e) { return t; } return t; } /// <summary> /// 接收线程 /// </summary> private void MsgListener() { string get_str = ""; soc_client.SetSocketOption(SocketOptionLevel.Socket,SocketOptionName.ReceiveTimeout,500); while (true) { Array.Clear(socket_buf, 0, socket_buf.Length); try { int length = soc_client.Receive(socket_buf); //接收活动连接发送的数据填充到buffer中 get_str += Encoding.ASCII.GetString(socket_buf, 0, length); //将缓存buffer的byte数据转换成字符串 } catch (SocketException se) { //线程委托去刷新信息 this.Invoke(new MethodInvoker(delegate { this.txtLog.AppendText("收到服务端信息:"); this.txtLog.AppendText(System.Environment.NewLine); this.txtLog.AppendText(get_str); this.txtLog.AppendText(System.Environment.NewLine); get_str = ""; })); //挂起线程 t_listener.Suspend(); continue; } } } } }

急。。。。交作业 !java socket发送和接收数据

一、 项目需求 模拟socket发送(发送随机16进制数据)和接收(接收后解析成10进制),并在前台进行显示和规则判断,判断符合条件的数据,向前台发送报警信息。 模拟两组数据同时发送(并发),发送间隔5秒。 二、 流程说明 ![图片说明](https://img-ask.csdn.net/upload/201711/07/1510034044_771810.png) 用户角色为两个,A角色接收报警,并对报警进行处理(如点击确认按钮),处理后B角色才能看到这条报警信息。同时两个角色都可以查询历史报警。 三、 编码要求 编码规范结构清晰,注释规范。 四、 项目输出 可运行的项目代码;需求分析;设计说明书;项目总结。

C# socket接收单片机数据问题

单片机通过wifi将采集到传感器的数据传至上位机,单片机是每一秒发送一组数据,如“0xaa,0x55,‘采集到的数据1’,‘采集到的数据2’” 问:怎样才能接收数据并判断第一个是“0xaa“并且第二位是”0x55“时候将”采集到的数据1“和”采集到的数据2“拿出来并整合合,下一秒也是这样循环下去,我现在只能做到接收数据。 private byte[] m_receiveBuffer = new byte[1024]; sock.BeginReceive(m_receiveBuffer, 0, m_receiveBuffer.Length, 0, new AsyncCallback(ReceiveCallBack), null); private void ReceiveCallBack(IAsyncResult ar) { try { int REnd = sock.EndReceive(ar); string strReceiveData = m_receiveBuffer[0].ToString("X2"); this.HandleMessage(strReceiveData); sock.BeginReceive(m_receiveBuffer, 0, m_receiveBuffer.Length, 0, new AsyncCallback(ReceiveCallBack), null); } catch (Exception ex) { throw new Exception(ex.Message); } } private void HandleMessage(string message) { message = message.Replace("\0", ""); if (!string.IsNullOrEmpty(message)) { label6.Text = message; } }

C++socket数据接收处理问题

1.能够点了按钮之后能够一直接收发送过来的单行数据 2.能把接收的数据处理好了之后存到另外定义的数组或list中去 3.那个线程应该如何定义程序才能执行   SOCKET sHost;   WSADATA wsd;   SOCKET sServer;   SOCKET sClient;   SOCKADDR_IN addrServ;   void CMyDlg::OnRev()   {   #define BUF_SZIE 64   #pragma comment(lib, "ws2_32.lib")   char buf[BUF_SZIE];   int retVal;   if (WSAStartup(MAKEWORD(2,2), &wsd) != 0)   {   printf("WSAStartup failed!\n");   }   sServer = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);   addrServ.sin_family = AF_INET;   addrServ.sin_port = htons(3000);   addrServ.sin_addr.s_addr = INADDR_ANY;   retVal = bind(sServer, (LPSOCKADDR)&addrServ, sizeof(SOCKADDR_IN));   retVal = listen(sServer, 10);   sockaddr_in addrClient;   int addrClientlen = sizeof(addrClient);   sClient = accept(sServer,(sockaddr FAR*)&addrClient, &addrClientlen); ​   ZeroMemory(buf, BUF_SZIE);      while(true)   {   retVal = recv(sClient, buf, BUF_SZIE, 0);   if (SOCKET_ERROR == retVal)   {   printf("send failed!\n");   }   else   {   ......   }   }      closesocket(sClient);   WSACleanup();   } 求大神指点一二 - List item

C#通过socket接收数据,提示转换无效

我用socket接收数据,在接收这个方法中直接使用接收到的值,一切正常 可是我向其他方法传递值,其他方法中对这个值进行调用,出现“转换无效” 不知道什么情况,网上说是线程安全的问题 我用委托的方式和Control.CheckForIllegalCrossThreadCalls = false; 的方法 都不行

VC socket编程,数据接收问题

用VC socket编程时,用recv函数接收字符串数据,只能接收到前4个字符,多于4个字符的都是“烫”字乱码。这是什么问题?怎么解决? char cs[100]; case FD_READ: { CString num=""; //定义字符串,用于保存待显示字符 ::recv(s1,cs,strlen(cs),0); //接收来自客户端的字符串数据 GetDlgItem(IDC_TEXT)->GetWindowText(num); //获取消息显示框中原有的字符 num+="\r\n"; //添加换行符 num+=(LPTSTR)::inet_ntoa(add1.sin_addr); //将客户端IP换成字符串 num+=":\r\n"; //添加换行符 num+=(LPTSTR)cs; //将接收到的字符串添加到显示字符串 num+=":\r\n"; //添加换行符 GetDlgItem(IDC_TEXT)->SetWindowText(num); //将字符串显示到消息显示框 }

[新手]关于socket.io接收tcp服务器数据后转发给客户端的问题【一句话就能解决?】

如标题,接收到了tcp服务器的数据后,想转发给客户端。但是socket.io文档似乎没有这种方法。直接上代码。 服务器部分: **var express=require('express'); var app=express(); var fs =require('fs'); var net=require('net'); var http=require('http').createServer(app); var io=require('socket.io').listen(http); //nodeServer需要的变量 var nodeServer = new net.Socket(); var ExBuffer = require('./ExBuffer'); var len = 4027; var offset=4; var exBuffer = new ExBuffer().uint32Head().littleEndian(); var sbuf = new Buffer(4); //存储客户端的连接实例 var aSocket={}; app.use(express.static('public')); app.get('/',function(req,res){ res.sendfile(__dirname+'/index.html'); }); //连接到C服务器 nodeServer.connect(3102, '127.0.0.1', function() { console.log('CONNECTED TO: 127.0.0.1:3102' ); // 建立连接后立即向服务器发送数据,服务器将收到这些数据 nodeServer.write('your socket has connected'); }); var server = http.listen(8888, '127.0.0.1',function () { var host = server.address().address var port = server.address().port console.log("welcome to http://%s:%s", host, port) }); // 同客户端建立连接 io.sockets.on('connection', function (socketIO) { aSocket=socketIO; // 从客户端接收数据,然后发送至Tomcat socketIO.emit("test","your websocket has connected"); socketIO.on('fromWebClient', function (webClientData) { }); //客户端断开连接 socketIO.on('disconnect', function () { console.log('DISCONNECTED FROM CLIENT'); }); }); // 从C服务器接收数据 nodeServer.on('data', function (data) { if(data.readUInt8(0)==170){ sbuf.writeUInt32LE(len,0);//写入包长 exBuffer.put(sbuf); exBuffer.put(data); } else{ exBuffer.put(data); } console.log('nodeServer'+data.length); }); //当nodeServer收到完整的数据包时 exBuffer.on('data', function(buffer) { console.log('>> nodeServer receive data.length:'+buffer.length); //console.log(buffer); //console.log(buffer.readInt32LE(826)); var useData=byteArrayUntil.getUseJson(buffer,offset); console.log(aSocket); aSocket.emit['pushToWebClient',useData.hz]; }); // 为nodeServer添加“data”事件处理函数 // data是服务器发回的数据 // 为客户端添加“close”事件处理函数 nodeServer.on('close', function() { console.log('Connection closed'); }); //构造一个遍历函数,分别返回array或者json var byteArrayUntil=new function(){ this.getUseData=function(data,offset){ var arr=[]; for(var i=0;i<=799;i++){ arr.push(data.readInt32LE(826+i*offset)); } return arr; } this.getUseJson=function(data,offset){ var arr=[]; for(var i=0;i<=500;i++){ arr.push(data.readInt32LE(826+i*offset)); } return {'hz':arr}; } }();** 客户端部分:(很多无用的就贴关键的了,其实这个可以暂时无视) <script> var socket = io.connect(); socket.on("test", function (data) { console.log(data); }); socket.on('pushToWebClient', function (data) { console.log(data); }); 现在问题就是服务器的这一部分: exBuffer.on('data', function(buffer) { console.log('>> nodeServer receive data.length:'+buffer.length); //console.log(buffer); //console.log(buffer.readInt32LE(826)); var useData=byteArrayUntil.getUseJson(buffer,offset); console.log(aSocket); aSocket.emit['pushToWebClient',useData.hz]; }); 我把数据接收到了,最后一句转发给客户端不会。ps:不用管对应id问题,我只需要简单实现转发数据即可。 参考过这个文档(如果知道上面怎么处理可以不用继续看了): var http = require('http'), 2 net = require('net'), 3 app = http.createServer().listen('8181'), 4 io = require('socket.io').listen(app), 5 nodeServer = new net.Socket(); 6 // 连接到Tomcat 7 nodeServer.connect(8007, '127.0.0.1', function() { 8 console.log('CONNECTED'); 9 }); 10 // 存储客户端的WebSocket连接实例 11 var aSocket = {}; 12 // 同客户端建立连接 13 io.sockets.on('connection', function (socketIO) { 14 // 从客户端接收数据,然后发送至Tomcat 15 socketIO.on('fromWebClient', function (webClientData) { 16 // 存储至映射表 17 aSocket[socketIO.id] = socketIO; 18 // 发送至Tomcat的数据中添加socket_id 19 webClientData['sid'] = socketIO.id; 20 // 发送String类型的数据至Tomcat 21 nodeServer.write(JSON.stringify(webClientData)); 22 }); 23 // 客户端断开连接 24 socketIO.on('disconnect', function () { 25 console.log('DISCONNECTED FROM CLIENT'); 26 }); 27 }); 28 29 // 从Tomcat接收数据 30 nodeServer.on('data', function (data) { 31 var jsonData = JSON.parse(data.toString()); 32 // 分发数据至客户端 33 for (var i in jsonData.list) { 34 aSocket[jsonData.list[i]['sid']].emit('pushToWebClient', jsonData.list[i].data); 35 } 36 }); 有这么一句 aSocket[jsonData.list[i]['sid']].emit('pushToWebClient', jsonData.list[i].data); 虽然它实现的是通过id来实现建立一一对应连接,但是它还是独立出来使用了(查了一些资料都是在一起用的), 到底该怎么实现呢?ps:不用管对应id问题,我只需要简单实现转发数据即可。 求大神帮助。

Socket同时读写问题,两边都可以发送接收数据

有个协议通过socket通讯,两边都可以发送接收数据。完整的指令是一个请求对应一个应答。 正常来说是需要有个读线程用来监听对方主动发过来的数据,当接收到数据后我就返回个响应信息给对方。我这边主动发送指令后也要进行读取对方响应的消息。但我该如何设计请求与响应这一对信息呢?Socket.Receive又是阻塞的,我希望最好是一个线程接收对方的指令,一个我这边主动发的指令,互相不干扰。

qt 线程中接收socket数据

#ifndef TCP_THREAD_H #define TCP_THREAD_H #include <QThread> #include <QTcpSocket> #include <QTcpServer> #define MAX_SEND_MSG_LEN 68 struct _loop_buf { int num_of_unit; // Number of data units int unit_size; int rhead; // Head for read int whead; // Head for write void *buf_head; }; class TcpThread : public QThread { Q_OBJECT private: QTcpServer *tcpServer; QTcpSocket *socket; QString ipAddress; quint16 destinationPort; int Flag; bool quit; struct _loop_buf loop_buf; void run() Q_DECL_OVERRIDE; void processMessage(char *msg); int init_loop_buf(struct _loop_buf *loop_buf, int num_of_unit, int unit_size); void reset_loop_buf(struct _loop_buf *loop_buf); void release_loop_buf(struct _loop_buf *loop_buf); int read_data_from_loop_buf(struct _loop_buf *loop_buf, void *data_unit); QByteArray bytes; QByteArray byteGet; public: TcpThread(QString ipAddress, quint16 destinationPort, QObject *parent = 0); ~TcpThread(); int addMessage(void *data_unit); signals: void error(int socketError, const QString &message); public slots: void finishWork(void); void newConnectionSlot(); void dataReceived(); }; #endif // TCP_THREAD_H .h文件 ``` #if defined(_MSC_VER) && (_MSC_VER >= 1600) #pragma execution_character_set("utf-8") #endif //#define MAX_SEND_MSG_LEN = 68 #include "TcpThread.h" #include "widget.h" #include <QDebug> TcpThread::TcpThread(QString ipAddress, quint16 destinationPort, QObject *parent) : QThread(parent), quit(false) { this->ipAddress = ipAddress; this->destinationPort = destinationPort; // Initialize loop buffer // Max length of messages to be sent is 68 bytes. if (init_loop_buf(&loop_buf, 128000, MAX_SEND_MSG_LEN) != 0) { qDebug() << "Can't initialize loop buffer."; return; } } TcpThread::~TcpThread() { // Wait for the end of the thread. quit = true; wait(); } void TcpThread::run() { // // At here, it is in the execution context of newly created thread. // So, it is better to define or create objects here. // Or, following error may occurred: // QObject: Cannot create children for a parent that is in a different thread // char *msg;//, *sendMsg; int conn_timeout = 30000; int read_timeout = 5000; int write_timeout = 5000; int bytesToRead, readBytes; int bytesToWrite, writeBytes; int ret; int gotMessageHead = 0; int toGetNewMessage = 0; //msg = (char *)calloc(65536 + 128, 1); msg = (char *)calloc(MAX_SEND_MSG_LEN, 1); if (msg == NULL) { qDebug() << "Can't allocate memory."; return; } tcpServer = new QTcpServer(); socket = new QTcpSocket(); //connect(tcpServer, SIGNAL(newConnection()), this, SLOT(newConnectionSlot()), Qt::DirectConnection); if (!tcpServer->isListening()) { qDebug() << ipAddress; //if (tcpServer->listen(QHostAddress::QHostAddress(ipAddress), 16512)) if (tcpServer->listen(QHostAddress::Any, 16512)) { //m_pEdt_Info->append(QObject::tr("打开监听端口成功!111")); qDebug()<< QObject::tr("打开监听端口成功!111"); socket = tcpServer->nextPendingConnection(); // //connect(socket, SIGNAL(disconnected()), socket, SLOT(deleteLater())); connect(socket, SIGNAL(readyRead()),this, SLOT(dataReceived())); } else { //m_pEdt_Info->append(QObject::tr("打开监听端口失败!")); qDebug()<< QObject::tr("打开监听端口失败!11"); } } else { //m_pEdt_Info->append(QObject::tr("正在监听中...!")); qDebug()<< QObject::tr("正在监听中...!"); } qDebug() << "Connected to" << ipAddress; // reset read variables readBytes = 0; bytesToRead = 4; gotMessageHead = 0; // reset write variables writeBytes = 0; toGetNewMessage = 1; } void TcpThread::processMessage(char *msg) { qDebug() << "Receive message:" << *(unsigned short *)msg << ". Length:" << *(unsigned short *)(msg + 2); } void TcpThread::finishWork(void) { quit = true; } int TcpThread::init_loop_buf(struct _loop_buf *loop_buf, int num_of_unit, int unit_size) { unsigned long long total_size; total_size = (unsigned long long)unit_size * (unsigned long long)num_of_unit; if (total_size > 0x7fffffff) { printf("Memory to be allocated is too large.\n"); return -1; } if (num_of_unit > 0x7ffffff0) { printf("Buffer size can't exceed 0x7ffffff0.\n"); return -1; } loop_buf->num_of_unit = num_of_unit; loop_buf->unit_size = unit_size; loop_buf->rhead = 0; loop_buf->whead = 0; loop_buf->buf_head = malloc(total_size); if (loop_buf->buf_head == NULL) { printf("Can't allocate memory for the loop buffer.\n"); return -1; } return 0; } // Be careful to call this function. You must make sure that // nobody is using the loop buffer pointed by 'loop_buf', // or error may occur. void TcpThread::reset_loop_buf(struct _loop_buf *loop_buf) { loop_buf->rhead = 0; loop_buf->whead = 0; } void TcpThread::release_loop_buf(struct _loop_buf *loop_buf) { free(loop_buf->buf_head); } // // Return value: // 0: Success. // -1: The loop buffer is NULL. // int TcpThread::read_data_from_loop_buf(struct _loop_buf *loop_buf, void *data_unit) { if (loop_buf->rhead == loop_buf->whead) { // The buffer is null. return -1; } // // Do your work here, you can read data from the loop buffer. // Following is just an example. // // Note: // Must copy the data out, or the content of the data unit may be // overwritten. // memcpy(data_unit, (char *)loop_buf->buf_head + loop_buf->rhead * loop_buf->unit_size, (size_t)loop_buf->unit_size); if (loop_buf->rhead == (loop_buf->num_of_unit - 1)) { loop_buf->rhead = 0; } else { loop_buf->rhead++; } return 0; } // // --- IMPORTANT --- // There is no mutex to avoid race condition in the function's implementation. // So, to call this function from only one code source. // //Return value: // 0: Success. // -1: The loop buffer is full. // int TcpThread::addMessage(void *data_unit) { int tmp_whead = 0; tmp_whead = loop_buf.whead + 1; if (tmp_whead >= loop_buf.num_of_unit) { tmp_whead = 0; } if (tmp_whead == loop_buf.rhead) { // The buffer is full. return -1; } // // Do your work here, you can write data to the loop buffer. // Following is just an example. // memcpy((char *)loop_buf.buf_head + loop_buf.whead * loop_buf.unit_size, data_unit, (size_t)loop_buf.unit_size); loop_buf.whead = tmp_whead; return 0; } void TcpThread::newConnectionSlot() { //m_pEdt_Info->append(QObject::tr("有新客户端连接到服务器")); socket = tcpServer->nextPendingConnection(); connect(socket, SIGNAL(disconnected()), socket, SLOT(deleteLater())); connect(socket, SIGNAL(readyRead()),this, SLOT(dataReceived())); } void TcpThread::dataReceived() { bytes = socket->readAll(); qDebug() << bytes.length() << bytes.size(); //if (bytes.size()=0) waitfo if (byteGet.size()!=0){ byteGet.append(bytes.left(68-byteGet.size())); bytes.remove(0,68-byteGet.size()); qDebug() << byteGet.length() << bytes.size(); } for (;bytes.size()>=68;){ byteGet = bytes.left(68); //m_pEdt_Info->append(byteGet.toHex()); bytes.remove(0,68); qDebug() << byteGet.length() << bytes.size(); } if (bytes.size()>0&&bytes.size()<68){ byteGet = bytes; bytes.remove(0,byteGet.size()); qDebug() << byteGet.toHex(); qDebug() << byteGet.length() << bytes.size(); //bytes = m_pSocket->readLine(); //m_pServer->close(); } } ``` .cpp文件 线程中接收数据,使用信号机制可不可以啊? 我用connect(socket, SIGNAL(readyRead()),this, SLOT(dataReceived())); 发现Slot里面定义的接收数据并未调用到。为什么,是this的问题,还是不应该这样使用信号机制。或者还有别的什么好方法吗,麻烦各位大神热点,感激

C#里用socket收发udp数据的问题

一:用udp收发数据,为什么接收方要发一帧数之后才能接收到数据? private Socket SetupUdpSocketObject(string localIp, string localPort, string remoteIp, string remotePort) { //得到本机IP,设置TCP端口号 var ip = new IPEndPoint(IPAddress.Parse(localIp), int.Parse(localPort)); var ret = new Socket(AddressFamily.InterNetwork, SocketType.Dgram, ProtocolType.Udp); //绑定网络地址 ret.Bind(ip); var sender = new IPEndPoint(IPAddress.Any, 0); _remote = sender; EndPoint point = new IPEndPoint(IPAddress.Parse(remoteIp), int.Parse(remotePort)); ret.SendTo(new byte[] { 1, 2, 3 }, point); //发送一帧数据才能收到数据 return ret; } private void ProcessUdpData() { while (true) { var data = new byte[DataMaximumLength]; //发送接受信息 var recv = _udpSocket.ReceiveFrom(data, ref _remote); _recorder.RecordBytes(data, 0, recv); //记录数据 var cell = new AzimuthCell(data); NotifyAllObservers(cell); //发送通知 } } 如果不写ret.SendTo(new byte[] { 1, 2, 3 }, point); 就收不到数据。 二:socket接收和发送数据我都是用线程发送,一个while(true)循环,反复sendto发缓存区,反复recvfrom,但是这样两个线程的占用率很高,有没有其他办法收发数据,除了beginsendto和beginrecvfrom

androidSocket通信TCP接收数据问题

rivate Button send; private TextView rec; private static Socket client; private PrintWriter write; @Override protected void onCreate(Bundle savedInstanceState) { super.onCreate(savedInstanceState); setContentView(R.layout.activity_main); rec=(TextView)findViewById(R.id.textView3);; Thread aa=new Thread(new Runnable() { @Override public void run() { // TODO Auto-generated method stub try { //服务器的ip的地址 和端口号 client=new Socket(InetAddress.getByName("192.168.1.101"),4312); BufferedReader read=new BufferedReader (new InputStreamReader(client .getInputStream())); rec.setText("123"); String s = ""; while(true){ s=read.readLine(); rec.setText(s); } } catch(IOException e){ rec.setText("123123"); } } }); aa.start(); } 在 while(true){ s=read.readLine(); rec.setText(s); }为什么只能接收服务器的一次消息第二次手机就会跳出程序

java nio socket 异步接收数据

nio socket 异步接收数据,如何确定收接的数据,就是发送的返回的?有谁研究过没。

C# socket networkstream 接收数据

最近在做c/s,客户端用C#的Socket进行通信。接收数据开单独的接收线程使用networkstream进行接收 接收的方法大体上跟网上流传的一样 do { int readSize = mNetworkstream.Read(bytes, 0, 1024); if (readSize > 0) { //do sth } }while(mNetworkstream.DataAvailable) 这样接收局内网或者单机没问题,但是放到外网测试网络不稳定就接收不全。 搜集很多资料,也试过在发送Socket包之前加个包大小,然后在while中增加判断是否读到包的大小,可是一样接不全,中间好像掺杂了一些没用的数据? 我一个包很容易超过byte[10240],而且要整个包接收完才能处理数据。 请问C# Socket使用networkstream怎样才能接收完全呢? ps:也有听说过异步networkstream.beginread接收。鉴于网上一大抄,各种人贴各种代码片段根本就没用。有些有用但只能接收一次。。。 如果有beginread相关代码也希望大牛们贴出来参考一下,不要贴代码片段。。。 谢谢了~

往socket发送大量数据,接收方无法读取到完整数据

大家有没有遇到一种情况,客户端往服务器的socket发送了一个很大的数据(3万+byte),在服务器那边read socket的时候没有读到所有的数据,服务器用while去读但是都无法读到客户端发过来的所有数据,读取socket fd的代码如图 ![图片说明](https://img-ask.csdn.net/upload/201504/26/1430034961_507939.png)

JAVA使用socket发送数据,服务端接收到的数据总是不一致,不明白哪里错了,请大神指点!

客户端: package test; import java.io.ByteArrayOutputStream; import java.io.OutputStream; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; import java.security.PublicKey; public class SocketClient { public static byte[] varout = "987654321hijklmn".getBytes() ; public static byte[] varout1 = {'1','2','3','4','5','6','7','8','9'} ; public static byte[] varout2 = {'a','b','c','d','e','f','g'} ; public static void main(String[] args) { Socket socket = null; try { socket = new Socket("127.0.0.1", 8000); socket.setSoTimeout(100000); OutputStream out1 = socket.getOutputStream(); out1.write(varout); out1.write(varout1); out1.write(varout2); out1.flush(); out1.close(); } catch (Exception e){ e.printStackTrace(); } finally { try{ socket.close(); } catch (Exception e){ e.printStackTrace(); } } } } 服务端: package test; import java.io.InputStream; import java.io.InputStreamReader; import java.net.Socket; import java.net.ServerSocket; public class SocketServer { public static void main(String[] args) { try { ServerSocket serverSocket2 = new ServerSocket(8000); while(true){ Socket s2 = serverSocket2.accept(); InputStream in = s2.getInputStream(); s2.setSoTimeout(10000); //使用InputStream.read(var1)接收数据 byte[] var1 = new byte[10000]; while(in.read(var1) !=-1){ System.out.println(in.read(var1)); System.out.println(new String(var1)); } System.out.println("结束:"+new String(var1)); } } catch (Exception e){ e.printStackTrace(); } } } 服务端接收的结果: ![图片说明](https://img-ask.csdn.net/upload/202002/21/1582283115_195272.jpg)

Java socket 接收数据包解析问题

我想实现的效果是,第一次接收4个字节,然后判断是否为包头,如果是包头就进行下一步,但是在限制字节,byte[] tmpHead = new byte[4]还有判断包头的时候总出错。初学者,基础不扎实,请大佬赐教。 ``` DataInputStream is =new DataInputStream(socket.getInputStream());//实例化 byte[] tmpHead = new byte[4];//接收包头 is.read(tmpHead);//将拿到的值给tmpHead if(is.read(tmpHead) != 0){ toastMsg("收到了"); }else { toastMsg("没有"); } if ((tmpHead[0] == 0x7E) && (tmpHead[1] == 0x81) && (tmpHead[2] == 0x18) && (tmpHead[3] == 0xE7)) {//判断包头 toastMsg("头验证"); byte[] tmpRest = new byte[44];//接收后续数据 is.read(tmpRest);//将拿到的值给tmpRest byte[] Head = new byte[tmpHead.length + tmpRest.length];//拼接完整包头 System.arraycopy(tmpHead, 0, Head, 0, tmpHead.length);//合并数组 System.arraycopy(tmpRest, 0, Head, tmpHead.length, tmpRest.length);//合并数组 struct.InfoHead mInfoHead = new struct.InfoHead();//JavaStruct 对象实例化 JavaStruct.unpack(mInfoHead, Head);//unpack解包 byte[] Data = new byte[mInfoHead.dataLen];//拿到Struct包中datalen,获取下段字节长度 is.read(Data);//将拿到的值给Data byte[] Tail = new byte[8];//包尾长度8字节 is.read(Tail);//将获取的数据给Tail struct.Tail mTail = new struct.Tail();//实例化Tail JavaStruct.unpack(mTail, Tail);//解包 if (mTail.packTail == 0x8F9009F8) {//判断包尾是否正确 System.out.print(mInfoHead.packHead); System.out.print(mTail.packTail); } } else { toastMsg("数据错误"); } } catch (Exception e) { e.printStackTrace(); } } }).start(); ```

Socket编程,为什么客户端无法接收来自服务器的数据?

如题,我写了段Socket服务器\客户端通讯的程序,服务端能接收到客户端的数据,但是客户端就无法接收到服务端传回的数据,代码如下 Server端 [code="java"] import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.ServerSocket; import java.net.Socket; /** * @author Think * */ public class SocketServer { /** * @param args */ public static void main(String[] args) { new SocketServer().start(); } public void start(){ try { ServerSocket server = new ServerSocket(10086); while(true){ System.out.println("Waiting for a client..."); Socket client = server.accept(); new SocketServerThread(client).start(); } } catch (IOException e) { e.printStackTrace(); } } class SocketServerThread extends Thread{ Socket client = null; public SocketServerThread(Socket client){ this.client = client; } @Override public void run(){ try { // 得到CLIENT的输入流,从输入流出取出传输的数据 BufferedReader reader_from_client = new BufferedReader(new InputStreamReader(client.getInputStream())); String line = null; System.out.print("from client message:"); while((line = reader_from_client.readLine()) != null){ System.out.println(line); } // 得到CLIENT端的输入流,通过向CLIENT传输数据 PrintWriter writer_to_client = new PrintWriter(client.getOutputStream()); writer_to_client.println("Ok"); writer_to_client.flush(); reader_from_client.close(); writer_to_client.close(); client.close(); } catch (IOException e) { } } } } [/code] Client [code="java"]import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.io.PrintWriter; import java.net.InetAddress; import java.net.Socket; /** * @author Think * */ public class SocketClient { /** * @param args */ public static void main(String[] args) { try { Socket remoteServer = new Socket(InetAddress.getLocalHost(), 10086); // 得到SERVER端SOCKET的输出流,通过向输出流写入数据,与SERVER进行通信 PrintWriter write_to_server = new PrintWriter(remoteServer.getOutputStream(), true); write_to_server.write("Hello, what's you name?"); write_to_server.flush(); // 把下面这几行放开,SERVER端就收不到数据了,一直处于阻塞状态 // 得到SERVER端的输出流,从输出流中读取从SERVER传递来的数据 // BufferedReader reader_from_server = new BufferedReader(new InputStreamReader(remoteServer.getInputStream())); // String line = null; // while((line = reader_from_server.readLine()) != null){ // System.out.println(line); // } // reader_from_server.close(); write_to_server.close(); remoteServer.close(); } catch (IOException e) { e.printStackTrace(); } } }[/code] 如果Client中的说明,只要是Client中放开了 [code="java"] BufferedReader reader_from_server = new BufferedReader(new InputStreamReader(remoteServer.getInputStream())); String line = null; while((line = reader_from_server.readLine()) != null){ System.out.println(line); } reader_from_server.close(); [/code] 这段代码,SERVER就阻塞在 [code="java"] while((line = reader_from_client.readLine()) != null){ [/code] 这行,不知道是哪个环节理解或处理错了,还望大家指点指点!

在中国程序员是青春饭吗?

今年,我也32了 ,为了不给大家误导,咨询了猎头、圈内好友,以及年过35岁的几位老程序员……舍了老脸去揭人家伤疤……希望能给大家以帮助,记得帮我点赞哦。 目录: 你以为的人生 一次又一次的伤害 猎头界的真相 如何应对互联网行业的「中年危机」 一、你以为的人生 刚入行时,拿着傲人的工资,想着好好干,以为我们的人生是这样的: 等真到了那一天,你会发现,你的人生很可能是这样的: ...

程序员请照顾好自己,周末病魔差点一套带走我。

程序员在一个周末的时间,得了重病,差点当场去世,还好及时挽救回来了。

Java基础知识面试题(2020最新版)

文章目录Java概述何为编程什么是Javajdk1.5之后的三大版本JVM、JRE和JDK的关系什么是跨平台性?原理是什么Java语言有哪些特点什么是字节码?采用字节码的最大好处是什么什么是Java程序的主类?应用程序和小程序的主类有何不同?Java应用程序与小程序之间有那些差别?Java和C++的区别Oracle JDK 和 OpenJDK 的对比基础语法数据类型Java有哪些数据类型switc...

技术大佬:我去,你写的 switch 语句也太老土了吧

昨天早上通过远程的方式 review 了两名新来同事的代码,大部分代码都写得很漂亮,严谨的同时注释也很到位,这令我非常满意。但当我看到他们当中有一个人写的 switch 语句时,还是忍不住破口大骂:“我擦,小王,你丫写的 switch 语句也太老土了吧!” 来看看小王写的代码吧,看完不要骂我装逼啊。 private static String createPlayer(PlayerTypes p...

和黑客斗争的 6 天!

互联网公司工作,很难避免不和黑客们打交道,我呆过的两家互联网公司,几乎每月每天每分钟都有黑客在公司网站上扫描。有的是寻找 Sql 注入的缺口,有的是寻找线上服务器可能存在的漏洞,大部分都...

Intellij IDEA 实用插件安利

1. 前言从2020 年 JVM 生态报告解读 可以看出Intellij IDEA 目前已经稳坐 Java IDE 头把交椅。而且统计得出付费用户已经超过了八成(国外统计)。IDEA 的...

女程序员,为什么比男程序员少???

昨天看到一档综艺节目,讨论了两个话题:(1)中国学生的数学成绩,平均下来看,会比国外好?为什么?(2)男生的数学成绩,平均下来看,会比女生好?为什么?同时,我又联想到了一个技术圈经常讨...

总结了 150 余个神奇网站,你不来瞅瞅吗?

原博客再更新,可能就没了,之后将持续更新本篇博客。

副业收入是我做程序媛的3倍,工作外的B面人生是怎样的?

提到“程序员”,多数人脑海里首先想到的大约是:为人木讷、薪水超高、工作枯燥…… 然而,当离开工作岗位,撕去层层标签,脱下“程序员”这身外套,有的人生动又有趣,马上展现出了完全不同的A/B面人生! 不论是简单的爱好,还是正经的副业,他们都干得同样出色。偶尔,还能和程序员的特质结合,产生奇妙的“化学反应”。 @Charlotte:平日素颜示人,周末美妆博主 大家都以为程序媛也个个不修边幅,但我们也许...

MySQL数据库面试题(2020最新版)

文章目录数据库基础知识为什么要使用数据库什么是SQL?什么是MySQL?数据库三大范式是什么mysql有关权限的表都有哪几个MySQL的binlog有有几种录入格式?分别有什么区别?数据类型mysql有哪些数据类型引擎MySQL存储引擎MyISAM与InnoDB区别MyISAM索引与InnoDB索引的区别?InnoDB引擎的4大特性存储引擎选择索引什么是索引?索引有哪些优缺点?索引使用场景(重点)...

如果你是老板,你会不会踢了这样的员工?

有个好朋友ZS,是技术总监,昨天问我:“有一个老下属,跟了我很多年,做事勤勤恳恳,主动性也很好。但随着公司的发展,他的进步速度,跟不上团队的步伐了,有点...

我入职阿里后,才知道原来简历这么写

私下里,有不少读者问我:“二哥,如何才能写出一份专业的技术简历呢?我总感觉自己写的简历太烂了,所以投了无数份,都石沉大海了。”说实话,我自己好多年没有写过简历了,但我认识的一个同行,他在阿里,给我说了一些他当年写简历的方法论,我感觉太牛逼了,实在是忍不住,就分享了出来,希望能够帮助到你。 01、简历的本质 作为简历的撰写者,你必须要搞清楚一点,简历的本质是什么,它就是为了来销售你的价值主张的。往深...

魂迁光刻,梦绕芯片,中芯国际终获ASML大型光刻机

据羊城晚报报道,近日中芯国际从荷兰进口的一台大型光刻机,顺利通过深圳出口加工区场站两道闸口进入厂区,中芯国际发表公告称该光刻机并非此前盛传的EUV光刻机,主要用于企业复工复产后的生产线扩容。 我们知道EUV主要用于7nm及以下制程的芯片制造,光刻机作为集成电路制造中最关键的设备,对芯片制作工艺有着决定性的影响,被誉为“超精密制造技术皇冠上的明珠”,根据之前中芯国际的公报,目...

优雅的替换if-else语句

场景 日常开发,if-else语句写的不少吧??当逻辑分支非常多的时候,if-else套了一层又一层,虽然业务功能倒是实现了,但是看起来是真的很不优雅,尤其是对于我这种有强迫症的程序"猿",看到这么多if-else,脑袋瓜子就嗡嗡的,总想着解锁新姿势:干掉过多的if-else!!!本文将介绍三板斧手段: 优先判断条件,条件不满足的,逻辑及时中断返回; 采用策略模式+工厂模式; 结合注解,锦...

离职半年了,老东家又发 offer,回不回?

有小伙伴问松哥这个问题,他在上海某公司,在离职了几个月后,前公司的领导联系到他,希望他能够返聘回去,他很纠结要不要回去? 俗话说好马不吃回头草,但是这个小伙伴既然感到纠结了,我觉得至少说明了两个问题:1.曾经的公司还不错;2.现在的日子也不是很如意。否则应该就不会纠结了。 老实说,松哥之前也有过类似的经历,今天就来和小伙伴们聊聊回头草到底吃不吃。 首先一个基本观点,就是离职了也没必要和老东家弄的苦...

2020阿里全球数学大赛:3万名高手、4道题、2天2夜未交卷

阿里巴巴全球数学竞赛( Alibaba Global Mathematics Competition)由马云发起,由中国科学技术协会、阿里巴巴基金会、阿里巴巴达摩院共同举办。大赛不设报名门槛,全世界爱好数学的人都可参与,不论是否出身数学专业、是否投身数学研究。 2020年阿里巴巴达摩院邀请北京大学、剑桥大学、浙江大学等高校的顶尖数学教师组建了出题组。中科院院士、美国艺术与科学院院士、北京国际数学...

为什么你不想学习?只想玩?人是如何一步一步废掉的

不知道是不是只有我这样子,还是你们也有过类似的经历。 上学的时候总有很多光辉历史,学年名列前茅,或者单科目大佬,但是虽然慢慢地长大了,你开始懈怠了,开始废掉了。。。 什么?你说不知道具体的情况是怎么样的? 我来告诉你: 你常常潜意识里或者心理觉得,自己真正的生活或者奋斗还没有开始。总是幻想着自己还拥有大把时间,还有无限的可能,自己还能逆风翻盘,只不是自己还没开始罢了,自己以后肯定会变得特别厉害...

男生更看重女生的身材脸蛋,还是思想?

往往,我们看不进去大段大段的逻辑。深刻的哲理,往往短而精悍,一阵见血。问:产品经理挺漂亮的,有点心动,但不知道合不合得来。男生更看重女生的身材脸蛋,还是...

为什么程序员做外包会被瞧不起?

二哥,有个事想询问下您的意见,您觉得应届生值得去外包吗?公司虽然挺大的,中xx,但待遇感觉挺低,马上要报到,挺纠结的。

当HR压你价,说你只值7K,你该怎么回答?

当HR压你价,说你只值7K时,你可以流畅地回答,记住,是流畅,不能犹豫。 礼貌地说:“7K是吗?了解了。嗯~其实我对贵司的面试官印象很好。只不过,现在我的手头上已经有一份11K的offer。来面试,主要也是自己对贵司挺有兴趣的,所以过来看看……”(未完) 这段话主要是陪HR互诈的同时,从公司兴趣,公司职员印象上,都给予对方正面的肯定,既能提升HR的好感度,又能让谈判气氛融洽,为后面的发挥留足空间。...

面试:第十六章:Java中级开发

HashMap底层实现原理,红黑树,B+树,B树的结构原理 Spring的AOP和IOC是什么?它们常见的使用场景有哪些?Spring事务,事务的属性,传播行为,数据库隔离级别 Spring和SpringMVC,MyBatis以及SpringBoot的注解分别有哪些?SpringMVC的工作原理,SpringBoot框架的优点,MyBatis框架的优点 SpringCould组件有哪些,他们...

面试阿里p7,被按在地上摩擦,鬼知道我经历了什么?

面试阿里p7被问到的问题(当时我只知道第一个):@Conditional是做什么的?@Conditional多个条件是什么逻辑关系?条件判断在什么时候执...

Python爬虫,高清美图我全都要(彼岸桌面壁纸)

爬取彼岸桌面网站较为简单,用到了requests、lxml、Beautiful Soup4

差点跪了...

最近微信又搞出了一个大利器,甚至都上了热搜,当然消息最敏捷的自媒体人,纷纷都开通了自己的视频号。01 视频号是什么呢?视频号是微信体系内的短视频,它不同...

面试了一个 31 岁程序员,让我有所触动,30岁以上的程序员该何去何从?

最近面试了一个31岁8年经验的程序猿,让我有点感慨,大龄程序猿该何去何从。

Vue回炉重造之router路由(更新中)

你好,我是Vam的金豆之路,可以叫我豆哥。2019年年度博客之星、技术领域博客专家。主要领域:前端开发。我的微信是 maomin9761,有什么疑问可以加我哦,自己创建了一个微信技术交流群,可以加我邀请你一起交流学习。最后自己也创建了一个微信公众号,里面的文章是我自己精挑细选的文章,主要介绍各种IT新技术。欢迎关注哦,微信搜索:臻美IT,等你来。 欢迎阅读本博文,本博文主要讲述【】,文字通...

大三实习生,字节跳动面经分享,已拿Offer

说实话,自己的算法,我一个不会,太难了吧

程序员垃圾简历长什么样?

已经连续五年参加大厂校招、社招的技术面试工作,简历看的不下于万份 这篇文章会用实例告诉你,什么是差的程序员简历! 疫情快要结束了,各个公司也都开始春招了,作为即将红遍大江南北的新晋UP主,那当然要为小伙伴们做点事(手动狗头)。 就在公众号里公开征简历,义务帮大家看,并一一点评。《启舰:春招在即,义务帮大家看看简历吧》 一石激起千层浪,三天收到两百多封简历。 花光了两个星期的所有空闲时...

Java岗开发3年,公司临时抽查算法,离职后这几题我记一辈子

前几天我们公司做了一件蠢事,非常非常愚蠢的事情。我原以为从学校出来之后,除了找工作有测试外,不会有任何与考试有关的事儿。 但是,天有不测风云,公司技术总监、人事总监两位大佬突然降临到我们事业线,叫上我老大,给我们组织了一场别开生面的“考试”。 那是一个风和日丽的下午,我翘着二郎腿,左手端着一杯卡布奇诺,右手抓着我的罗技鼠标,滚动着轮轴,穿梭在头条热点之间。 “淡黄的长裙~蓬松的头发...

大胆预测下未来5年的Web开发

在2019年的ReactiveConf 上,《Elm in Action》的作者Richard Feldman对未来5年Web开发的发展做了预测,很有意思,分享给大家。如果你有机会从头...

立即提问
相关内容推荐