java中能接受其他通信实体链接请求的类是serversocket，serversocket对象用于监听来自客户端的socket链接，如果没有链接，它将一直等待。如果接收到一个客户端socket的连接请求，serversocket的accept()方法将返回一个与客户端socket对应的socket（每个tcp连接有两个socket），否则该方法将一直阻塞，线程也被阻塞。
服务端思路：服务端应该包含多个线程，每个socket对应一个线程，这个线程负责读取该socket对应输入流的数据（从客户端发送过来的数据），并将读到的数据向每个socket输出流发送一次（将一个客户端发送过来的数据“广播”给其他客户端）。
服务端代码：
我要评论
//服务端主类
public class myserver
{
public static list<socket> socketlist = collections.synchronizedlist(new arraylist<socket>());
public static void main(string[] args) throws ioexception
{
serversocket ss = new serversocket(30000);
while (true)
{
//此行代码会阻塞，将一直等待别人的连接
socket s = ss.accept();
socketlist.add(s);
//每当客户端连接后启动一个serverthread线程为该客户端服务
new thread(new serverthread(s)).start();
}
}
}
public class serverthread implements runnable
{
//定义当前线程所处理的socket
socket s = null;
//该线程所处理的socket对应的输入流
bufferedreader br = null;
public serverthread(socket s) throws ioexception
{
this.s = s;
//初始化该socket对应的输入流
br = new bufferedreader(new inputstreamreader(s.getinputstream()));
}
@override
public void run()
{
try
{
string content = null;
//采用循环不断地从socket中读取客户端发送来的数据
while ((content = readfromclient()) != null)
{
//遍历socketlist中的每个socket
//将读到的内容向每个socket发送一次
for (socket s : myserver.socketlist)
{
printstream ps = new printstream(s.getoutputstream());
ps.println(content);
}
}
}
catch (ioexception e)
{
e.printstacktrace();
}
}
//定义读取客户端数据的方法
private string readfromclient()
{
try
{
return br.readline();
}
//如果捕获到异常，则表明该socket对应的客户端已经关闭
catch (ioexception e)
{
//删除该socket
myserver.socketlist.remove(s);
}
return null;
}
}
客户端思路：将用户输入的数据写入socket对应的输入流中；开启一个子线程读取socket对应输入流中的数据（从服务端发送过来的数据），并通过handler将读取的数据发送到主线程来更新ui。
//用户界面activity
public class mainactivity extends activity
{
private edittext mreceivermsg;
private button msendbtn;
private edittext msendmsg;
handler handler = new handler()
{
@override
public void handlemessage(message msg)
{
log.d("mainactivity" , "okk");
mreceivermsg.append(msg.obj.tostring());
}
};
private socket s;
@override
protected void oncreate(bundle savedinstancestate)
{
super.oncreate(savedinstancestate);
setcontentview(r.layout.main_activity);
initview();
initsocket();
msendbtn.setonclicklistener(new view.onclicklistener()
{
@override
public void onclick(view view)
{
senddata();
}
});
}
private void initsocket()
{
new thread()
{
@override
public void run()
{
try
{
s = new socket("192.168.1.101" , 30000);
new thread(new clientthread(s , handler)).start();
}
catch (ioexception e)
{
e.printstacktrace();
}
}
}.start();
}
private void initview()
{
mreceivermsg = (edittext) findviewbyid(r.id.receiver_message);
msendmsg = (edittext) findviewbyid(r.id.send_message);
msendbtn = (button) findviewbyid(r.id.send_button);
}
private void senddata()
{
try
{
//获取该socket对应的输出流
printstream ps = new printstream(s.getoutputstream());
if (textutils.isempty(msendmsg.gettext()))
{
toast.maketext(this , "请输入信息" , toast.length_long).show();
return;
}
ps.println(msendmsg.gettext().tostring());
}
catch (ioexception e)
{
e.printstacktrace();
}
}
}
public class clientthread implements runnable
{
//该线程负责处理的socket
private socket ss;
//该线程所处理的socket对应的输入流
bufferedreader br = null;
handler handler;
public clientthread(socket s , handler handler) throws ioexception
{
this.ss = s;
this.handler = handler;
br = new bufferedreader(new inputstreamreader(ss.getinputstream()));
}
@override
public void run()
{
try
{
string content = null;
while ((content = br.readline()) != null)
{
message msg = new message();
msg.obj = content;
handler.sendmessage(msg);
}
}
catch (ioexception e)
{
e.printstacktrace();
}
}
}
先运行上面程序中的myserver类，该类运行只是作为服务端。再启动多个模拟器，运行安装客户端的程序作为多个客户端，然后可以再任何一个客户端通过edit输入一些内容，点击发送就可以在任何一个客户端看到刚刚输入的内容。
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持移动技术网。
如对本文有疑问， 点击进行留言回复！！
网友评论