java-使用DataOutputStream将消息写入客户端套接字的消息仅在关闭客户端套接字后才发送到服务器套接字,为什么？
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了java-使用DataOutputStream将消息写入客户端套接字的消息仅在关闭客户端套接字后才发送到服务器套接字,为什么？，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含4651字，纯文字阅读大概需要7分钟。
内容图文
我用Java进行了Socket-Client编程.我正在使用DataOutputStream将消息发送到服务器套接字.有时在DataOutputstream上写入的消息没有发送到ServerSocket.我认为是由于发送消息后我没有刷新.我这样做但没有用.如果我终止类的执行,那么只有我从ServerSocket接收消息.
我的密码：
public class LoggingClient {
LinkedBlockingQueue<byte[]> messages = new LinkedBlockingQueue<byte[]>();
public static LoggingClient clientObj;
/*
* waiting 2 seconds for connecting centralized log server . If it's not reachable writing log's in local machine
* this log's will be collected on eclipse restart.
*/
public static final int SOCKET_TIMEOUT = 2000;
/**
* Server which the log server is currently running.
*/
public static final String SERVER = "bharathi";
/**
* Port which the log server is running.
*/
public static final int PORT = 10000;
/**
* Client socket used to connect the server .
*/
Socket client = null;
public static Logger logger = Logger.getLogger(LoggingClient.class.getName());
/**
* Used to write given logs into client output stream.
*/
DataOutputStream out = null;
public boolean isConnected = false;
/**
* Used for preventing instaniate LoggingClient without calling getInstance method.
*/
private LoggingClient(){
}
/**
* Clear's the socket and initialize new socket .
*/
public void init(){
try{
clear();
client = new Socket();
client.setTcpNoDelay(true);
client.connect(new InetSocketAddress(SERVER,PORT),SOCKET_TIMEOUT); //trying to make connection within two seconds.
out = new DataOutputStream(client.getOutputStream());
isConnected = true;
}catch(Exception e){
isConnected = false;
}
}
public static LoggingClient getInstance(){
if(clientObj == null){
clientObj = new LoggingClient();
}
return clientObj;
}
public void clear(){
try{
if(out != null){
out.close(); //if we call close method it invokes flush and then closes the DataOutputStream.
}
if(client != null){
client.close();
}
}catch(Exception e){
logger.log(Level.INFO,"Error while closing connection , reason {0}",e);
}finally{
try{
client.close();
out.close();
}catch(Exception e){
}
isConnected = false;
}
}
/**
* Adding this message into a queue . Scheduled thread will get this logs and push into central logging server.
* @param message
*/
public synchronized void write(byte[] message){
if(!isConnected){ //has connection.
init();
}
messages.add(message); //adding message to this queue . Background thread will collect the log message and sent it to the central log server.
}
/**
* Sending logs into central log server . If it's not reachable write into local machine.
* @param message
*/
public void sendLog(byte[] message){
try {
out.write(message);
out.flush();
} catch (Exception e) {
writeInLocalMachine(localLoggingPath, message); //in case of failure writing logs in local machine . Sync this logs when restart of eclipse.
}
}
/**
* Writing log's into his machine this log will be synced on plugin startup.
* @param file - File path.
* @param message - Message to log.
*/
public static void writeInLocalMachine(String file, byte[] message) {
FileOutputStream fileWriter = null;
File f = new File(file);
try {
if(!f.exists()){
f.createNewFile();
}
fileWriter = new FileOutputStream(file, true);
fileWriter.write(message);
fileWriter.flush();
} catch (Exception e) {
logger.log(
Level.WARNING,
"This may be due to given file not found in system , reason {0}",
e);
} finally {
try{
fileWriter.close();
}catch(Exception e){
}
}
}
/**
* @return - Recently received message from queue . Returns null if it's empty.
*/
public byte[] getMessage(){
return messages.poll(); //returns the head element and deletes it.
}
}
测试Java类以将消息发送到服务器套接字.
public class LogTest implements Runnable {
public static final String LINE_SEPARATOR = System.getProperty("line.separator");
@Override
public void run() {
while(true){
try{
LoggingClient client = LoggingClient.getInstance();
byte[] message = client.getMessage();
if(message != null){
client.sendLog(message);
}
}catch(Exception e){
}
}
}
public static void startSending(){
for(int i=0;i<10000;i++){
String msg = "msg number" + i+LINE_SEPARATOR;
LoggingClient.getInstance().write(msg.getBytes());
}
}
public static void main(String args[]){
LoggingClient c = LoggingClient.getInstance();
System.out.println("START TIME " + System.currentTimeMillis());
Thread t = new Thread(new LogTest(),"LOG MESSAGER");
t.start();
startSending();
System.out.println("END TIME " + System.currentTimeMillis());
}
发送的邮件将存储在文件中.
：
START TIME 1340815857896
END TIME 1340815858063
完成将消息放入队列.无限的while循环将负责将日志发送到服务器套接字.
为什么文件中存储的内容为0字节？ .如果我停止上课,为什么会收到发送的消息？
解决方法:
您发布了太多代码,但是在这种情况下,仅在流/程序关闭后才看到数据的情况下,您发布的代码太多了99次,问题是您在写入数据后从未刷新数据
内容总结
以上是互联网集市为您收集整理的java-使用DataOutputStream将消息写入客户端套接字的消息仅在关闭客户端套接字后才发送到服务器套接字,为什么？全部内容，希望文章能够帮你解决java-使用DataOutputStream将消息写入客户端套接字的消息仅在关闭客户端套接字后才发送到服务器套接字,为什么？所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】