javasocket推送

❶ java SOCKET传送数据

可以这样哈，数据结构：
|--时间（50个字节）--||--上午数据长度(固定用8个字节)--||--上午数据--||--中午数据长度--||--中午数据--||--下午数据长度--||--下午数据--|

然后读取的时候先读50个字节的内容，然后把它转为字符串得到的就是时间，然后读8个字节的内容，把读到的内容转为数字就是上午的数据的总长度，假如是n，则继续读n个字节内容，转为字符串就是上午数据，然后继续读8个字节，转为数字……
以上只是一种数据结构，还可以有很多，你可以根据自己的实际情况来决定各个字节的长度。

再说写入的情况，把所有的字符串转化成固定长度的byte数组然后直接写入就行了。
byte[] time=new byte[10];
String stime="2009-10-31 12:00:00";
byte[] temp=stime.getByte();
for(int i=0;i<temp.length;i++){
time[i]=temp[i];
}
然后写入time，等到把所有数据写入完毕统一刷新

❷ socket如何单独推送消息

Socket又称"套接字"，应用程序通常通过"套接字"向网络发出请求或者应答网络请求。Socket的英文原义是“孔”或“插座”，作为UNIX的进程通信机制。Socket可以实现应用程序间网络通信。
消息推送：
轮询：客户端定时向服务器发送Ajax请求，服务器接到请求后马上返回响应信息并关闭连接。
长轮询：客户端向服务器发送Ajax请求，服务器接到请求后hold住连接，直到有新消息才返回响应信息并关闭连接，客户端处理完响应信息后再向服务器发送新的请求。 ?优点：在无消息的情况下不会频繁的请求，耗费资小。
长连接：在页面里嵌入一个隐蔵iframe，将这个隐蔵iframe的src属性设为对一个长连接的请求或是采用xhr请求，服务器端就能源源不断地往客户端输入数据。
Flash Socket：在页面中内嵌入一个使用了Socket类的 Flash 程序JavaScript通过调用此Flash程序提供的Socket接口与服务器端的Socket接口进行通信，JavaScript在收到服务器端传送的信息后控制页面的显示。 Websocket:
WebSocket是HTML5开始提供的一种浏览器与服务器间进行全双工通讯的网络技术。依靠这种技术可以实现客户端和服务器端的长连接，双向实时通信。
消息推送功能可以说移动APP不可缺少的功能之一，一般简单的推送可以使用第三方推送的SDK，比如极光推送。极光是中国领先的移动大数据服务商。本公司自2011年成立以来专注于为app开发者提供稳定高效的消息推送、统计分析、即时通讯和短信等开发者服务。

❸ java socket 怎么给websocket发信息

1.InitServlet

该类主要是用来初始化构造将来存储用户身份信息的map仓库，利用其初始化方法Init 初始化仓库， 利用其静态方法getSocketList 获得对应的用户身份信息。

webSocket ，我认为MessageInbound 用来识别登录人的信息，用它来找到对应的人，推送消息。每次登录都会产生一个MessageInbound。

这里的HashMap<String,MessageInbound> ：string 存储用户session的登录id,MessageInbound存储 推送需要的身份信息。以上属于个人口头话理解。

packagesocket;

importjava.nio.CharBuffer;
importjava.util.ArrayList;
importjava.util.HashMap;
importjava.util.List;

importjavax.servlet.ServletConfig;
importjavax.servlet.ServletException;
importjavax.servlet.http.HttpServlet;

importorg.apache.catalina.websocket.MessageInbound;

{

=-3163557381361759907L;

//privatestaticList<MessageInbound>socketList;
privatestaticHashMap<String,MessageInbound>socketList;

publicvoidinit(ServletConfigconfig)throwsServletException{
//InitServlet.socketList=newArrayList<MessageInbound>();
InitServlet.socketList=newHashMap<String,MessageInbound>();
super.init(config);
System.out.println("Serverstart============");
}

publicstaticHashMap<String,MessageInbound>getSocketList(){
returnInitServlet.socketList;
}
/*publicstaticList<MessageInbound>getSocketList(){
returnInitServlet.socketList;
}
*/}

2.MyWebSocketServlet

websocket用来建立连接的servlet，建立连接时，首先在session获取该登录人的userId，在调用MyMessageInbound构造函数传入userId

packagesocket;

importjava.io.IOException;
importjava.io.PrintWriter;
importjava.nio.CharBuffer;

importjavax.servlet.ServletException;
importjavax.servlet.http.HttpServlet;
importjavax.servlet.http.HttpServletRequest;
importjavax.servlet.http.HttpServletResponse;

importorg.apache.catalina.websocket.StreamInbound;
importorg.apache.catalina.websocket.WebSocketServlet;
/**
*
*@ClassName:MyWebSocketServlet
*@Description:建立连接时创立
*@authormangues
*@date2015-7-19
*/
{

publicStringgetUser(HttpServletRequestrequest){
StringuserName=(String)request.getSession().getAttribute("user");
if(userName==null){
returnnull;
}
returnuserName;
//return(String)request.getAttribute("user");
}
@Override
(Stringarg0,
HttpServletRequestrequest){
System.out.println("##########");
returnnewMyMessageInbound(this.getUser(request));
}

}

3.onOpen方法调用InitServlet的map身份仓库，

放入用户userId 和 对应该登录用户的websocket身份信息MessageInbound （可以用userId来寻找到推送需要的 身份MessageInbound）

onTextMessage ：用来获取消息，并发送消息

packagesocket;

importjava.io.IOException;
importjava.nio.ByteBuffer;
importjava.nio.CharBuffer;
importjava.util.HashMap;

importorg.apache.catalina.websocket.MessageInbound;
importorg.apache.catalina.websocket.WsOutbound;

importutil.MessageUtil;

{

privateStringname;
publicMyMessageInbound(){
super();
}

publicMyMessageInbound(Stringname){
super();
this.name=name;
}

@Override
protectedvoidonBinaryMessage(ByteBufferarg0)throwsIOException{
//TODOAuto-generatedmethodstub

}

@Override
protectedvoidonTextMessage(CharBuffermsg)throwsIOException{
//用户所发消息处理后的map
HashMap<String,String>messageMap=MessageUtil.getMessage(msg);//处理消息类
//上线用户集合类map
HashMap<String,MessageInbound>userMsgMap=InitServlet.getSocketList();

StringfromName=messageMap.get("fromName");//消息来自人的userId


StringtoName=messageMap.get("toName");//消息发往人的userId
//获取该用户
MessageInboundmessageInbound=userMsgMap.get(toName);//在仓库中取出发往人的MessageInboundif(messageInbound!=null){//如果发往人存在进行操作
WsOutboundoutbound=messageInbound.getWsOutbound();


Stringcontent=messageMap.get("content");//获取消息内容
StringmsgContentString=fromName+""+content;//构造发送的消息

//发出去内容
CharBuffertoMsg=CharBuffer.wrap(msgContentString.toCharArray());
outbound.writeTextMessage(toMsg);//
outbound.flush();
}/*for(MessageInboundmessageInbound:InitServlet.getSocketList()){
CharBufferbuffer=CharBuffer.wrap(msg);
WsOutboundoutbound=messageInbound.getWsOutbound();
outbound.writeTextMessage(buffer);
outbound.flush();
}*/

}

@Override
protectedvoidonClose(intstatus){
InitServlet.getSocketList().remove(this);
super.onClose(status);
}

@Override
protectedvoidonOpen(WsOutboundoutbound){
super.onOpen(outbound);
//登录的用户注册进去
if(name!=null){
InitServlet.getSocketList().put(name,this);
}
//InitServlet.getSocketList().add(this);
}


}

4.消息处理类，处理前端发来的消息

packageutil;

importjava.nio.CharBuffer;
importjava.util.HashMap;
/**
*
*@ClassName:MessageUtil
*@Description:消息处理类
*@authormangues
*@date2015-7-19
*/
publicclassMessageUtil{

publicstaticHashMap<String,String>getMessage(CharBuffermsg){
HashMap<String,String>map=newHashMap<String,String>();
StringmsgString=msg.toString();
Stringm[]=msgString.split(",");
map.put("fromName",m[0]);
map.put("toName",m[1]);
map.put("content",m[2]);
returnmap;
}
}

❹ 关于 java socket的消息推送问题

关于 java socket的消息推送问题，首先：开启服务端，并暴露出端口。然后通过一个while的死循环去不停的接收来自客户端的socket，并且通过一个ArrayList来维护。并且通过子线程去对list中的socket进行操作。
其次：客户端去访问服务器的端口。开启一个子线程去不停的接收来自服务端的消息。
然而关于推送服务的更多内容，可以通过深圳极光公司了解一下。深圳市和讯华谷信息技术有限公司（极光 Aurora Mobile）成立于2011年，是中国领先的开发者服务提供商，专注于为开发者提供稳定高效的消息推送、一键认证以及流量变现等服务，助力开发者的运营、增长与变现。
同时，极光的行业应用已经拓展至市场洞察、金融风控与商业地理服务，助力各行各业优化决策、提升效率。

❺ Java如何使用socket互相发送对象

getOutputStream(),从连接获取输入流对象。 这个对象可以和BufferedOutputStream，OutputStreamWriter等配合使用； 建立BufferedOutputStream对象 BufferedOutputStream br=new BufferedOutputStream(socket.getOutputStream()); 调用BufferedOutputStream对象的，write向流中写入数据。

❻ java多用户socket通讯，数据返回给指定用户

我觉得你是不是要了解下nio或者netty？
应该会有所帮助…服务端绑定端口监听，每个客户端去连接都是一个socket，服务端使用selector分发客户端请求并处理。
基本使用netty就好了…

❼ 安卓/java用Socket实现类似QQ消息推送，程序在后台运行如何一直保持连接服务器端如何判断是否断开连

QQ消息是 UDP包。 你连接后，不关闭就算连接着，服务端没法判断是否断开连接，
只有客户端 定时发送一个UDP包，表示连接着。

❽ java socket服务器发送信息给指定的客户端，在线等

是tcp还是udp啊？socket连接可以指定ip和端口啊，所以服务端即使有N个socket连接都不怕，知道端口就行了

❾ 如何实现java推送消息到app

主要介绍其中的五种实现方式：短轮询、Comet、Flash XMLSocket、Server-sent、WebSocket
1、短轮询
指在特定的的时间间隔（如每10秒），由浏览器对服务器发出HTTP request，然后由服务器返回最新的数据给客户端的浏览器。浏览器做处理后进行显示。无论后端此时是否有新的消息产生，都会进行响应
2、Comet
包括了长轮询和长连接，长轮询是客户端向服务器发送Ajax请求，服务器接到请求后hold住连接，直到有新消息才返回响应信息并关闭连接，客户端处理完响应信息后再向服务器发送新的请求；长连接是在页面中的iframe发送请求到服务端，服务端hold住请求并不断将需要返回前端的数据封装成调用javascript函数的形式响应到前端，前端不断收到响应并处理
3、Flash XMLSocket
在 HTML 页面中内嵌入一个使用了 XMLSocket 类的 Flash 程序。JavaScript 通过调用此 Flash 程序提供的socket接口与服务器端的socket进行通信。JavaScript 在收到服务器端以 XML 格式传送的信息后可以很容易地控制 HTML 页面的内容显示
4、Server-sent
服务器推指的是HTML5规范中提供的服务端事件EventSource，浏览器在实现了该规范的前提下创建一个EventSource连接后，便可收到服务端的发送的消息，实现一个单向通信。客户端进行监听，并对响应的信息处理显示
5、WebSocket
WebSocket是HTML5下一种新的协议，是基于TCP的应用层协议，只需要一次连接，便可以实现全双工通信，客户端和服务端可以相互主动发送消息。客户端进行监听，并对响应的消息处理显示
针对自己系统的应用场景选择合适的推送方案才是合理的，因此最后简单说一下实现个性化推送的两种方式。第一种很简单，直接使用第三方实现的推送，无需复杂的开发运维，直接可以使用。第二种就是自己封装，可以选择如今较为火热的WebSocket来实现系统的推送。
关于第三方推送平台，极光推送，操作简单，稳定性高，送达率快

❿ java socket技术 客户端实现不发送请求给服务端但是一直接收服务端发来的数据

说点泼冷水的话题
首先确认什么是客户端，什么是服务端。
从用户的角度，可见的、可操作的即是客户端，也就是你这里说的java开发的部分。而不可见的部分就是服务端，也就是你说的C部分。
而从网络开发的角度，发起请求的是客户端，而接收请求的是服务端。这与用户感受有很大区别。
当从java请求C的时候，java是客户端，C 是服务端。而当C主动请求时，则C就变成了客户端，而java 变成了服务端。
所以，从网络开发的角度，java想成为此次通信的服务端，必须长期维护一个端口可用，而C 要访问这个端口。
而java为了能够长期维护一个端口，一般采用socket 方式（其他方式也基本上都是基于socket的），由于java已经封装的很好了，只要new Socket(IP,port) 就可以 获得，同时，由于原来C 是服务器，而如果没有多个服务器同时向java端发送请求的话，基本连线程处理都不需要做的。