java socket服务器怎么给客户端发信息

java socket服务器怎么给客户端发信息,第1张

服务器端和客户端都是通过SOCKET来进行通信的,首先产生一个
socket实例,通过这个实例,服务器端调用accept这个方法接收来自客户端发送的信息但是在产生socket实例的时候必须初始化一个端口用来负责接受客户端的请求!
客户端要给服务器发送消息也必须产生一个socket实例,初始化的时候必须指定服务器的IP地址,并且指定服务接收的端口号,这样客户端才能找到服务器要接收的地方,找到地方就可以发送过去了。和你写信一样。找到地址
BufferedReader
in
=
new
BufferedReader(new
InputStreamReader(socketgetInputStream()));
PrintWriter
out
=
new
PrintWriter(socketgetOutputStream());
BufferedReader
wt
=
new
BufferedReader(new
InputStreamReader(Systemin));
这个只是用来获取一个从键盘的一个流传送给服务器端的数据都是通过流来表示的。意思是是键盘输入的一个字节转化成字符流并输出或者写入!

package Server;
import javaio;
import javanet;
import messageMessageType;
//该线程用于和客服端进行通信,是一个线程类
public class ServerClientComunicationThread extends Thread{
Socket s=null;
ObjectInputStream ois=null;
MessageType mt=null;
ObjectOutputStream oos=null;
public ServerClientComunicationThread(Socket s){
thiss=s;
}
public void run(){
//不停地从socket里面读取数据
while(true){
try {
ois=new ObjectInputStream(sgetInputStream());
mt=(MessageType)oisreadObject();
Systemoutprintln("服务器读取到的信息");
Systemoutprintln(mtgetContent()+" "+mtgetGetter()+" "+
mtgetMessagetype()+mtgetSendTime());
//将读取到的数据转发给对应的客服端
Systemoutprintln("从集合里面可以找到用户压迫将数据发送给"+ ManageOnlineUserhmget(mtgetGetter()));
oos=new ObjectOutputStream(( ManageOnlineUserhmget(mtgetGetter()))getOutputStream());
ooswriteObject(mt);
} catch (Exception e) {
eprintStackTrace();
}
}
}
}

你服务器accept方法后是不是会得到一个Socket
为这个Socket(是通过这个Socket和客户端的Socket进行沟通)分配一个服务
我是这么用的ServerThread tt=new ServerThread(socket);

class ServerThread
{
private Socket so;
    public ServerThread(Socket s)
    {
        thisso=s;
    }
public void send()
{
}
public void receive()
{
    Thread re=new Thread()
        {
            public void run()
            {
               }
        }
}
}


相当于你用手机拨打人工服务,会给你分配一个客服
为这个Socket分配后,写一个发送方法,和一个接收方法(线程)
然后把ServerThread tt=new ServerThread(socket);中的tt保存到集合中去,要单独给某个发送
就从集合中取出来send();这个方法应该带个参数,把消息对象传过去就是

你这消息头、消息体的结构格式都定下来了,总长度就是固定的啊?消息体的长度不是一共2+2+4+1=9个字节么?消息格式肯定要按照服务端的要求进行发送,明显服务端不是java的程序。。但是java里是没有Unsigned Integer这种数据类型的(java的stream *** 作里提供了一些unsigned的方法,或者自己写方法来生成对应的字节格式),你可以按照他的要求,使用字节数组封装好,然后发送。
针对这个示例消息,你可以:
创建一个长度为9的字节数组。把“9”变成byte放入前两个字节(前两个字节数据应该为:0x00, 0x09。这是第一个字段,长度),后面的字段数据以此类推。一个字段一个字段处理成服务器要求的格式。
然后把字节流发送给服务端。

主要介绍其中的五种实现方式:短轮询、Comet、Flash XMLSocket、Server-sent、WebSocket
1、短轮询
指在特定的的时间间隔(如每10秒),由浏览器对服务器发出>当然能
server端:
记录所有当前聊天室的在线人的socket
开启一个线程,通过记录的socket集合向每个socket中写数据
client端:
启动就开始一个线程,进行循环监听读取server发送的数据
好像就是这样了,怎么感觉简单了点,
就这样吧,有什么问题在说


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

原文地址: http://outofmemory.cn/zz/10278739.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-05-07
下一篇 2023-05-07

发表评论

登录后才能评论

评论列表(0条)

保存