java socket 自己充当tomcat

package test.com.ict.testcountry;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ConnectException;
import java.net.InetSocketAddress;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketTimeoutException;

/**
 * 用socket来收发http协议报文
 * @author luoguansong [email protected]
 */
public class SocketHttp {
    public static void main(String[] args) {
        Thread threadReceive=new Thread(new TestReceiveHttp());
        threadReceive.start();
//      Thread threadSend=new Thread(new TestSendHttp());
//      threadSend.start();
    }
}

class TestSendHttp implements Runnable{
    @Override
    public void run() {
        try {
            String path = "/";
            String host = "localhost";
            int port = 50000;
            Socket socket = new Socket();
            InetSocketAddress address=new InetSocketAddress(host, port);
            socket.connect(address,3000);
            OutputStreamWriter osw = new OutputStreamWriter(socket.getOutputStream(),"utf-8");
            osw.write("GET " + path + " HTTP/1.1\r\n");
            osw.write("Host: " + host + " \r\n");
            //http协议必须在报文头后面再加一个换行,通知服务器发送完成,不然服务器会一直等待
            osw.write("\r\n");
            osw.flush();
            socket.shutdownOutput();

            BufferedReader bufferedReader = new BufferedReader(
                    new InputStreamReader(socket.getInputStream(), "utf-8"));
            String line = null;
            while ((line = bufferedReader.readLine()) != null) {
                System.out.println(line);
            }
            osw.close();
            bufferedReader.close();
            socket.close();
        }catch (ConnectException e) {
            System.out.println("连接失败");
        }catch (SocketTimeoutException e) {
            System.out.println("连接超时");
        }catch (Exception e) {
            System.out.println(e.getMessage());
        }
    }
}

class TestReceiveHttp implements Runnable{
    @Override
    public void run() {
        ServerSocket server;
        Socket socket;
        try{
            server=new ServerSocket(50000);
            System.out.println("正在等待50000端口的请求");
            while(true){
                socket=server.accept();
                if(socket!=null){
                    new Thread(new TestReveiveThread(socket)).start();
                }
            }
        }catch (Exception e) {
            System.out.println("异常");
        }
    }
}

class TestReveiveThread implements Runnable{
    Socket socket;
    public TestReveiveThread(Socket s) {
        socket=s;
    }
    public void run() {
        try{
            BufferedReader bufferedReader = new BufferedReader(new InputStreamReader(socket.getInputStream(), "utf-8"));
            OutputStreamWriter osw = new OutputStreamWriter(socket.getOutputStream(),"utf-8");
            String line=null;
            while((line=bufferedReader.readLine())!=null){
                System.out.println(line);
                if(line.equals("")){
                    break;
                }
            }
            //模拟http请求到网站,然后把内容转发给当前的http请求
//          String path = "/";
//          String host = "www.oschina.net";
//          int port = 80;
//          Socket socket2 = new Socket(host, port);
//          OutputStreamWriter osw2 = new OutputStreamWriter(socket2.getOutputStream(),"utf-8");
//          osw2.write("GET " + path + " HTTP/1.1\r\n");
//          osw2.write("Host: " + host + " \r\n");
//          osw2.write("\r\n");
//          osw2.flush();
//          BufferedReader bufferedReader2 = new BufferedReader(new InputStreamReader(socket2.getInputStream(), "utf-8"));
//          String line2 = null;
//          while ((line2 = bufferedReader2.readLine()) != null) {
//              osw.write(line2+"\r\n");
//          }
//          bufferedReader2.close();
//          osw2.close();
//          socket2.close();
            osw.write("HTTP/1.1 200 OK\r\n");
            osw.write("Server: Apache-Coyote/1.1\r\n");
            osw.write("Set-Cookie: JSESSIONID=03493794995CE31A0F131787B6C6CBB2; Path=/; HttpOnly\r\n");
            osw.write("Content-Type: text/html;charset=UTF-8\r\n");
            osw.write("Transfer-Encoding: chunked\r\n");
            osw.write("Date: Tue, 19 May 2015 02:48:27 GMT\r\n");
            osw.write("\r\n");
            osw.write("c9\r\n");
            osw.write("<!DOCTYPE HTML PUBLIC \"-//W3C//DTD HTML 4.01 Transitional//EN\">\r\n");
            osw.write("<HTML>\r\n");
            osw.write("  <HEAD><TITLE>A Servlet</TITLE></HEAD>\r\n");
            osw.write("  <BODY>\r\n");
            osw.write("    This is class com.serv.myServ, using the GET method\r\n");
            osw.write("  </BODY>\r\n");
            osw.write("</HTML>\r\n");
            osw.write("\r\n");
            osw.write("0");
            osw.write("\r\n");
            osw.write("\r\n");
            osw.flush();
            bufferedReader.close();
            osw.close();
            socket.close();
        }catch (Exception e) {
            System.out.println("客户端接受异常"+e.getMessage());
        }
    }
}

在浏览器中输入 localhost:50000

时间: 2024-08-05 16:50:12

java socket 自己充当tomcat的相关文章

Java]Socket和ServerSocket服务器端接受数据

java socket 与  ServerSocket 某次写一个智能设备上传数据,数据每次三秒一条,然后使用c++写的客户端,没有对应java的源码,只能自己手写了,期间各种问题现在总结下 首先用的框架是ssh(我想用那个应该是没什么差别),因为是添加到web项目中的,so我想到的是tomcat启动的时候启动,于是首先必须要有的是后台程序,否则tomcat无法启动成功:话不多说,上源码... web.xml中我最后选用的是listener  监听还有一种是servlet  应该都可以 我最后选

使用Java Socket手撸一个http服务器

原文连接:使用Java Socket手撸一个http服务器 作为一个java后端,提供http服务可以说是基本技能之一了,但是你真的了解http协议么?你知道知道如何手撸一个http服务器么?tomcat的底层是怎么支持http服务的呢?大名鼎鼎的Servlet又是什么东西呢,该怎么使用呢? 在初学java时,socket编程是逃不掉的一章:虽然在实际业务项目中,使用这个的可能性基本为0,本篇博文将主要介绍如何使用socket来实现一个简单的http服务器功能,提供常见的get/post请求支持

java socket编程实例代码讲解

1.所谓socket通常也称作"套接字",用于描述IP地址和端口,是一个通信链的句柄.应用程序通常通过"套接字"向网络发出请求或者应答网络请求. 操作java socket时用到的最多的三个方法为: accept():主要用于服务器端产生"阻塞",等待客户端的链接请求,并且返回一个客户端的Socket实例: getInputStream():方法主要用来获得网络连接输入,同时返回一个InputStream对象实例: getOutputStream

java socket通信-传输文件图片--传输图片

ClientTcpSend.java   客户端发送类 package com.yjf.test; import java.io.DataOutputStream; import java.io.File; import java.io.FileInputStream; import java.net.InetSocketAddress; import java.net.Socket; public class ClientTcpSend { public static String clien

java socket 的参数选项解读(转)

java socket中有很多参数可以选择,这篇博客的目的是沉淀出这些参数的语义和用法,供自己以后查阅. 1.java socket参数选项总览 在JDK1.6中有如下参数选项: 1 public final static int TCP_NODELAY = 0x0001; 2 3 public final static int SO_BINDADDR = 0x000F; 4 5 public final static int SO_REUSEADDR = 0x04; 6 7 public fi

Java Socket编程

对于Java Socket编程而言,有两个概念,一个是ServerSocket,一个是Socket.服务端和客户端之间通过Socket建立连接,之后它们就可以进行通信了.首先ServerSocket将在服务端监听某个端口,当发现客户端有Socket来试图连接它时,它会accept该Socket的连接请求,同时在服务端建立一个对应的Socket与之进行通信.这样就有两个Socket了,客户端和服务端各一个. 客户端写服务端读 服务端代码 public class Server { public s

交通银行 Java Socket 服务启动 管理 WINDOWS 版

按照交通银行提供的无界面启动方法试验了很多次,都没有成功,所以自己动手用C# 知识写了一个. 小工具可以判断 交通银行 JAVA SOCKET 服务是否启动,并可以启动/关闭服务 主要代码如下: 判断服务是否启动 引用 :using System.Management; SelectQuery selectQuery = new SelectQuery(“select * from Win32_Process where Name = ‘java.exe’”); object cmdLine =

java socket服务器端搭建

import java.io.BufferedReader; import java.io.IOException; import java.io.InputStreamReader; import java.net.HttpURLConnection; import java.net.ServerSocket; import java.net.Socket; import java.net.URL; public class ServerBase extends Thread { public

Java Socket编程readLine返回null,read返回-1的条件

客户端正常关闭socket的时候,服务器端的readLine()方法会返回null,或者read()方法会返回-1 Java Socket编程readLine返回null,read返回-1的条件,布布扣,bubuko.com