java socket多线程的问题?可以多个线程使用同一个socket吗?

java socket多线程的问题?可以多个线程使用同一个socket吗?,第1张

可以写个demo试一下啊,应该是可以的,socket接收到的消息只能被其中一个线程接收。线程1 和2 接受到的肯定不是同一个消息。会有先后之分。看你怎么控制。比如从接收的消息是ABCD,那么这相当于一个资源。线程1和2在这里拿消息,拿到之后,socket里面就少了,比如线程1拿到AB,线程2拿到CD

我以前写过类似的socket通信,虽然你用的方法和我的不太一样,但我还是感觉有一些问题
接受消息的时候,你用的是while(true)循环,当第一次将消息接受后,缓冲区就为空了,我想你再用循环去接收应该会出问题。
我记得有个poll方法,具体什么用途忘记了(很久没写代码了)你在循环里面加个if (clientsocketPoll(1000, SelectModeSelectRead))判断语句“clientsocket为你需要接收消息的socket”看看能不能解决,或者就用异步也可以,我可以发一下我以前的代码你参考下:
using System;
using SystemCollectionsGeneric;
using SystemComponentModel;
using SystemData;
using SystemDrawing;
using SystemText;
using SystemWindowsForms;
using SystemNet;
using SystemNetSockets;
using SystemThreading;
namespace test4_2
{
public partial class Form1 : Form
{
Socket connectSocket;
//Socket client;
byte[] bytes = new byte[1024];
delegate void listboxDel(string s);
listboxDel listboxdel;
public Form1()
{
InitializeComponent();
textBoxContentFocus();
listboxdel = new listboxDel(listbox);
//为连接指派线程
Thread threadConnect = new Thread(new ThreadStart(Connect));
threadConnectStart();

}
public void listbox(string str)
{
listBox1ItemsAdd(str);
listBox1SelectedIndex = listBox1ItemsCount - 1;
listBox1ClearSelected();
}
//连接方法
public void Connect()
{
try
{
//建立连接socket
connectSocket = new Socket(AddressFamilyInterNetwork,SocketTypeStream,ProtocolTypeTcp);
//开始异步连接
connectSocketBeginConnect(IPAddressParse("1721694152"),
82,
new AsyncCallback(ConnectCallback), //定义回调函数代理
connectSocket); //传递给回调函数的状态
}
catch (Exception e)
{
MessageBoxShow(eMessage);
}
}
//连接方法的回调函数
private void ConnectCallback(IAsyncResult ar)
{
try
{
//从传递的状态中获取套接字,创建一个客户端套接字
Socket client = (Socket)arAsyncState;
//完成挂起的连接 *** 作
clientEndConnect(ar);
listBox1Invoke(listboxdel, "连接服务器成功,可以开始通话!");
clientBeginReceive(bytes, 0, 1000, 0, new AsyncCallback(receivecallback), client);
}
catch (Exception e)
{
ConsoleWriteLine(eToString());
}
}
public void receivecallback(IAsyncResult ar)
{
try
{
Socket client = (Socket)arAsyncState;
int length = clientEndReceive(ar);
listBox1Invoke(listboxdel, EncodingUTF8GetString(bytes, 0, length));
clientBeginReceive(bytes, 0, 1000, 0, new AsyncCallback(receivecallback), client);
}
catch
{
}
}
//发送方法
private void Send(String data)
{
//使用ASCII转换字符串为字节序列
byte[] byteData = EncodingUTF8GetBytes(data); //将字符串转换成字节序列
//开始向远端设备发送数据
connectSocketBeginSend(byteData, 0, byteDataLength, SocketFlagsNone,
new AsyncCallback(SendCallback), connectSocket);
}
//发送方法的回调函数
private void SendCallback(IAsyncResult ar)
{
try
{
//从传递的状态中获取套接字,创建一个客户端套接字
Socket client = (Socket)arAsyncState;
//结束异步数据传输 *** 作,返回传输的字节数
int bytesSent = clientEndSend(ar);
listBox1Invoke(listboxdel, textBoxUserText +":"+ textBoxContentText);

}
catch (Exception e)
{
MessageBoxShow(eToString());
}
}
private void buttonSend_Click(object sender, EventArgs e)
{
Send(textBoxUserText+":"+textBoxContentText);

}
}
}

是这样的,多线程技术一般是应用在客户端-服务器的模型中,这个服务器是固定的,但是可以有多个客户端同时连接服务器(这里,多个客户端体现在IP或是源端口的不同),多线程就体现在服务器可以同时派发多个线程,去服务每个客户。你说的这种情况,用多线程来实现是可以的,只不过是同一个IP不同的源端口建立的socket而已,可以建立多个socket连接。


欢迎分享,转载请注明来源:内存溢出

原文地址:https://54852.com/zz/12613308.html

(0)
打赏 微信扫一扫微信扫一扫 支付宝扫一扫支付宝扫一扫
上一篇 2025-08-26
下一篇2025-08-26

发表评论

登录后才能评论

评论列表(0条)

    保存