现代化 Java Web 在线商城项目技术方案与实战开发指南

@Configuration
@EnableWebSecurity
public class SecurityConfig extends WebSecurityConfigurerAdapter {

    @Autowired
    private JwtAuthenticationEntryPoint jwtAuthenticationEntryPoint;

    @Autowired
    private JwtRequestFilter jwtRequestFilter;

    @Override
    protected void configure(HttpSecurity http) throws Exception {
        http.csrf().disable()
            .authorizeRequests()
            .antMatchers("/api/auth/**").permitAll()
            .anyRequest().authenticated()
            .and()
            .exceptionHandling().authenticationEntryPoint(jwtAuthenticationEntryPoint)
            .and()
            .sessionManagement().sessionCreationPolicy(SessionCreationPolicy.STATELESS);

        http.addFilterBefore(jwtRequestFilter, UsernamePasswordAuthenticationFilter.class);
    }
}

public interface ProductRepository extends JpaRepository<Product, Long> {
    List<Product> findByCategory(String category);
    List<Product> findByNameContaining(String keyword);
}

@Service
@Transactional
public class ProductServiceImpl implements ProductService {

    private final ProductRepository productRepository;

    @Override
    public List<Product> getAllProducts() {
        return productRepository.findAll();
    }

    @Override
    public Product getProductById(Long id) {
        return productRepository.findById(id)
                .orElseThrow(() -> new EntityNotFoundException("Product not found"));
    }

    @Override
    public Product saveProduct(Product product) {
        return productRepository.save(product);
    }
}

@Service
public class CartService {

    private static final String CART_KEY_PREFIX = "cart:";

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    public void addToCart(String userId, CartItem item) {
        String key = CART_KEY_PREFIX + userId;
        HashOperations<String, String, CartItem> hashOps = redisTemplate.opsForHash();
        
        if (hashOps.hasKey(key, item.getProductId().toString())) {
            CartItem existingItem = hashOps.get(key, item.getProductId().toString());
            existingItem.setQuantity(existingItem.getQuantity() + item.getQuantity());
            hashOps.put(key, item.getProductId().toString(), existingItem);
        } else {
            hashOps.put(key, item.getProductId().toString(), item);
        }
    }

    public List<CartItem> getCartItems(String userId) {
        String key = CART_KEY_PREFIX + userId;
        HashOperations<String, String, CartItem> hashOps = redisTemplate.opsForHash();
        return new ArrayList<>(hashOps.values(key));
    }
}

<template>
  <div class="product-list">
    <el-card v-for="product in products" :key="product.id" class="product-card">
      <template #header>
        <div class="card-header">{{ product.name }}</div>
      </template>
      <img :src="product.imageUrl" alt="Product Image" class="product-image">
      <div class="product-info">
        <p>Price: ¥{{ product.price }}</p>
        <p>Stock: {{ product.stock }}</p>
        <el-button @click="addToCart(product.id)">Add to Cart</el-button>
      </div>
    </el-card>
  </div>
</template>

<script lang="ts" setup>
import { ref, onMounted } from 'vue';
import axios from 'axios';

interface Product {
  id: number;
  name: string;
  price: number;
  stock: number;
  imageUrl: string;
}

const products = ref<Product[]>([]);

const fetchProducts = async () => {
  try {
    const response = await axios.get('/api/products');
    products.value = response.data;
  } catch (error) {
    console.error('Failed to fetch products:', error);
  }
};

const addToCart = (productId: number) => {
  axios.post('/api/cart/add', { productId, quantity: 1 })
    .then(() => {
      ElMessage.success('Added to cart successfully');
    })
    .catch(error => {
      ElMessage.error('Failed to add to cart');
      console.error(error);
    });
};

onMounted(fetchProducts);
</script>

import { defineStore } from 'pinia';
import axios from 'axios';

export const useCartStore = defineStore({
  id: 'cart',
  state: () => ({
    cartItems: [] as CartItem[],
    loading: false,
    error: null as string | null
  }),
  getters: {
    totalItems: (state) => state.cartItems.reduce((total, item) => total + item.quantity, 0),
    totalPrice: (state) => state.cartItems.reduce((total, item) => 
      total + (item.price * item.quantity), 0)
  },
  actions: {
    async fetchCartItems() {
      this.loading = true;
      try {
        const response = await axios.get('/api/cart');
        this.cartItems = response.data;
      } catch (error) {
        this.error = error.message;
      } finally {
        this.loading = false;
      }
    },
    async addToCart(productId: number, quantity: number = 1) {
      try {
        await axios.post('/api/cart/add', { productId, quantity });
        await this.fetchCartItems();
      } catch (error) {
        this.error = error.message;
      }
    }
  }
});

# 使用官方OpenJDK基础镜像
FROM openjdk:17-jdk-slim

# 设置工作目录
WORKDIR /app

# 复制Maven构建产物
COPY target/online-store.jar /app/online-store.jar

# 暴露应用端口
EXPOSE 8080

# 启动应用
CMD ["java", "-jar", "online-store.jar"]

apiVersion: apps/v1
kind: Deployment
metadata:
  name: product-service
  labels:
    app: product-service
spec:
  replicas: 3
  selector:
    matchLabels:
      app: product-service
  template:
    metadata:
      labels:
        app: product-service
    spec:
      containers:
      - name: product-service
        image: your-registry/product-service:1.0.0
        ports:
        - containerPort: 8080
        env:
        - name: SPRING_DATASOURCE_URL
          value: jdbc:mysql://mysql-service:3306/online_store
        - name: SPRING_DATASOURCE_USERNAME
          valueFrom:
            secretKeyRef:
              name: db-secret
              key: username
        - name: SPRING_DATASOURCE_PASSWORD
          valueFrom:
            secretKeyRef:
              name: db-secret
              key: password

---
apiVersion: v1
kind: Service
metadata:
  name: product-service
spec:
  selector:
    app: product-service
  ports:
    - protocol: TCP
      port: 80
      targetPort: 8080
  type: LoadBalancer

name: Build and Deploy

on:
  push:
    branches: [ main ]

jobs:
  build:
    runs-on: ubuntu-latest

    steps:
    - uses: actions/checkout@v3
    - name: Set up JDK 17
      uses: actions/setup-java@v3
      with:
        java-version: '17'
        distribution: 'temurin'
        cache: maven

    - name: Build with Maven
      run: mvn clean package -DskipTests

    - name: Build and push Docker image
      uses: docker/build-push-action@v4
      with:
        context: .
        push: true
        tags: your-registry/online-store:${{ github.sha }}

  deploy:
    needs: build
    runs-on: ubuntu-latest
    steps:
    - name: Deploy to Kubernetes
      uses: steebchen/kubectl@v2.0.0
      with:
        config: ${{ secrets.KUBE_CONFIG }}
        command: |
          kubectl set image deployment/online-store online-store=your-registry/online-store:${{ github.sha }}